session

Documentation

Index

• Constants
• Variables
• func FindById(id i.SessionId) (*sessionDesc, error)
• func Ipc_CallDesc(j job.Job, chanIdx int) (grpc.ServerDescriptor, grpc.GrpcServiceLayersIpc)
• func NewSession(expireInSecs time.Duration) *sessionDesc
• type StreamType

Constants

const (
	Sequential gRpcCallOder = iota
	OutOfOrder
)

const MaxChans = 8

Variables

var (
	ErrOutOfOrderCall    = errors.New("gRPC call is out of order")
	ErrNotStreamableCall = errors.New("gRPC call is not streamable")
	ErrStreamRequired    = errors.New("server-side streaming RPC requires a stream")
)

Functions

func FindById

func FindById(id i.SessionId) (*sessionDesc, error)

func Ipc_CallDesc

func Ipc_CallDesc(j job.Job, chanIdx int) (grpc.ServerDescriptor, grpc.GrpcServiceLayersIpc)

func NewSession

func NewSession(expireInSecs time.Duration) *sessionDesc

Types

type StreamType

type StreamType int