stream

Documentation

Index

• Constants
• type Connection
  • func (conn *Connection) Receive() <-chan interface{}
• type Server
  • func NewServer(sdkRegistrar sdk.Registrar, metrics metrics.Reporter, log log.Logger, ...) Server
• type Stream
  • func NewStream(sdkId string, sdkClient sdk.Client, metrics metrics.Reporter, 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(sdkRegistrar sdk.Registrar, metrics metrics.Reporter, log log.Logger, serverType string) Server

type Stream

type Stream interface {
	CanEval(key string) bool
	IsInValidState() bool
	CreateConnection(key string, user model.UserAttrs) *Connection
	CloseConnection(conn *Connection, key string)
	Close()
}

func NewStream

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