pubsub

Documentation

Index

• Variables
• type Agent
• type Event

Variables

var (
	ErrAgentClosed   = errors.New("agent closed")
	ErrTopicNotFound = errors.New("topic not found")
)

Types

type Agent

type Agent interface {
	Publish(ctx context.Context, topic string, msg interface{}) error
	Subscribe(ctx context.Context, topics ...string) (<-chan Event, error)
	Close() error
}

type Event

type Event struct {
	Topic   string
	Payload string
}