sse

Documentation

Index

• Variables
• type Event
• type Streamer
  • func NewStreamer(pubsub pubsub.PubSub, namespace string) Streamer
  • func ProvideEventsStreaming(pubsub pubsub.PubSub) Streamer

Variables

var WireSet = wire.NewSet(
	ProvideEventsStreaming,
)

WireSet provides a wire set for this package.

Types

type Event

type Event struct {
	Type enum.SSEType    `json:"type"`
	Data json.RawMessage `json:"data"`
}

Event is a server sent event.

type Streamer

type Streamer interface {
	// Publish publishes an event to a given space ID.
	Publish(ctx context.Context, spaceID int64, eventType enum.SSEType, data any) error

	// Stream streams the events on a space ID.
	Stream(ctx context.Context, spaceID int64) (<-chan *Event, <-chan error, func(context.Context) error)
}

func NewStreamer

func NewStreamer(pubsub pubsub.PubSub, namespace string) Streamer

func ProvideEventsStreaming

func ProvideEventsStreaming(pubsub pubsub.PubSub) Streamer