stream

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

type Event struct {
	// APIKey is the SDKs API Key
	APIKey string
	// Environment is the ID of the environment that the event occured for
	Environment string
	// SSEEvent is the SSEEvent that was sent from the FeatureFlags server to the SDK
	SSEEvent *sse.Event

	// Err holds any errors encountered by the sdk while listening on the stream and this
	// field should be used to pass those errors on to the EventStreamListener to let it
	// know something has gone wrong on the stream it's listening on
	Err error
}

type EventStreamListener interface {
	// Pub publishes an event from the SDK to your Listener. Pub should implement
	// any backoff/retry logic as this is not handled in the SDK.
	Pub(ctx context.Context, event Event) error
}

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

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