conn

Documentation

Index

• type Connect
• type DefaultTCPConnect
  • func (d *DefaultTCPConnect) Close() error
  • func (d *DefaultTCPConnect) Handshake() error
  • func (d *DefaultTCPConnect) LocalNodeID() string
  • func (d *DefaultTCPConnect) Read() *msg.Message
  • func (d *DefaultTCPConnect) RemoteAddr() string
  • func (d *DefaultTCPConnect) RemoteNodeID() string
  • func (d *DefaultTCPConnect) Status() Status
  • func (d *DefaultTCPConnect) Type() Type
  • func (d *DefaultTCPConnect) Write(payload *msg.Message)
• type DefaultUDPConnect
  • func (d *DefaultUDPConnect) Close() error
  • func (d *DefaultUDPConnect) Multicast() bool
  • func (d *DefaultUDPConnect) Read() *msg.Message
  • func (d *DefaultUDPConnect) Write(payload *msg.Message)
• type Status
  • func (s Status) Active() bool
  • func (s Status) Closed() bool
  • func (s Status) Init() bool
• type TCPConnect
  • func NewTCPConnect(c net.Conn, client bool, lNode string) (TCPConnect, error)
• type Type
• type UDPConnect
  • func NewUDPConnect(c net.Conn, multicast bool) UDPConnect

Types

type Connect

type Connect interface {
	Write(payload *msg.Message)
	Read() *msg.Message
	Close() error
}

type DefaultTCPConnect

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

func (*DefaultTCPConnect) Close

func (d *DefaultTCPConnect) Close() error

func (*DefaultTCPConnect) Handshake

func (d *DefaultTCPConnect) Handshake() error

func (*DefaultTCPConnect) LocalNodeID

func (d *DefaultTCPConnect) LocalNodeID() string

func (*DefaultTCPConnect) Read

func (d *DefaultTCPConnect) Read() *msg.Message

func (*DefaultTCPConnect) RemoteAddr

func (d *DefaultTCPConnect) RemoteAddr() string

func (*DefaultTCPConnect) RemoteNodeID

func (d *DefaultTCPConnect) RemoteNodeID() string

func (*DefaultTCPConnect) Status

func (d *DefaultTCPConnect) Status() Status

func (*DefaultTCPConnect) Type

func (d *DefaultTCPConnect) Type() Type

func (*DefaultTCPConnect) Write

func (d *DefaultTCPConnect) Write(payload *msg.Message)

type DefaultUDPConnect

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

func (*DefaultUDPConnect) Close

func (d *DefaultUDPConnect) Close() error

func (*DefaultUDPConnect) Multicast

func (d *DefaultUDPConnect) Multicast() bool

func (*DefaultUDPConnect) Read

func (d *DefaultUDPConnect) Read() *msg.Message

func (*DefaultUDPConnect) Write

func (d *DefaultUDPConnect) Write(payload *msg.Message)

type Status

type Status int

const (
	StatusInit      Status = 0
	StatusHandshake Status = 1
	StatusActive    Status = 2
	StatusClosed    Status = 3
)

func (Status) Active

func (s Status) Active() bool

func (Status) Closed

func (s Status) Closed() bool

func (Status) Init

func (s Status) Init() bool

type TCPConnect

type TCPConnect interface {
	RemoteNodeID() string
	RemoteAddr() string
	LocalNodeID() string
	Handshake() error
	Type() Type
	Status() Status
	Connect
}

func NewTCPConnect

func NewTCPConnect(c net.Conn, client bool, lNode string) (TCPConnect, error)

type Type

type Type string

const (
	TypeClient   Type = "client"
	TypeService  Type = "service"
	TypeLoopback Type = "Loopback"
)

type UDPConnect

type UDPConnect interface {
	Multicast() bool
	Connect
}

func NewUDPConnect

func NewUDPConnect(c net.Conn, multicast bool) UDPConnect