pubsub

type Config struct {
	Backend    Type
	Store      store.Store
	InstanceID string
}

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

type MemoryPublisher struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type Message struct {
	// ID identifies this message.
	ID string `json:"id,omitempty"`

	// Data is the actual data in the entry.
	Data []byte `json:"data"`

	// Labels represents the key-value pairs the entry is labeled with.
	Labels map[string]string `json:"labels,omitempty"`
}

type Publisher interface {
	Publish(message Message)
	Subscribe(c context.Context, receiver Receiver)
}

type Receiver func(Message)

type Type string