notify

package
v0.11.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 22, 2026 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrOffsetNotifyClosed = errors.New("offset notify already closed")

Functions

This section is empty.

Types

type Offset 

type Offset struct {
	// contains filtered or unexported fields
}

func NewOffset 

func NewOffset(nextOffset int64) *Offset

func (*Offset) Close 

func (w *Offset) Close() error

func (*Offset) Set 

func (w *Offset) Set(nextOffset int64)

func (*Offset) Wait 

func (w *Offset) Wait(ctx context.Context, offset int64) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.