mgmt

Documentation

Index

• type Addr
  • func NewAddr(host addr.HostAddr, ctrlPort, encapPort uint16) *Addr
  • func (a *Addr) ProtoId() proto.ProtoIdType
  • func (a *Addr) String() string
  • func (a *Addr) Write(b common.RawBytes) (int, error)
• type MsgIdType
  • func (m MsgIdType) String() string
  • func (m MsgIdType) Time() time.Time
• type Pld
  • func NewPld(id MsgIdType, u proto.Cerealizable) (*Pld, error)
  • func (p *Pld) ProtoId() proto.ProtoIdType
  • func (p *Pld) String() string
  • func (p *Pld) Union() (proto.Cerealizable, error)
• type Poll
  • func (p *Poll) ProtoId() proto.ProtoIdType
  • func (p *Poll) String() string
  • func (p *Poll) Write(b common.RawBytes) (int, error)
• type PollRep
  • func NewPollRep(a *Addr, s SessionType) *PollRep
• type PollReq
  • func NewPollReq(a *Addr, s SessionType) *PollReq
• type SessionType
  • func (st SessionType) MarshalJSON() ([]byte, error)
  • func (st SessionType) String() string

Types

type Addr

type Addr struct {
	Ctrl      *hostinfo.Host
	EncapPort uint16
}

func NewAddr

func NewAddr(host addr.HostAddr, ctrlPort, encapPort uint16) *Addr

func (*Addr) ProtoId

func (a *Addr) ProtoId() proto.ProtoIdType

func (*Addr) String

func (a *Addr) String() string

func (*Addr) Write

func (a *Addr) Write(b common.RawBytes) (int, error)

type MsgIdType

type MsgIdType uint64

func (MsgIdType) String

func (m MsgIdType) String() string

func (MsgIdType) Time

func (m MsgIdType) Time() time.Time

type Pld

type Pld struct {
	Id MsgIdType
	// contains filtered or unexported fields
}

func NewPld

func NewPld(id MsgIdType, u proto.Cerealizable) (*Pld, error)

NewPld creates a new SIG ctrl payload, containing the supplied Cerealizable instance.

func (*Pld) ProtoId

func (p *Pld) ProtoId() proto.ProtoIdType

func (*Pld) String

func (p *Pld) String() string

func (*Pld) Union

func (p *Pld) Union() (proto.Cerealizable, error)

type Poll

type Poll struct {
	Addr    *Addr
	Session SessionType
}

func (*Poll) ProtoId

func (p *Poll) ProtoId() proto.ProtoIdType

func (*Poll) String

func (p *Poll) String() string

func (*Poll) Write

func (p *Poll) Write(b common.RawBytes) (int, error)

type PollRep

type PollRep struct {
	*Poll
}

func NewPollRep

func NewPollRep(a *Addr, s SessionType) *PollRep

type PollReq

type PollReq struct {
	*Poll
}

func NewPollReq

func NewPollReq(a *Addr, s SessionType) *PollReq

type SessionType

type SessionType uint8

func (SessionType) MarshalJSON

func (st SessionType) MarshalJSON() ([]byte, error)

func (SessionType) String

func (st SessionType) String() string