Versions in this module Expand all Collapse all v1 v1.1.0 Aug 27, 2023 v1.0.0 Feb 27, 2023 Changes in this version + var ErrFunctionAlreadyExist = errors.New("function already exist") + var IncomingQueueCap = 4096 + var OutgoingQueueCap = 4096 + 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 func(args value.Value, inC <-chan value.Value) (<-chan value.Value, error) + type Function func(args value.Value) (value.Value, error) + type IncomingStream func(args value.Value, inC <-chan value.Value) error + type OutgoingStream func(args value.Value) (<-chan value.Value, error) + type Server interface + AddChat func(name string, args valuerpc.TypeDef, cb Chat) error + AddFunction func(name string, args valuerpc.TypeDef, res valuerpc.TypeDef, cb Function) error + AddIncomingStream func(name string, args valuerpc.TypeDef, cb IncomingStream) error + AddOutgoingStream func(name string, args valuerpc.TypeDef, cb OutgoingStream) error + Close func() error + Run func() error + func NewDevelopmentServer(address string) (Server, error) + func NewServer(address string, logger *zap.Logger) (Server, error)
Go to main page