sbc

Jun 7, 2024

Changes in this version

+ type Encoder interface

+ Decode func(data []byte, v any) error

+ Encode func(v any) ([]byte, error)

+ type Holder struct

+ func NewHolder[T comparable](value T) *Holder[T]

+ func (e *Holder[T]) GetValue() T

+ func (e *Holder[T]) Updates(ctx context.Context) <-chan T

+ type KeyBuilder interface

+ BuildKey func(t T) string

+ type KeyBuilderFunc func(t T) string

+ func (k KeyBuilderFunc[T]) BuildKey(t T) string

+ type Subscriber struct

+ func NewSubscriber[T comparable](transport Transport, kb KeyBuilder[T], opts ...SubscriberOpt) *Subscriber[T]

+ func (s *Subscriber[T]) Subscribe(ctx context.Context) (*Subscription[T], error)

+ type SubscriberOpt func(*subscriberOpts)

+ func WithEncoder(encoder Encoder) SubscriberOpt

+ type Subscription struct

+ func NewSubscription[T comparable](transport Transport, encoder Encoder, kb KeyBuilder[T]) *Subscription[T]

+ func (sub *Subscription[T]) Get() T

+ func (sub *Subscription[T]) GetUpdates() <-chan T

+ func (sub *Subscription[T]) Unsubscribe()

+ type Transport interface

+ Current func(ctx context.Context, key string) ([]byte, error)

+ Updates func(ctx context.Context, key string) (<-chan []byte, error)