broadcast

type Broadcaster interface {
	Start(done chan (error)) error
	Shutdown(ctx context.Context) error
	// Returns true if the broadcaster fan-outs the same event
	// to all nodes. Such subscriber shouldn't be used with real pub/sub
	// engines (which are responsible for message distribution)
	IsFanout() bool
}

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

type HTTPConfig struct {
	// Port to listen on
	Port int `toml:"port"`
	// Path for HTTP broadast
	Path string `toml:"path"`
	// Secret token to authorize requests
	Secret string `toml:"secret"`
	// SecretBase is a secret used to generate a token if none provided
	SecretBase string
	// AddCORSHeaders enables adding CORS headers (so you can perform broadcast requests from the browser)
	// (We mostly need it for Stackblitz)
	AddCORSHeaders bool `toml:"cors_headers"`
	// CORSHosts contains a list of hostnames for CORS (comma-separated)
	CORSHosts string `toml:"cors_hosts"`
}

type Handler interface {
	// Handle broadcast message delivered only to this node (and pass it through the broker)
	// (Used by single-node broadcasters)
	HandleBroadcast(json []byte)
	// Handle broadcast message delivered to all nodes
	// (Used by fan-out broadcasters)
	HandlePubSub(json []byte)
}

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

type LegacyNATSConfig struct {
	Channel string              `toml:"channel"`
	NATS    *nconfig.NATSConfig `toml:"nats"`
}

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

type LegacyRedisConfig struct {
	Channel string               `toml:"channel"`
	Redis   *rconfig.RedisConfig `toml:"redis"`
}

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

type RedisConfig struct {
	Stream string `toml:"stream"`
	Group  string `toml:"group"`
	// Redis stream read wait time in milliseconds
	StreamReadBlockMilliseconds int64 `toml:"stream_read_block_milliseconds"`

	Redis *rconfig.RedisConfig `toml:"redis"`
}