sse

Documentation

Index

• func BuildSSEClient(options options.Options) (*sse.Client, error)
• func StartSSEConnection(client *sse.Client, apiConfigStore ConfigStore)
• type ConfigStore

Functions

func BuildSSEClient

func BuildSSEClient(options options.Options) (*sse.Client, error)

func StartSSEConnection

func StartSSEConnection(client *sse.Client, apiConfigStore ConfigStore)

Types

type ConfigStore

type ConfigStore interface {
	SetFromConfigsProto(configs *prefabProto.Configs)
	GetHighWatermark() int64
}