ctrl_msg

Documentation

Index

• Constants
• func NewCircuitFailedMsg(message string) *channel.Message
• func NewCircuitSuccessMsg(sessionId, address string) *channel.Message
• func NewRouteResultFailedMessage(sessionId string, attempt int, rerr string) *channel.Message
• func NewRouteResultSuccessMsg(sessionId string, attempt int) *channel.Message
• type CreateCircuitRequest
  • func DecodeCreateCircuitRequest(m *channel.Message) (*CreateCircuitRequest, error)
  • func (self *CreateCircuitRequest) GetFingerprints() []string
  • func (self *CreateCircuitRequest) GetPeerData() map[uint32][]byte
  • func (self *CreateCircuitRequest) GetSessionToken() string
  • func (self *CreateCircuitRequest) GetTerminatorInstanceId() string
  • func (self *CreateCircuitRequest) ToMessage() *channel.Message
• type CreateCircuitResponse
  • func DecodeCreateCircuitResponse(m *channel.Message) (*CreateCircuitResponse, error)
  • func (self *CreateCircuitResponse) ToMessage() *channel.Message

Constants

const (
	CircuitSuccessType = 1001
	CircuitFailedType  = 1016
	RouteResultType    = 1022

	CircuitSuccessAddressHeader = 1100
	RouteResultAttemptHeader    = 1101
	RouteResultSuccessHeader    = 1102
	RouteResultErrorHeader      = 1103
	RouteResultErrorCodeHeader  = 1104

	TerminatorLocalAddressHeader  = 1110
	TerminatorRemoteAddressHeader = 1111

	InitiatorLocalAddressHeader  = 1112
	InitiatorRemoteAddressHeader = 1113

	ErrorTypeGeneric                 = 0
	ErrorTypeInvalidTerminator       = 1
	ErrorTypeMisconfiguredTerminator = 2
	ErrorTypeDialTimedOut            = 3
	ErrorTypeConnectionRefused       = 4

	CreateCircuitPeerDataHeader = 10

	CreateCircuitReqSessionTokenHeader         = 11
	CreateCircuitReqFingerprintsHeader         = 12
	CreateCircuitReqTerminatorInstanceIdHeader = 13

	CreateCircuitRespCircuitId  = 11
	CreateCircuitRespAddress    = 12
	CreateCircuitRespTagsHeader = 13

	HeaderResultErrorCode = 10

	ResultErrorRateLimited = 1
)

Functions

func NewCircuitFailedMsg

func NewCircuitFailedMsg(message string) *channel.Message

func NewCircuitSuccessMsg

func NewCircuitSuccessMsg(sessionId, address string) *channel.Message

func NewRouteResultFailedMessage

func NewRouteResultFailedMessage(sessionId string, attempt int, rerr string) *channel.Message

func NewRouteResultSuccessMsg

func NewRouteResultSuccessMsg(sessionId string, attempt int) *channel.Message

Types

type CreateCircuitRequest

type CreateCircuitRequest struct {
	SessionToken         string
	Fingerprints         []string
	TerminatorInstanceId string
	PeerData             map[uint32][]byte
}

func DecodeCreateCircuitRequest

func DecodeCreateCircuitRequest(m *channel.Message) (*CreateCircuitRequest, error)

func (*CreateCircuitRequest) GetFingerprints

func (self *CreateCircuitRequest) GetFingerprints() []string

func (*CreateCircuitRequest) GetPeerData

func (self *CreateCircuitRequest) GetPeerData() map[uint32][]byte

func (*CreateCircuitRequest) GetSessionToken

func (self *CreateCircuitRequest) GetSessionToken() string

func (*CreateCircuitRequest) GetTerminatorInstanceId

func (self *CreateCircuitRequest) GetTerminatorInstanceId() string

func (*CreateCircuitRequest) ToMessage

func (self *CreateCircuitRequest) ToMessage() *channel.Message

type CreateCircuitResponse

type CreateCircuitResponse struct {
	CircuitId string
	Address   string
	PeerData  map[uint32][]byte
	Tags      map[string]string
}

func DecodeCreateCircuitResponse

func DecodeCreateCircuitResponse(m *channel.Message) (*CreateCircuitResponse, error)

func (*CreateCircuitResponse) ToMessage

func (self *CreateCircuitResponse) ToMessage() *channel.Message