tcpgetcommand

package
v1.1.38 Latest Latest
Warning

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

Go to latest
Published: Apr 27, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Directories

Path Synopsis
cmd

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL