Documentation ¶
Overview ¶
Package statf comment This file was generated by tars2go 1.1.7 Generated from StatF.tars
Package statf comment This file was generated by tars2go 1.1.7 Generated from StatF.tars
Index ¶
- type ProxyInfo
- func (st *ProxyInfo) ReadBlock(readBuf *codec.Reader, tag byte, require bool) error
- func (st *ProxyInfo) ReadFrom(readBuf *codec.Reader) error
- func (st *ProxyInfo) ResetDefault()
- func (st *ProxyInfo) WriteBlock(buf *codec.Buffer, tag byte) error
- func (st *ProxyInfo) WriteTo(buf *codec.Buffer) (err error)
- type StatF
- func (obj *StatF) Dispatch(tarsCtx context.Context, val interface{}, tarsReq *requestf.RequestPacket, ...) (err error)
- func (obj *StatF) ReportMicMsg(msg map[StatMicMsgHead]StatMicMsgBody, bFromClient bool, ...) (ret int32, err error)
- func (obj *StatF) ReportMicMsgOneWayWithContext(tarsCtx context.Context, msg map[StatMicMsgHead]StatMicMsgBody, ...) (ret int32, err error)
- func (obj *StatF) ReportMicMsgWithContext(tarsCtx context.Context, msg map[StatMicMsgHead]StatMicMsgBody, ...) (ret int32, err error)
- func (obj *StatF) ReportSampleMsg(msg []StatSampleMsg, opts ...map[string]string) (ret int32, err error)
- func (obj *StatF) ReportSampleMsgOneWayWithContext(tarsCtx context.Context, msg []StatSampleMsg, opts ...map[string]string) (ret int32, err error)
- func (obj *StatF) ReportSampleMsgWithContext(tarsCtx context.Context, msg []StatSampleMsg, opts ...map[string]string) (ret int32, err error)
- func (obj *StatF) SetServant(servant m.Servant)
- func (obj *StatF) TarsSetProtocol(p m.Protocol)
- func (obj *StatF) TarsSetTimeout(timeout int)
- type StatFServant
- type StatFServantWithContext
- type StatMicMsgBody
- func (st *StatMicMsgBody) ReadBlock(readBuf *codec.Reader, tag byte, require bool) error
- func (st *StatMicMsgBody) ReadFrom(readBuf *codec.Reader) error
- func (st *StatMicMsgBody) ResetDefault()
- func (st *StatMicMsgBody) WriteBlock(buf *codec.Buffer, tag byte) error
- func (st *StatMicMsgBody) WriteTo(buf *codec.Buffer) (err error)
- type StatMicMsgHead
- func (st *StatMicMsgHead) ReadBlock(readBuf *codec.Reader, tag byte, require bool) error
- func (st *StatMicMsgHead) ReadFrom(readBuf *codec.Reader) error
- func (st *StatMicMsgHead) ResetDefault()
- func (st *StatMicMsgHead) WriteBlock(buf *codec.Buffer, tag byte) error
- func (st *StatMicMsgHead) WriteTo(buf *codec.Buffer) (err error)
- type StatSampleMsg
- func (st *StatSampleMsg) ReadBlock(readBuf *codec.Reader, tag byte, require bool) error
- func (st *StatSampleMsg) ReadFrom(readBuf *codec.Reader) error
- func (st *StatSampleMsg) ResetDefault()
- func (st *StatSampleMsg) WriteBlock(buf *codec.Buffer, tag byte) error
- func (st *StatSampleMsg) WriteTo(buf *codec.Buffer) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProxyInfo ¶
type ProxyInfo struct {
BFromClient bool `json:"bFromClient"`
}
ProxyInfo struct implement
func (*ProxyInfo) ResetDefault ¶ added in v1.2.0
func (st *ProxyInfo) ResetDefault()
func (*ProxyInfo) WriteBlock ¶
WriteBlock encode struct
type StatF ¶
type StatF struct {
// contains filtered or unexported fields
}
StatF struct
func (*StatF) Dispatch ¶
func (obj *StatF) Dispatch(tarsCtx context.Context, val interface{}, tarsReq *requestf.RequestPacket, tarsResp *requestf.ResponsePacket, withContext bool) (err error)
Dispatch is used to call the server side implement for the method defined in the tars file. withContext shows using context or not.
func (*StatF) ReportMicMsg ¶
func (obj *StatF) ReportMicMsg(msg map[StatMicMsgHead]StatMicMsgBody, bFromClient bool, opts ...map[string]string) (ret int32, err error)
ReportMicMsg is the proxy function for the method defined in the tars file, with the context
func (*StatF) ReportMicMsgOneWayWithContext ¶ added in v1.2.0
func (obj *StatF) ReportMicMsgOneWayWithContext(tarsCtx context.Context, msg map[StatMicMsgHead]StatMicMsgBody, bFromClient bool, opts ...map[string]string) (ret int32, err error)
ReportMicMsgOneWayWithContext is the proxy function for the method defined in the tars file, with the context
func (*StatF) ReportMicMsgWithContext ¶
func (obj *StatF) ReportMicMsgWithContext(tarsCtx context.Context, msg map[StatMicMsgHead]StatMicMsgBody, bFromClient bool, opts ...map[string]string) (ret int32, err error)
ReportMicMsgWithContext is the proxy function for the method defined in the tars file, with the context
func (*StatF) ReportSampleMsg ¶
func (obj *StatF) ReportSampleMsg(msg []StatSampleMsg, opts ...map[string]string) (ret int32, err error)
ReportSampleMsg is the proxy function for the method defined in the tars file, with the context
func (*StatF) ReportSampleMsgOneWayWithContext ¶ added in v1.2.0
func (obj *StatF) ReportSampleMsgOneWayWithContext(tarsCtx context.Context, msg []StatSampleMsg, opts ...map[string]string) (ret int32, err error)
ReportSampleMsgOneWayWithContext is the proxy function for the method defined in the tars file, with the context
func (*StatF) ReportSampleMsgWithContext ¶
func (obj *StatF) ReportSampleMsgWithContext(tarsCtx context.Context, msg []StatSampleMsg, opts ...map[string]string) (ret int32, err error)
ReportSampleMsgWithContext is the proxy function for the method defined in the tars file, with the context
func (*StatF) SetServant ¶
SetServant sets servant for the service.
func (*StatF) TarsSetProtocol ¶ added in v1.2.0
TarsSetProtocol sets the protocol for the servant.
func (*StatF) TarsSetTimeout ¶
TarsSetTimeout sets the timeout for the servant which is in ms.
type StatFServant ¶ added in v1.3.0
type StatFServant interface { ReportMicMsg(msg map[StatMicMsgHead]StatMicMsgBody, bFromClient bool) (ret int32, err error) ReportSampleMsg(msg []StatSampleMsg) (ret int32, err error) }
type StatFServantWithContext ¶ added in v1.3.0
type StatFServantWithContext interface { ReportMicMsg(tarsCtx context.Context, msg map[StatMicMsgHead]StatMicMsgBody, bFromClient bool) (ret int32, err error) ReportSampleMsg(tarsCtx context.Context, msg []StatSampleMsg) (ret int32, err error) }
type StatMicMsgBody ¶
type StatMicMsgBody struct { Count int32 `json:"count"` TimeoutCount int32 `json:"timeoutCount"` ExecCount int32 `json:"execCount"` IntervalCount map[int32]int32 `json:"intervalCount"` TotalRspTime int64 `json:"totalRspTime"` MaxRspTime int32 `json:"maxRspTime"` MinRspTime int32 `json:"minRspTime"` }
StatMicMsgBody struct implement
func (*StatMicMsgBody) ReadFrom ¶
func (st *StatMicMsgBody) ReadFrom(readBuf *codec.Reader) error
ReadFrom reads from readBuf and put into struct.
func (*StatMicMsgBody) ResetDefault ¶ added in v1.2.0
func (st *StatMicMsgBody) ResetDefault()
func (*StatMicMsgBody) WriteBlock ¶
func (st *StatMicMsgBody) WriteBlock(buf *codec.Buffer, tag byte) error
WriteBlock encode struct
type StatMicMsgHead ¶
type StatMicMsgHead struct { MasterName string `json:"masterName"` SlaveName string `json:"slaveName"` InterfaceName string `json:"interfaceName"` MasterIp string `json:"masterIp"` SlaveIp string `json:"slaveIp"` SlavePort int32 `json:"slavePort"` ReturnValue int32 `json:"returnValue"` SlaveSetName string `json:"slaveSetName"` SlaveSetArea string `json:"slaveSetArea"` SlaveSetID string `json:"slaveSetID"` TarsVersion string `json:"tarsVersion"` }
StatMicMsgHead struct implement
func (*StatMicMsgHead) ReadFrom ¶
func (st *StatMicMsgHead) ReadFrom(readBuf *codec.Reader) error
ReadFrom reads from readBuf and put into struct.
func (*StatMicMsgHead) ResetDefault ¶ added in v1.2.0
func (st *StatMicMsgHead) ResetDefault()
func (*StatMicMsgHead) WriteBlock ¶
func (st *StatMicMsgHead) WriteBlock(buf *codec.Buffer, tag byte) error
WriteBlock encode struct
type StatSampleMsg ¶
type StatSampleMsg struct { Unid string `json:"unid"` MasterName string `json:"masterName"` SlaveName string `json:"slaveName"` InterfaceName string `json:"interfaceName"` MasterIp string `json:"masterIp"` SlaveIp string `json:"slaveIp"` Depth int32 `json:"depth"` Width int32 `json:"width"` ParentWidth int32 `json:"parentWidth"` }
StatSampleMsg struct implement
func (*StatSampleMsg) ReadFrom ¶
func (st *StatSampleMsg) ReadFrom(readBuf *codec.Reader) error
ReadFrom reads from readBuf and put into struct.
func (*StatSampleMsg) ResetDefault ¶ added in v1.2.0
func (st *StatSampleMsg) ResetDefault()
func (*StatSampleMsg) WriteBlock ¶
func (st *StatSampleMsg) WriteBlock(buf *codec.Buffer, tag byte) error
WriteBlock encode struct