protocol

package
v0.12.7 Latest Latest
Warning

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

 Go to latest Published: Dec 6, 2015 License: MPL-2.0 Imports: 6 Imported by: 7

Documentation

Index

Constants

View Source 
const (
	ProtocolName = "bep-relay"
)

Variables

View Source 
var (
	ResponseSuccess           = Response{0, "success"}
	ResponseNotFound          = Response{1, "not found"}
	ResponseAlreadyConnected  = Response{2, "already connected"}
	ResponseInternalError     = Response{99, "internal error"}
	ResponseUnexpectedMessage = Response{100, "unexpected message"}
)

Functions

func ReadMessage 

func ReadMessage(r io.Reader) (interface{}, error)

func WriteMessage 

func WriteMessage(w io.Writer, message interface{}) error

Types

type ConnectRequest 

type ConnectRequest struct {
	ID []byte // max:32
}

func (ConnectRequest) AppendXDR 

func (o ConnectRequest) AppendXDR(bs []byte) ([]byte, error)

func (*ConnectRequest) DecodeXDR 

func (o *ConnectRequest) DecodeXDR(r io.Reader) error

func (*ConnectRequest) DecodeXDRFrom 

func (o *ConnectRequest) DecodeXDRFrom(xr *xdr.Reader) error

func (ConnectRequest) EncodeXDR 

func (o ConnectRequest) EncodeXDR(w io.Writer) (int, error)

func (ConnectRequest) EncodeXDRInto 

func (o ConnectRequest) EncodeXDRInto(xw *xdr.Writer) (int, error)

func (ConnectRequest) MarshalXDR 

func (o ConnectRequest) MarshalXDR() ([]byte, error)

func (ConnectRequest) MustMarshalXDR 

func (o ConnectRequest) MustMarshalXDR() []byte

func (*ConnectRequest) UnmarshalXDR 

func (o *ConnectRequest) UnmarshalXDR(bs []byte) error

type JoinRelayRequest 

type JoinRelayRequest struct{}

func (JoinRelayRequest) AppendXDR 

func (o JoinRelayRequest) AppendXDR(bs []byte) ([]byte, error)

func (*JoinRelayRequest) DecodeXDR 

func (o *JoinRelayRequest) DecodeXDR(r io.Reader) error

func (*JoinRelayRequest) DecodeXDRFrom 

func (o *JoinRelayRequest) DecodeXDRFrom(xr *xdr.Reader) error

func (JoinRelayRequest) EncodeXDR 

func (o JoinRelayRequest) EncodeXDR(w io.Writer) (int, error)

func (JoinRelayRequest) EncodeXDRInto 

func (o JoinRelayRequest) EncodeXDRInto(xw *xdr.Writer) (int, error)

func (JoinRelayRequest) MarshalXDR 

func (o JoinRelayRequest) MarshalXDR() ([]byte, error)

func (JoinRelayRequest) MustMarshalXDR 

func (o JoinRelayRequest) MustMarshalXDR() []byte

func (*JoinRelayRequest) UnmarshalXDR 

func (o *JoinRelayRequest) UnmarshalXDR(bs []byte) error

type JoinSessionRequest 

type JoinSessionRequest struct {
	Key []byte // max:32
}

func (JoinSessionRequest) AppendXDR 

func (o JoinSessionRequest) AppendXDR(bs []byte) ([]byte, error)

func (*JoinSessionRequest) DecodeXDR 

func (o *JoinSessionRequest) DecodeXDR(r io.Reader) error

func (*JoinSessionRequest) DecodeXDRFrom 

func (o *JoinSessionRequest) DecodeXDRFrom(xr *xdr.Reader) error

func (JoinSessionRequest) EncodeXDR 

func (o JoinSessionRequest) EncodeXDR(w io.Writer) (int, error)

func (JoinSessionRequest) EncodeXDRInto 

func (o JoinSessionRequest) EncodeXDRInto(xw *xdr.Writer) (int, error)

func (JoinSessionRequest) MarshalXDR 

func (o JoinSessionRequest) MarshalXDR() ([]byte, error)

func (JoinSessionRequest) MustMarshalXDR 

func (o JoinSessionRequest) MustMarshalXDR() []byte

func (*JoinSessionRequest) UnmarshalXDR 

func (o *JoinSessionRequest) UnmarshalXDR(bs []byte) error

type Ping 

type Ping struct{}

func (Ping) AppendXDR 

func (o Ping) AppendXDR(bs []byte) ([]byte, error)

func (*Ping) DecodeXDR 

func (o *Ping) DecodeXDR(r io.Reader) error

func (*Ping) DecodeXDRFrom 

func (o *Ping) DecodeXDRFrom(xr *xdr.Reader) error

func (Ping) EncodeXDR 

func (o Ping) EncodeXDR(w io.Writer) (int, error)

func (Ping) EncodeXDRInto 

