core

Documentation

Index

• type Config
  • func NewConfig(path string) (*Config, error)
• type Event
• type EventBus
  • func NewEventBus(options *EventBusOptions) *EventBus
  • func (bus *EventBus) Send(event *Event)
  • func (bus *EventBus) Subscribe(userID string, sessionID string, filter *topic.TopicFilter)
  • func (bus *EventBus) Unsubscribe(userID string, sessionID string, filter *topic.TopicFilter)
• type EventBusOptions
• type Node
• type Subscription

Types

type Config

type Config struct {
	Zone    string `config:"zone"`
	Addr    string `config:"addr"`
	JwksURL string `config:"jwks_url"`
	Nodes   []Node `config:"nodes"`
}

func NewConfig

func NewConfig(path string) (*Config, error)

type Event

type Event struct {
	UserID   string           `json:"user_id"`
	Topic    *topic.TopicName `json:"topic"`
	Name     string           `json:"name"`
	Data     any              `json:"data"`
	Metadata any              `json:"metadata"`
}

type EventBus

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

func NewEventBus

func NewEventBus(options *EventBusOptions) *EventBus

func (*EventBus) Send

func (bus *EventBus) Send(event *Event)

func (*EventBus) Subscribe

func (bus *EventBus) Subscribe(userID string, sessionID string, filter *topic.TopicFilter)

func (*EventBus) Unsubscribe

func (bus *EventBus) Unsubscribe(userID string, sessionID string, filter *topic.TopicFilter)

type EventBusOptions

type EventBusOptions struct {
	Server *sse.Server
}

type Node

type Node struct {
	URL    string `config:"url"`
	Zone   string `config:"zone"`
	Shared bool   `config:"shared"`
}

type Subscription

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