connection

Documentation

Index

• type Listener
• type SocketConnection
  • func NewTcpConnection(options TcpOpts, codecImpl codec.Codec) SocketConnection
• type Status
• type TcpConnection
  • func (conn TcpConnection) AddListener(listener Listener)
  • func (conn TcpConnection) Close(ex error) (err error)
  • func (conn *TcpConnection) Connect() error
  • func (conn TcpConnection) GetConnectionState() Status
  • func (conn TcpConnection) Send(frame model.Frame) error
  • func (conn TcpConnection) SetConnectionStatus(status Status)
• type TcpOpts

Types

type Listener

type Listener struct {
	OnStatusChange func(status Status)
	OnReceive      func(frame model.Frame)
	OnError        func(err error)
}

type SocketConnection

type SocketConnection interface {
	AddListener(listener Listener)
	GetConnectionState() Status
	SetConnectionStatus(status Status)
	Close(ex error) (err error)
	Send(frame model.Frame) error
	// contains filtered or unexported methods
}

func NewTcpConnection

func NewTcpConnection(options TcpOpts, codecImpl codec.Codec) SocketConnection

type Status

type Status string

const (
	CLOSED       Status = "CLOSED"
	CONNECTED    Status = "CONNECTED"
	CONNECTING   Status = "CONNECTING"
	NotConnected Status = "NOT_CONNECTED"
	ERROR        Status = "ERROR"
)

type TcpConnection

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

func (TcpConnection) AddListener

func (conn TcpConnection) AddListener(listener Listener)

func (TcpConnection) Close

func (conn TcpConnection) Close(ex error) (err error)

func (*TcpConnection) Connect

func (conn *TcpConnection) Connect() error

func (TcpConnection) GetConnectionState

func (conn TcpConnection) GetConnectionState() Status

func (TcpConnection) Send

func (conn TcpConnection) Send(frame model.Frame) error

func (TcpConnection) SetConnectionStatus

func (conn TcpConnection) SetConnectionStatus(status Status)

type TcpOpts

type TcpOpts struct {
	Host string `json:"host"`
}