rpc

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 30, 2020 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ArgumentsField = "args" // allow multiple args if List value in function call
View Source 
var ClientIdField = "cid"
View Source 
var ErrorField = "err"
View Source 
var FunctionNameField = "fn"
View Source 
var HandshakeRequestId = int64(-1)
View Source 
var Magic = "vRPC"
View Source 
var MagicField = "m"
View Source 
var MessageTypeField = "t"
View Source 
var RequestIdField = "rid"
View Source 
var ResultField = "res" // allow multiple results if List in function call
View Source 
var TimeoutField = "sla"
View Source 
var ValueField = "val" // streaming value field
View Source 
var Version = 1.0
View Source 
var VersionField = "v"

Functions

func NewHandshakeRequest 

func NewHandshakeRequest(clientId int64) value.Map

func NewHandshakeResponse 

func NewHandshakeResponse() value.Map

func ValidMagicAndVersion 

func ValidMagicAndVersion(req value.Map) bool

Types

type MessageType 

type MessageType int64
const (
	HandshakeRequest MessageType = iota
	HandshakeResponse
	FunctionRequest
	FunctionResponse
	GetStreamRequest
	PutStreamRequest
	ChatRequest
	ErrorResponse
	StreamReady
	StreamValue
	StreamEnd
	CancelRequest
	ThrottleIncrease
	ThrottleDecrease
)

func (MessageType) Long 

func (t MessageType) Long() value.Number

type MsgConn 

type MsgConn interface {
	ReadMessage() (value.Map, error)

	WriteMessage(msg value.Map) error

	Close() error

	Conn() net.Conn
}

func NewMsgConn 

func NewMsgConn(conn net.Conn) MsgConn

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.