realtime

Documentation

Index

• func ValidChannel(channel string) bool
• type Bus
• type HeaderBus
• type Publication
• type Publisher
  • func NewPublisher(bus Bus) *Publisher
  • func (p *Publisher) Publish(ctx context.Context, channel string, payload any) error

Functions

func ValidChannel

func ValidChannel(channel string) bool

Types

type Bus

type Bus interface {
	Publish(ctx context.Context, subject string, data []byte) error
}

type HeaderBus

type HeaderBus interface {
	PublishWithHeaders(ctx context.Context, subject string, headers map[string]string, data []byte) error
}

type Publication

type Publication struct {
	Data any `json:"data"`
}

type Publisher

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

func NewPublisher

func NewPublisher(bus Bus) *Publisher

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, channel string, payload any) error