trans

package
v0.0.0-...-72ebda1 Latest Latest
Warning

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

Go to latest
Published: Nov 3, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetParam1

func GetParam1() []byte

GetParam1 获取第一个参数

func GetParam2

func GetParam2() []byte

GetParam2 获取第二个参数

func GetParam3

func GetParam3() []byte

GetParam3 获取第三个参数

Types

type BaseEntry

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

BaseEntry the base transact

func (*BaseEntry) GetDatas

func (base *BaseEntry) GetDatas() int

GetDatas init the transact

type Entry

type Entry interface {
	MakeSendParams() []byte
	ParseRespond(params []byte)
}

Entry 一个接口类型,实现实体的参数组织及返回解析

type GetStockCount

type GetStockCount struct {
	BaseEntry
	Count  uint16 // 股票个数
	Market uint16 // 市场代码
}

GetStockCount 获取股票个数

func (*GetStockCount) MakeSendParams

func (entry *GetStockCount) MakeSendParams() []byte

MakeSendParams 创建获取个数的字节序列

func (*GetStockCount) ParseRespond

func (entry *GetStockCount) ParseRespond(params []byte)

ParseRespond 解析返回值

type GetStockList

type GetStockList struct {
	BaseEntry
	Market uint16       // 市场代码
	Start  uint16       // 入参,从多少开始
	Stocks []StockEntry // 股票列表
	// contains filtered or unexported fields
}

GetStockList 获取股票列表

func (*GetStockList) MakeSendParams

func (entry *GetStockList) MakeSendParams() []byte

MakeSendParams a

func (*GetStockList) ParseRespond

func (entry *GetStockList) ParseRespond(params []byte)

ParseRespond 解析返回值

type Status

type Status int32

Status 定义引擎的状态

const (
	StatusStop    Status = 0
	StatusRunning Status = 1
)

定义引擎的状态

type StockEntry

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

StockEntry 定义

type Transfer

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

Transfer comment init the base transfer

func NEW

func NEW(ipaddr string, port uint16) Transfer

NEW 初始化创建一个

func (*Transfer) AddEntry

func (trans *Transfer) AddEntry(entry Entry)

AddEntry 将一个请求放入至请求池子

func (*Transfer) GetTransSize

func (trans *Transfer) GetTransSize() uint32

GetTransSize 获取下行的流量值

func (*Transfer) GetWeight

func (trans *Transfer) GetWeight() uint32

GetWeight 获取成功的权重

func (*Transfer) Init

func (trans *Transfer) Init() int

Init 初始化一次链接

func (*Transfer) Match

func (trans *Transfer) Match(ipaddr string, port uint16) bool

Match 判断是否存在

func (*Transfer) Start

func (trans *Transfer) Start()

Start 发送连接

func (*Transfer) Stop

func (trans *Transfer) Stop()

Stop 停止接收

func (*Transfer) Wait

func (trans *Transfer) Wait()

Wait 等待结果完成

Jump to

Keyboard shortcuts

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