session

Documentation

Index

• func Accept(ini PreState, rolename string, id int, conn transport.Transport) error
• func Connect(ini PreState, rolename string, id int, conn transport.Transport) error
• func NewConn(roles []ParamRole) (map[string][]transport.Channel, error)
• func RoleRange(id, nw int)
• type Endpoint
  • func NewEndpoint(roleId, numRoles int, conn map[string][]transport.Channel) *Endpoint
  • func (e *Endpoint) CheckConnection()
• type LinearResource
  • func (res *LinearResource) Use()
• type ParamRole
• type PreState

Functions

func Accept

func Accept(ini PreState, rolename string, id int, conn transport.Transport) error

func Connect

func Connect(ini PreState, rolename string, id int, conn transport.Transport) error

func NewConn

func NewConn(roles []ParamRole) (map[string][]transport.Channel, error)

func RoleRange

func RoleRange(id, nw int)

Types

type Endpoint

type Endpoint struct {
	Id       int
	NumRoles int

	// guards Conn
	ConnMu sync.RWMutex
	Conn   map[string][]transport.Channel
	// contains filtered or unexported fields
}

func NewEndpoint

func NewEndpoint(roleId, numRoles int, conn map[string][]transport.Channel) *Endpoint

func (*Endpoint) CheckConnection

func (e *Endpoint) CheckConnection()

CheckConnection ensures connections initiated (by Accept) in Endpoint e are fully established.

type LinearResource

type LinearResource struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*LinearResource) Use

func (res *LinearResource) Use()

type ParamRole

type ParamRole struct {
	Name  string
	Param int
}

type PreState

type PreState interface {
	Ept() *Endpoint
}