cluster

May 23, 2024

Changes in this version

+ var ErrClosed = errors.New("reader is closed")

+ type Cluster interface

+ CreateMembership func() (Membership, error)

+ type Member struct

+ Data string

+ ID string

+ type Membership interface

+ Data func() string

+ Deregister func(ctx context.Context) error

+ ID func() string

+ Register func(ctx context.Context) error

+ SetData func(data string) error

+ type Reader interface

+ Close func()

+ GetMembers func(ctx context.Context) ([]Member, error)

+ WatchMembers func(ctx context.Context) <-chan []Member