getdelaystatistics

package
v0.2.6 Latest Latest
Warning

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

 Go to latest Published: Dec 26, 2024 License: MIT Imports: 5 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) Descriptor() protoreflect.EnumDescriptor

func (DelayStatisticsType) Enum 

func (x DelayStatisticsType) Enum() *DelayStatisticsType

func (DelayStatisticsType) EnumDescriptor deprecated 

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

Deprecated: Use DelayStatisticsType.Descriptor instead.

func (DelayStatisticsType) Number 

func (x DelayStatisticsType) Number() protoreflect.EnumNumber

func (DelayStatisticsType) String 

func (x DelayStatisticsType) String() string

func (DelayStatisticsType) Type 

func (DelayStatisticsType) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

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 (x QotPushStage) Number() protoreflect.EnumNumber

func (QotPushStage) String 

func (x QotPushStage) String() string

func (QotPushStage) Type 

func (QotPushStage) Type() protoreflect.EnumType

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) Descriptor() protoreflect.EnumDescriptor

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) Type() protoreflect.EnumType

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 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.