connector

Documentation

Index

• type Connector
• type FileConnector
  • func NewFileConnector(sdkKey string, path string) (FileConnector, error)
  • func (f FileConnector) Close() error
  • func (f FileConnector) Configurations(ctx context.Context, identifiers ...string) (evaluation.Configurations, error)
  • func (f FileConnector) Stream(ctx context.Context, updater Updater) error
  • func (f FileConnector) Variables(ctx context.Context, identifiers ...string) ([]evaluation.Variable, error)
• type Msg
• type Updater

Types

type Connector

type Connector interface {
	Configurations(ctx context.Context, identifiers ...string) (evaluation.Configurations, error)
	Variables(ctx context.Context, identifiers ...string) ([]evaluation.Variable, error)
	Stream(ctx context.Context, updater Updater) error
	Close() error
}

type FileConnector

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

func NewFileConnector

func NewFileConnector(sdkKey string, path string) (FileConnector, error)

func (FileConnector) Close

func (f FileConnector) Close() error

func (FileConnector) Configurations

func (f FileConnector) Configurations(ctx context.Context, identifiers ...string) (evaluation.Configurations, error)

func (FileConnector) Stream

func (f FileConnector) Stream(ctx context.Context, updater Updater) error

func (FileConnector) Variables

func (f FileConnector) Variables(ctx context.Context, identifiers ...string) ([]evaluation.Variable, error)

type Msg

type Msg struct {
	Event []byte
	Data  []byte
}

type Updater

type Updater interface {
	OnDisconnect()
	OnEvent(msg *Msg)
	OnConnect()
}