subscription

Documentation

Index

• Variables
• type Registry
  • func NewRegistry() *Registry
  • func (registry *Registry) Active() []string
  • func (registry *Registry) Get(id string) *Subscription
  • func (registry *Registry) Register(sub *Subscription)
  • func (registry *Registry) Remove(id string)
• type Subscription
  • func New(sub_id string, channel string, buffer_size uint) (*Subscription, error)
  • func (subscription *Subscription) Active() bool
  • func (subscription *Subscription) Close()
  • func (subscription *Subscription) Decode(ctx context.Context, value any) error
  • func (subscription *Subscription) Deliver(ctx context.Context, payload app.Payload) error
  • func (subscription *Subscription) Next(ctx context.Context) ([]byte, error)

Variables

var ErrInvalidChannel = errors.New("Expected channel, received empty string")

var ErrInvalidID = errors.New("Expected ID, received empty string")

Types

type Registry

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

func NewRegistry

func NewRegistry() *Registry

func (*Registry) Active

func (registry *Registry) Active() []string

func (*Registry) Get

func (registry *Registry) Get(id string) *Subscription

func (*Registry) Register

func (registry *Registry) Register(sub *Subscription)

func (*Registry) Remove

func (registry *Registry) Remove(id string)

type Subscription

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

func New

func New(sub_id string, channel string, buffer_size uint) (*Subscription, error)

func (*Subscription) Active

func (subscription *Subscription) Active() bool

func (*Subscription) Close

func (subscription *Subscription) Close()

func (*Subscription) Decode

func (subscription *Subscription) Decode(ctx context.Context, value any) error

func (*Subscription) Deliver

func (subscription *Subscription) Deliver(ctx context.Context, payload app.Payload) error

func (*Subscription) Next

func (subscription *Subscription) Next(ctx context.Context) ([]byte, error)