stream

Documentation

Index

• Constants
• type Connection
  • func (conn *Connection) Receive() <-chan interface{}
• type Server
  • func NewServer(sdkClients map[string]sdk.Client, metrics metrics.Handler, log log.Logger, ...) Server
• type Stream
  • func NewStream(sdkId string, sdkClient sdk.Client, metrics metrics.Handler, log log.Logger, ...) Stream

Constants

const AllFlagsDiscriminator = "[ALL]"

Types

type Connection

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

func (*Connection) Receive

func (conn *Connection) Receive() <-chan interface{}

type Server

type Server interface {
	GetStreamOrNil(sdkId string) Stream
	Close()
}

func NewServer

func NewServer(sdkClients map[string]sdk.Client, metrics metrics.Handler, log log.Logger, serverType string) Server

type Stream

type Stream interface {
	CreateConnection(key string, user sdk.UserAttrs) *Connection
	CloseConnection(conn *Connection, key string)
	Close()
}

func NewStream

func NewStream(sdkId string, sdkClient sdk.Client, metrics metrics.Handler, log log.Logger, serverType string) Stream