valueserver

Documentation

Index

• Variables
• func FunctionError(requestId value.Number, format string, args ...interface{}) value.Map
• func FunctionResult(requestId value.Number, result value.Value) value.Map
• func NewServingClient(clientId int64, conn vrpc.MsgConn, functionMap *sync.Map, logger *zap.Logger) *servingClient
• func NewServingRequest(ft functionType, requestId value.Number) *servingRequest
• func StreamEnd(requestId value.Number, val value.Value) value.Map
• func StreamReady(requestId value.Number) value.Map
• func StreamValue(requestId value.Number, val value.Value) value.Map
• type Chat
• type Function
• type IncomingStream
• type OutgoingStream
• type Server
  • func NewDevelopmentServer(address string) (Server, error)
  • func NewServer(address string, logger *zap.Logger) (Server, error)

Variables

var ErrFunctionAlreadyExist = errors.New("function already exist")

var IncomingQueueCap = 4096

var OutgoingQueueCap = 4096

Functions

func FunctionError

func FunctionError(requestId value.Number, format string, args ...interface{}) value.Map

func FunctionResult

func FunctionResult(requestId value.Number, result value.Value) value.Map

func NewServingClient

func NewServingClient(clientId int64, conn vrpc.MsgConn, functionMap *sync.Map, logger *zap.Logger) *servingClient

func NewServingRequest

func NewServingRequest(ft functionType, requestId value.Number) *servingRequest

func StreamEnd

func StreamEnd(requestId value.Number, val value.Value) value.Map

func StreamReady

func StreamReady(requestId value.Number) value.Map

func StreamValue

func StreamValue(requestId value.Number, val value.Value) value.Map

Types

type Chat

type Chat func(args value.Value, inC <-chan value.Value) (<-chan value.Value, error)

type Function

type Function func(args value.Value) (value.Value, error)

type IncomingStream

type IncomingStream func(args value.Value, inC <-chan value.Value) error

type OutgoingStream

type OutgoingStream func(args value.Value) (<-chan value.Value, error)

type Server

type Server interface {
	AddFunction(name string, args valuerpc.TypeDef, res valuerpc.TypeDef, cb Function) error

	// GET for client
	AddOutgoingStream(name string, args valuerpc.TypeDef, cb OutgoingStream) error

	// PUT for client
	AddIncomingStream(name string, args valuerpc.TypeDef, cb IncomingStream) error

	// Dual channel chat
	AddChat(name string, args valuerpc.TypeDef, cb Chat) error

	Run() error

	Close() error
}

func NewDevelopmentServer

func NewDevelopmentServer(address string) (Server, error)

func NewServer

func NewServer(address string, logger *zap.Logger) (Server, error)