pubsub

Documentation

Index

• type EventMessage
• type PubSub
  • func NewMemPubSub() PubSub
  • func NewPubSub(ctx context.Context, provider types.ProviderName, opts types.ProviderOptions, ...) (PubSub, error)

Types

type EventMessage

type EventMessage struct {
	User       string  `json:"user"`
	Event      string  `json:"event"`
	NumGuesses *uint16 `json:"num_guesses,omitempty"`
	GuessCount *uint16 `json:"guess_count,omitempty"`
}

type PubSub

type PubSub interface {
	Ack(ctx context.Context, realm types.RealmID, tenant string, ids []string) error
	Publish(ctx context.Context, realm types.RealmID, tenant string, event EventMessage) error
	// If there are no pending messages, implementations of Pull may choose to
	// wait a reasonable (~30 seconds) amount of time to see if a new message
	// turns up.
	Pull(ctx context.Context, realm types.RealmID, tenant string, maxRows uint16) ([]responses.TenantLogEntry, error)
}

func NewMemPubSub

func NewMemPubSub() PubSub

func NewPubSub

func NewPubSub(ctx context.Context, provider types.ProviderName, opts types.ProviderOptions, realmID types.RealmID) (PubSub, error)