tcpreceiver

Documentation

Index

• Constants
• func NewFactory(md *trigger.Metadata) trigger.Factory
• type BinPacket
• type MyTrigger
  • func (t *MyTrigger) Initialize(ctx trigger.InitContext) error
  • func (t *MyTrigger) Metadata() *trigger.Metadata
  • func (t *MyTrigger) Start() error
  • func (t *MyTrigger) Stop() error
• type MyTriggerFactory
  • func (t *MyTriggerFactory) New(config *trigger.Config) trigger.Trigger
• type ServerSocket
  • func NewServerSocket(address string) *ServerSocket
  • func (server *ServerSocket) Listen() error
• type Socket

Constants

const (
	ASCII_CR byte = 13
)

Functions

func NewFactory

func NewFactory(md *trigger.Metadata) trigger.Factory

NewFactory create a new Trigger factory

Types

type BinPacket

type BinPacket struct {
	Command           byte
	Sequence          []byte
	DataSegmentLength []byte
	DataSegment       []byte
	CRC16Check        []byte
}

BinPacket the orignal TCP packet

type MyTrigger

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

MyTrigger is a stub for your Trigger implementation

func (*MyTrigger) Initialize

func (t *MyTrigger) Initialize(ctx trigger.InitContext) error

Initialize implements trigger.Init.Initialize

func (*MyTrigger) Metadata

func (t *MyTrigger) Metadata() *trigger.Metadata

Metadata implements trigger.Trigger.Metadata

func (*MyTrigger) Start

func (t *MyTrigger) Start() error

Start implements trigger.Trigger.Start

func (*MyTrigger) Stop

func (t *MyTrigger) Stop() error

Stop implements trigger.Trigger.Start

type MyTriggerFactory

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

MyTriggerFactory My Trigger factory

func (*MyTriggerFactory) New

func (t *MyTriggerFactory) New(config *trigger.Config) trigger.Trigger

New Creates a new trigger instance for a given id

type ServerSocket

type ServerSocket struct {
	Address   string
	OnOpen    func(*Socket) error
	OnMessage func(*Socket, *bufio.Writer, *BinPacket) error
	OnClose   func(*Socket)
	OnError   func(*Socket, error)
	Listener  net.Listener
}

ServerSocket TCP server

func NewServerSocket

func NewServerSocket(address string) *ServerSocket

NewServerSocket init a serversocket

func (*ServerSocket) Listen

func (server *ServerSocket) Listen() error

Listen start to listner port

type Socket

type Socket struct {
	Type          byte
	Pin           string
	TerminalNum   string
	HardwareVer   string
	Conn          net.Conn
	ServerSocket  *ServerSocket
	RemoteAddrStr string
	CntrNum       string
	DevId         string
	CommandSeq    uint16
	Company       string
}

Socket TCP client