func (o Ping) EncodeXDRInto(xw *xdr.Writer) (int, error)

func (Ping) MarshalXDR 

func (o Ping) MarshalXDR() ([]byte, error)

func (Ping) MustMarshalXDR 

func (o Ping) MustMarshalXDR() []byte

func (*Ping) UnmarshalXDR 

func (o *Ping) UnmarshalXDR(bs []byte) error

type Pong 

type Pong struct{}

func (Pong) AppendXDR 

func (o Pong) AppendXDR(bs []byte) ([]byte, error)

func (*Pong) DecodeXDR 

func (o *Pong) DecodeXDR(r io.Reader) error

func (*Pong) DecodeXDRFrom 

func (o *Pong) DecodeXDRFrom(xr *xdr.Reader) error

func (Pong) EncodeXDR 

func (o Pong) EncodeXDR(w io.Writer) (int, error)

func (Pong) EncodeXDRInto 

func (o Pong) EncodeXDRInto(xw *xdr.Writer) (int, error)

func (Pong) MarshalXDR 

func (o Pong) MarshalXDR() ([]byte, error)

func (Pong) MustMarshalXDR 

func (o Pong) MustMarshalXDR() []byte

func (*Pong) UnmarshalXDR 

func (o *Pong) UnmarshalXDR(bs []byte) error

type RelayFull added in v0.12.4 

type RelayFull struct{}

func (RelayFull) AppendXDR added in v0.12.4 

func (o RelayFull) AppendXDR(bs []byte) ([]byte, error)

func (*RelayFull) DecodeXDR added in v0.12.4 

func (o *RelayFull) DecodeXDR(r io.Reader) error

func (*RelayFull) DecodeXDRFrom added in v0.12.4 

func (o *RelayFull) DecodeXDRFrom(xr *xdr.Reader) error

func (RelayFull) EncodeXDR added in v0.12.4 

func (o RelayFull) EncodeXDR(w io.Writer) (int, error)

func (RelayFull) EncodeXDRInto added in v0.12.4 

func (o RelayFull) EncodeXDRInto(xw *xdr.Writer) (int, error)

func (RelayFull) MarshalXDR added in v0.12.4 

func (o RelayFull) MarshalXDR() ([]byte, error)

func (RelayFull) MustMarshalXDR added in v0.12.4 

func (o RelayFull) MustMarshalXDR() []byte

func (*RelayFull) UnmarshalXDR added in v0.12.4 

func (o *RelayFull) UnmarshalXDR(bs []byte) error

type Response 

type Response struct {
	Code    int32
	Message string
}

func (Response) AppendXDR 

func (o Response) AppendXDR(bs []byte) ([]byte, error)

func (*Response) DecodeXDR 

func (o *Response) DecodeXDR(r io.Reader) error

func (*Response) DecodeXDRFrom 

func (o *Response) DecodeXDRFrom(xr *xdr.Reader) error

func (Response) EncodeXDR 

func (o Response) EncodeXDR(w io.Writer) (int, error)

func (Response) EncodeXDRInto 

func (o Response) EncodeXDRInto(xw *xdr.Writer) (int, error)

func (Response) MarshalXDR 

func (o Response) MarshalXDR() ([]byte, error)

func (Response) MustMarshalXDR 

func (o Response) MustMarshalXDR() []byte

func (*Response) UnmarshalXDR 

func (o *Response) UnmarshalXDR(bs []byte) error

type SessionInvitation 

type SessionInvitation struct {
	From         []byte // max:32
	Key          []byte // max:32
	Address      []byte // max:32
	Port         uint16
	ServerSocket bool
}

func (SessionInvitation) AddressString 

func (i SessionInvitation) AddressString() string

func (SessionInvitation) AppendXDR 

func (o SessionInvitation) AppendXDR(bs []byte) ([]byte, error)

func (*SessionInvitation) DecodeXDR 

func (o *SessionInvitation) DecodeXDR(r io.Reader) error

func (*SessionInvitation) DecodeXDRFrom 

func (o *SessionInvitation) DecodeXDRFrom(xr *xdr.Reader) error

func (SessionInvitation) EncodeXDR 

func (o SessionInvitation) EncodeXDR(w io.Writer) (int, error)

func (SessionInvitation) EncodeXDRInto 

func (o SessionInvitation) EncodeXDRInto(xw *xdr.Writer) (int, error)

func (SessionInvitation) GoString 

func (i SessionInvitation) GoString() string

func (SessionInvitation) MarshalXDR 

func (o SessionInvitation) MarshalXDR() ([]byte, error)

func (SessionInvitation) MustMarshalXDR 

func (o SessionInvitation) MustMarshalXDR() []byte

func (SessionInvitation) String 

func (i SessionInvitation) String() string

func (*SessionInvitation) UnmarshalXDR 

func (o *SessionInvitation) UnmarshalXDR(bs []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.