session

package
v0.0.0-...-fc7dab2 Latest Latest
Warning

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

Go to latest
Published: Nov 4, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Sequential gRpcCallOder = iota
	OutOfOrder
)
View Source
const MaxChans = 8

Variables

View Source
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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL