getdelaystatistics

package
v0.0.0-...-6059486 Latest Latest
Warning

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

Go to latest
Published: Nov 23, 2021 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Default_Response_RetType = int32(-400)
)

Default values for Response fields.

Variables

View Source
var (
	DelayStatisticsType_name = map[int32]string{
		0: "DelayStatisticsType_Unkonw",
		1: "DelayStatisticsType_QotPush",
		2: "DelayStatisticsType_ReqReply",
		3: "DelayStatisticsType_PlaceOrder",
	}
	DelayStatisticsType_value = map[string]int32{
		"DelayStatisticsType_Unkonw":     0,
		"DelayStatisticsType_QotPush":    1,
		"DelayStatisticsType_ReqReply":   2,
		"DelayStatisticsType_PlaceOrder": 3,
	}
)

Enum value maps for DelayStatisticsType.

View Source
var (
	QotPushStage_name = map[int32]string{
		0: "QotPushStage_Unkonw",
		1: "QotPushStage_SR2SS",
		2: "QotPushStage_SS2CR",
		3: "QotPushStage_CR2CS",
		4: "QotPushStage_SS2CS",
		5: "QotPushStage_SR2CS",
	}
	QotPushStage_value = map[string]int32{
		"QotPushStage_Unkonw": 0,
		"QotPushStage_SR2SS":  1,
		"QotPushStage_SS2CR":  2,
		"QotPushStage_CR2CS":  3,
		"QotPushStage_SS2CS":  4,
		"QotPushStage_SR2CS":  5,
	}
)

Enum value maps for QotPushStage.

View Source
var (
	QotPushType_name = map[int32]string{
		0: "QotPushType_Unkonw",
		1: "QotPushType_Price",
		2: "QotPushType_Ticker",
		3: "QotPushType_OrderBook",
		4: "QotPushType_Broker",
	}
	QotPushType_value = map[string]int32{
		"QotPushType_Unkonw":    0,
		"QotPushType_Price":     1,
		"QotPushType_Ticker":    2,
		"QotPushType_OrderBook": 3,
		"QotPushType_Broker":    4,
	}
)

Enum value maps for QotPushType.

View Source
var File_GetDelayStatistics_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type C2S

type C2S struct {
	TypeList     []int32 `protobuf:"varint,1,rep,name=typeList" json:"typeList,omitempty"`         //统计数据类型,DelayStatisticsType
	QotPushStage *int32  `protobuf:"varint,2,opt,name=qotPushStage" json:"qotPushStage,omitempty"` //行情推送统计的区间,行情推送统计时有效,QotPushStage
	SegmentList  []int32 `protobuf:"varint,3,rep,name=segmentList" json:"segmentList,omitempty"`   //统计分段,默认100ms以下以2ms分段,100ms以上以500,1000,2000,-1分段,-1表示无穷大。
	// contains filtered or unexported fields
}

func (*C2S) Descriptor deprecated

func (*C2S) Descriptor() ([]byte, []int)

Deprecated: Use C2S.ProtoReflect.Descriptor instead.

func (*C2S) GetQotPushStage

func (x *C2S) GetQotPushStage() int32

func (*C2S) GetSegmentList

func (x *C2S) GetSegmentList() []int32

func (*C2S) GetTypeList

func (x *C2S) GetTypeList() []int32

func (*C2S) ProtoMessage

func (*C2S) ProtoMessage()

func (*C2S) ProtoReflect

func (x *C2S) ProtoReflect() protoreflect.Message

func (*C2S) Reset

func (x *C2S) Reset()

func (*C2S) String

func (x *C2S) String() string

type DelayStatistics

type DelayStatistics struct {
	QotPushType *int32                 `protobuf:"varint,1,req,name=qotPushType" json:"qotPushType,omitempty"` //行情推送类型,QotPushType
	ItemList    []*DelayStatisticsItem `protobuf:"bytes,2,rep,name=itemList" json:"itemList,omitempty"`        //统计信息
	DelayAvg    *float32               `protobuf:"fixed32,3,req,name=delayAvg" json:"delayAvg,omitempty"`      //平均延迟
	Count       *int32                 `protobuf:"varint,4,req,name=count" json:"count,omitempty"`             //总包数
	// contains filtered or unexported fields
}

func (*DelayStatistics) Descriptor deprecated

func (*DelayStatistics) Descriptor() ([]byte, []int)

Deprecated: Use DelayStatistics.ProtoReflect.Descriptor instead.

func (*DelayStatistics) GetCount

func (x *DelayStatistics) GetCount() int32

func (*DelayStatistics) GetDelayAvg

func (x *DelayStatistics) GetDelayAvg() float32

func (*DelayStatistics) GetItemList

func (x *DelayStatistics) GetItemList() []*DelayStatisticsItem

func (*DelayStatistics) GetQotPushType

func (x *DelayStatistics) GetQotPushType() int32

func (*DelayStatistics) ProtoMessage

func (*DelayStatistics) ProtoMessage()

func (*DelayStatistics) ProtoReflect

func (x *DelayStatistics) ProtoReflect() protoreflect.Message

func (*DelayStatistics) Reset

func (x *DelayStatistics) Reset()

func (*DelayStatistics) String

func (x *DelayStatistics) String() string

type DelayStatisticsItem

type DelayStatisticsItem struct {

	//范围左闭右开,[begin,end)
	Begin           *int32   `protobuf:"varint,1,req,name=begin" json:"begin,omitempty"`                      //耗时范围起点,毫秒单位
	End             *int32   `protobuf:"varint,2,req,name=end" json:"end,omitempty"`                          //耗时范围结束,毫秒单位
	Count           *int32   `protobuf:"varint,3,req,name=count" json:"count,omitempty"`                      //个数
	Proportion      *float32 `protobuf:"fixed32,4,req,name=proportion" json:"proportion,omitempty"`           //占比, %
	CumulativeRatio *float32 `protobuf:"fixed32,5,req,name=cumulativeRatio" json:"cumulativeRatio,omitempty"` //累计占比, %
	// contains filtered or unexported fields
}

func (*DelayStatisticsItem) Descriptor deprecated

func (*DelayStatisticsItem) Descriptor() ([]byte, []int)

Deprecated: Use DelayStatisticsItem.ProtoReflect.Descriptor instead.

func (*DelayStatisticsItem) GetBegin

func (x *DelayStatisticsItem) GetBegin() int32

func (*DelayStatisticsItem) GetCount

func (x *DelayStatisticsItem) GetCount() int32

func (*DelayStatisticsItem) GetCumulativeRatio

func (x *DelayStatisticsItem) GetCumulativeRatio() float32

func (*DelayStatisticsItem) GetEnd

func (x *DelayStatisticsItem) GetEnd() int32

func (*DelayStatisticsItem) GetProportion

func (x *DelayStatisticsItem) GetProportion() float32

func (*DelayStatisticsItem) ProtoMessage

func (*DelayStatisticsItem) ProtoMessage()

func (*DelayStatisticsItem) ProtoReflect

func (x *DelayStatisticsItem) ProtoReflect() protoreflect.Message

func (*DelayStatisticsItem) Reset

func (x *DelayStatisticsItem) Reset()

func (*DelayStatisticsItem) String

func (x *DelayStatisticsItem) String() string

type DelayStatisticsType

type DelayStatisticsType int32
const (
	DelayStatisticsType_DelayStatisticsType_Unkonw     DelayStatisticsType = 0 //未知类型
	DelayStatisticsType_DelayStatisticsType_QotPush    DelayStatisticsType = 1 //行情推送统计
	DelayStatisticsType_DelayStatisticsType_ReqReply   DelayStatisticsType = 2 //请求回应统计
	DelayStatisticsType_DelayStatisticsType_PlaceOrder DelayStatisticsType = 3 //下单统计
)

func (DelayStatisticsType) Descriptor

func (DelayStatisticsType) Enum

func (DelayStatisticsType) EnumDescriptor deprecated

func (DelayStatisticsType) EnumDescriptor() ([]byte, []int)

Deprecated: Use DelayStatisticsType.Descriptor instead.

func (DelayStatisticsType) Number

func (DelayStatisticsType) String

func (x DelayStatisticsType) String() string

func (DelayStatisticsType) Type

func (*DelayStatisticsType) UnmarshalJSON deprecated

func (x *DelayStatisticsType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type PlaceOrderStatisticsItem

type PlaceOrderStatisticsItem struct {
	OrderID    *string  `protobuf:"bytes,1,req,name=orderID" json:"orderID,omitempty"`         //订单ID
	TotalCost  *float32 `protobuf:"fixed32,2,req,name=totalCost" json:"totalCost,omitempty"`   //总耗时,毫秒单位
	OpenDCost  *float32 `protobuf:"fixed32,3,req,name=openDCost" json:"openDCost,omitempty"`   //OpenD耗时,毫秒单位
	NetDelay   *float32 `protobuf:"fixed32,4,req,name=netDelay" json:"netDelay,omitempty"`     //网络耗时,非当时实际请求网络耗时,毫秒单位
	UpdateCost *float32 `protobuf:"fixed32,5,req,name=updateCost" json:"updateCost,omitempty"` //订单回包后到接收到订单下到交易所的耗时,毫秒单位
	// contains filtered or unexported fields
}

func (*PlaceOrderStatisticsItem) Descriptor deprecated

func (*PlaceOrderStatisticsItem) Descriptor() ([]byte, []int)

Deprecated: Use PlaceOrderStatisticsItem.ProtoReflect.Descriptor instead.

func (*PlaceOrderStatisticsItem) GetNetDelay

func (x *PlaceOrderStatisticsItem) GetNetDelay() float32

func (*PlaceOrderStatisticsItem) GetOpenDCost

func (x *PlaceOrderStatisticsItem) GetOpenDCost() float32

func (*PlaceOrderStatisticsItem) GetOrderID

func (x *PlaceOrderStatisticsItem) GetOrderID() string

func (*PlaceOrderStatisticsItem) GetTotalCost

func (x *PlaceOrderStatisticsItem) GetTotalCost() float32

func (*PlaceOrderStatisticsItem) GetUpdateCost

func (x *PlaceOrderStatisticsItem) GetUpdateCost() float32

func (*PlaceOrderStatisticsItem) ProtoMessage

func (*PlaceOrderStatisticsItem) ProtoMessage()

func (*PlaceOrderStatisticsItem) ProtoReflect

func (x *PlaceOrderStatisticsItem) ProtoReflect() protoreflect.Message

func (*PlaceOrderStatisticsItem) Reset

func (x *PlaceOrderStatisticsItem) Reset()

func (*PlaceOrderStatisticsItem) String

func (x *PlaceOrderStatisticsItem) String() string

type QotPushStage

type QotPushStage int32

某段时间的统计数据 SR表示服务器收到数据,目前只有港股支持SR字段,SS表示服务器发出数据 CR表示OpenD收到数据,CS表示OpenD发出数据

const (
	QotPushStage_QotPushStage_Unkonw QotPushStage = 0 // 未知
	QotPushStage_QotPushStage_SR2SS  QotPushStage = 1 //统计服务端处理耗时
	QotPushStage_QotPushStage_SS2CR  QotPushStage = 2 //统计网络耗时
	QotPushStage_QotPushStage_CR2CS  QotPushStage = 3 //统计OpenD处理耗时
	QotPushStage_QotPushStage_SS2CS  QotPushStage = 4 //统计服务器发出到OpenD发出的处理耗时
	QotPushStage_QotPushStage_SR2CS  QotPushStage = 5 //统计服务器收到数据到OpenD发出的处理耗时
)

func (QotPushStage) Descriptor

func (QotPushStage) Enum

func (x QotPushStage) Enum() *QotPushStage

func (QotPushStage) EnumDescriptor deprecated

func (QotPushStage) EnumDescriptor() ([]byte, []int)

Deprecated: Use QotPushStage.Descriptor instead.

func (QotPushStage) Number

func (QotPushStage) String

func (x QotPushStage) String() string

func (QotPushStage) Type

func (*QotPushStage) UnmarshalJSON deprecated

func (x *QotPushStage) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type QotPushType

type QotPushType int32

行情推送类型

const (
	QotPushType_QotPushType_Unkonw    QotPushType = 0 // 未知
	QotPushType_QotPushType_Price     QotPushType = 1 //最新价
	QotPushType_QotPushType_Ticker    QotPushType = 2 //逐笔
	QotPushType_QotPushType_OrderBook QotPushType = 3 //摆盘
	QotPushType_QotPushType_Broker    QotPushType = 4 //经纪队列
)

func (QotPushType) Descriptor

func (QotPushType) Enum

func (x QotPushType) Enum() *QotPushType

func (QotPushType) EnumDescriptor deprecated

func (QotPushType) EnumDescriptor() ([]byte, []int)

Deprecated: Use QotPushType.Descriptor instead.

func (QotPushType) Number

func (x QotPushType) Number() protoreflect.EnumNumber

func (QotPushType) String

func (x QotPushType) String() string

func (QotPushType) Type

func (*QotPushType) UnmarshalJSON deprecated

func (x *QotPushType) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type ReqReplyStatisticsItem

type ReqReplyStatisticsItem struct {
	ProtoID      *int32   `protobuf:"varint,1,req,name=protoID" json:"protoID,omitempty"`            //协议ID
	Count        *int32   `protobuf:"varint,2,req,name=count" json:"count,omitempty"`                //请求个数
	TotalCostAvg *float32 `protobuf:"fixed32,3,req,name=totalCostAvg" json:"totalCostAvg,omitempty"` //平均总耗时,毫秒单位
	OpenDCostAvg *float32 `protobuf:"fixed32,4,req,name=openDCostAvg" json:"openDCostAvg,omitempty"` //平均OpenD耗时,毫秒单位
	NetDelayAvg  *float32 `protobuf:"fixed32,5,req,name=netDelayAvg" json:"netDelayAvg,omitempty"`   //平均网络耗时,非当时实际请求网络耗时,毫秒单位
	IsLocalReply *bool    `protobuf:"varint,6,req,name=isLocalReply" json:"isLocalReply,omitempty"`  //是否本地直接回包,没有向服务器请求数据
	// contains filtered or unexported fields
}

func (*ReqReplyStatisticsItem) Descriptor deprecated

func (*ReqReplyStatisticsItem) Descriptor() ([]byte, []int)

Deprecated: Use ReqReplyStatisticsItem.ProtoReflect.Descriptor instead.

func (*ReqReplyStatisticsItem) GetCount

func (x *ReqReplyStatisticsItem) GetCount() int32

func (*ReqReplyStatisticsItem) GetIsLocalReply

func (x *ReqReplyStatisticsItem) GetIsLocalReply() bool

func (*ReqReplyStatisticsItem) GetNetDelayAvg

func (x *ReqReplyStatisticsItem) GetNetDelayAvg() float32

func (*ReqReplyStatisticsItem) GetOpenDCostAvg

func (x *ReqReplyStatisticsItem) GetOpenDCostAvg() float32

func (*ReqReplyStatisticsItem) GetProtoID

func (x *ReqReplyStatisticsItem) GetProtoID() int32

func (*ReqReplyStatisticsItem) GetTotalCostAvg

func (x *ReqReplyStatisticsItem) GetTotalCostAvg() float32

func (*ReqReplyStatisticsItem) ProtoMessage

func (*ReqReplyStatisticsItem) ProtoMessage()

func (*ReqReplyStatisticsItem) ProtoReflect

func (x *ReqReplyStatisticsItem) ProtoReflect() protoreflect.Message

func (*ReqReplyStatisticsItem) Reset

func (x *ReqReplyStatisticsItem) Reset()

func (*ReqReplyStatisticsItem) String

func (x *ReqReplyStatisticsItem) String() string

type Request

type Request struct {
	C2S *C2S `protobuf:"bytes,1,req,name=c2s" json:"c2s,omitempty"`
	// contains filtered or unexported fields
}

func (*Request) Descriptor deprecated

func (*Request) Descriptor() ([]byte, []int)

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetC2S

func (x *Request) GetC2S() *C2S

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) ProtoReflect

func (x *Request) ProtoReflect() protoreflect.Message

func (*Request) Reset

func (x *Request) Reset()

func (*Request) String

func (x *Request) String() string

type Response

type Response struct {
	RetType *int32  `protobuf:"varint,1,req,name=retType,def=-400" json:"retType,omitempty"` //返回结果,参见Common.RetType的枚举定义
	RetMsg  *string `protobuf:"bytes,2,opt,name=retMsg" json:"retMsg,omitempty"`             //返回结果描述
	ErrCode *int32  `protobuf:"varint,3,opt,name=errCode" json:"errCode,omitempty"`          //错误码,客户端一般通过retType和retMsg来判断结果和详情,errCode只做日志记录,仅在个别协议失败时对账用
	S2C     *S2C    `protobuf:"bytes,4,opt,name=s2c" json:"s2c,omitempty"`
	// contains filtered or unexported fields
}

func (*Response) Descriptor deprecated

func (*Response) Descriptor() ([]byte, []int)

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) GetErrCode

func (x *Response) GetErrCode() int32

func (*Response) GetRetMsg

func (x *Response) GetRetMsg() string

func (*Response) GetRetType

func (x *Response) GetRetType() int32

func (*Response) GetS2C

func (x *Response) GetS2C() *S2C

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) ProtoReflect

