tcpgetcommand

Documentation

Index

• type TcpGetCommandConfig
• type TcpGetCommandMessage
• type TcpGetCommandService
  • func NewTcpGetCommandService(config TcpGetCommandConfig) *TcpGetCommandService
  • func (svc *TcpGetCommandService) OnClose(c *gev.Connection)
  • func (svc *TcpGetCommandService) OnConnect(c *gev.Connection)
  • func (svc *TcpGetCommandService) OnMessage(c *gev.Connection, ctx interface{}, data []byte) (out interface{})
  • func (svc *TcpGetCommandService) Run(ctx context.Context, params ...interface{}) error

Types

type TcpGetCommandConfig

type TcpGetCommandConfig struct {
	ListenPort    int    `json:"listen_port"`
	ListenAddress string `json:"listen_address"`
}

type TcpGetCommandMessage

type TcpGetCommandMessage struct {
	Data       []byte
	RemoteAddr string
}

type TcpGetCommandService

type TcpGetCommandService struct {
	natsservice.NatsService
	// contains filtered or unexported fields
}

func NewTcpGetCommandService

func NewTcpGetCommandService(config TcpGetCommandConfig) *TcpGetCommandService

func (*TcpGetCommandService) OnClose

func (svc *TcpGetCommandService) OnClose(c *gev.Connection)

func (*TcpGetCommandService) OnConnect

func (svc *TcpGetCommandService) OnConnect(c *gev.Connection)

func (*TcpGetCommandService) OnMessage

func (svc *TcpGetCommandService) OnMessage(c *gev.Connection, ctx interface{}, data []byte) (out interface{})

func (*TcpGetCommandService) Run

func (svc *TcpGetCommandService) Run(ctx context.Context, params ...interface{}) error