core

Documentation

Index

• func Publish(topic string, message []byte) error
• type InputError
  • func (e InputError) Error() string
• type Subscriber
  • func NewSub(topic string, group string) (*Subscriber, error)
  • func (s Subscriber) String() string
  • func (s *Subscriber) Subscribe(ctx context.Context, handler func([]byte) error) error

Functions

func Publish

func Publish(topic string, message []byte) error

Stores the message on disk then publishes message to all open gates

Types

type InputError

type InputError struct {
	Msg string
}

func (InputError) Error

func (e InputError) Error() string

type Subscriber

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

func NewSub

func NewSub(topic string, group string) (*Subscriber, error)

func (Subscriber) String

func (s Subscriber) String() string

func (*Subscriber) Subscribe

func (s *Subscriber) Subscribe(ctx context.Context, handler func([]byte) error) error

Invokes handler on every new message. Blocks until context is canceled.