subscription

package

v0.0.1 Latest Latest Go to latest Published: May 14, 2026 License: MIT Imports: 6 Imported by: 0

Details

This section is empty.

View Source

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

View Source

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

This section is empty.

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

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 struct {
	// contains filtered or unexported fields
}

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)