func (x *Response) ProtoReflect() protoreflect.Message

func (*Response) Reset

func (x *Response) Reset()

func (*Response) String

func (x *Response) String() string

type ResponseChan

type ResponseChan chan *Response

func (ResponseChan) Close

func (ch ResponseChan) Close()

func (ResponseChan) Send

func (ch ResponseChan) Send(b []byte) error

type S2C

type S2C struct {
	QotPushStatisticsList    []*DelayStatistics          `protobuf:"bytes,1,rep,name=qotPushStatisticsList" json:"qotPushStatisticsList,omitempty"`       //行情推送延迟统计
	ReqReplyStatisticsList   []*ReqReplyStatisticsItem   `protobuf:"bytes,2,rep,name=reqReplyStatisticsList" json:"reqReplyStatisticsList,omitempty"`     //请求延迟统计
	PlaceOrderStatisticsList []*PlaceOrderStatisticsItem `protobuf:"bytes,3,rep,name=placeOrderStatisticsList" json:"placeOrderStatisticsList,omitempty"` //下单延迟统计
	// contains filtered or unexported fields
}

func (*S2C) Descriptor deprecated

func (*S2C) Descriptor() ([]byte, []int)

Deprecated: Use S2C.ProtoReflect.Descriptor instead.

func (*S2C) GetPlaceOrderStatisticsList

func (x *S2C) GetPlaceOrderStatisticsList() []*PlaceOrderStatisticsItem

func (*S2C) GetQotPushStatisticsList

func (x *S2C) GetQotPushStatisticsList() []*DelayStatistics

func (*S2C) GetReqReplyStatisticsList

func (x *S2C) GetReqReplyStatisticsList() []*ReqReplyStatisticsItem

func (*S2C) ProtoMessage

func (*S2C) ProtoMessage()

func (*S2C) ProtoReflect

func (x *S2C) ProtoReflect() protoreflect.Message

func (*S2C) Reset

func (x *S2C) Reset()

func (*S2C) String

func (x *S2C) String() string

Jump to

Keyboard shortcuts

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