stream

Documentation

Index

• type Connection
• type Message
• type SSEClient
  • func NewSSEClient(apiKey string, token string, client *sse.Client, cache cache.Cache, ...) *SSEClient
  • func (c *SSEClient) Connect(environment string) error
  • func (c *SSEClient) OnDisconnect(f func() error) error

Types

type Connection

type Connection interface {
	Connect(environment string) error
	OnDisconnect(func() error) error
}

Connection is simple interface for streams

type Message

type Message struct {
	Event      string `json:"event"`
	Domain     string `json:"domain"`
	Identifier string `json:"identifier"`
	Version    int    `json:"version"`
}

Message is basic object for marshalling data from ff stream

type SSEClient

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

SSEClient is Server Send Event object

func NewSSEClient

func NewSSEClient(
	apiKey string,
	token string,
	client *sse.Client,
	cache cache.Cache,
	api rest.ClientWithResponsesInterface,
	logger logger.Logger,
) *SSEClient

NewSSEClient creates an object for stream interactions

func (*SSEClient) Connect

func (c *SSEClient) Connect(environment string) error

Connect will subscribe to SSE stream

func (*SSEClient) OnDisconnect

func (c *SSEClient) OnDisconnect(f func() error) error

OnDisconnect will trigger func f when stream disconnects