session

Documentation

Index

• func JSON(context view.Context) *jsonSession
• func NewJSON(context view.Context, caller view.View, party view.Identity) (*jsonSession, error)
• func ReadFirstMessageOrPanic(context view.Context) []byte
• func ReadMessageWithTimeout(session Session, d time.Duration) ([]byte, error)
• type LocalBidirectionalChannel
  • func NewLocalBidirectionalChannel(caller string, contextID string, endpoint string, pkid []byte) (*LocalBidirectionalChannel, error)
  • func (c *LocalBidirectionalChannel) LeftSession() view.Session
  • func (c *LocalBidirectionalChannel) RightSession() view.Session
• type Session
  • func ReadFirstMessage(context view.Context) (Session, []byte, error)

Functions

func JSON

func JSON(context view.Context) *jsonSession

func NewJSON

func NewJSON(context view.Context, caller view.View, party view.Identity) (*jsonSession, error)

func ReadFirstMessageOrPanic

func ReadFirstMessageOrPanic(context view.Context) []byte

func ReadMessageWithTimeout

func ReadMessageWithTimeout(session Session, d time.Duration) ([]byte, error)

Types

type LocalBidirectionalChannel

type LocalBidirectionalChannel struct {
	// contains filtered or unexported fields
}

LocalBidirectionalChannel is a bidirectional channel that is used to simulate a session between two views (let's call them L and R) running in the same process.

func NewLocalBidirectionalChannel

func NewLocalBidirectionalChannel(caller string, contextID string, endpoint string, pkid []byte) (*LocalBidirectionalChannel, error)

NewLocalBidirectionalChannel creates a new bidirectional channel

func (*LocalBidirectionalChannel) LeftSession

func (c *LocalBidirectionalChannel) LeftSession() view.Session

LeftSession returns the session from the L to R

func (*LocalBidirectionalChannel) RightSession

func (c *LocalBidirectionalChannel) RightSession() view.Session

RightSession returns the session from the R to L

type Session

type Session interface {
	view.Session
}

func ReadFirstMessage

func ReadFirstMessage(context view.Context) (Session, []byte, error)