statf

Documentation

Overview

Package statf comment This file was generated by ksf2go 1.1.7 Generated from StatF.ksf

Package statf comment This file was generated by ksf2go 1.1.7 Generated from StatF.ksf

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(ksfCtx context.Context, val interface{}, ksfReq *requestf.RequestPacket, ...) (err error)
  • func (obj *StatF) KsfSetProtocol(p m.Protocol)
  • func (obj *StatF) KsfSetTimeout(timeout int)
  • func (obj *StatF) ReportMicMsg(msg map[StatMicMsgHead]StatMicMsgBody, bFromClient bool, ...) (ret int32, err error)
  • func (obj *StatF) ReportMicMsgOneWayWithContext(ksfCtx context.Context, msg map[StatMicMsgHead]StatMicMsgBody, ...) (ret int32, err error)
  • func (obj *StatF) ReportMicMsgWithContext(ksfCtx 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(ksfCtx context.Context, msg []StatSampleMsg, opts ...map[string]string) (ret int32, err error)
  • func (obj *StatF) ReportSampleMsgWithContext(ksfCtx context.Context, msg []StatSampleMsg, opts ...map[string]string) (ret int32, err error)
  • func (obj *StatF) SetServant(servant m.Servant)
• 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)

Types

type ProxyInfo

type ProxyInfo struct {
	BFromClient bool `json:"bFromClient"`
}

ProxyInfo struct implement

func (*ProxyInfo) ReadBlock

func (st *ProxyInfo) ReadBlock(readBuf *codec.Reader, tag byte, require bool) error

ReadBlock reads struct from the given tag , require or optional.

func (*ProxyInfo) ReadFrom

func (st *ProxyInfo) ReadFrom(readBuf *codec.Reader) error

ReadFrom reads from readBuf and put into struct.

func (*ProxyInfo) ResetDefault

func (st *ProxyInfo) ResetDefault()

func (*ProxyInfo) WriteBlock

func (st *ProxyInfo) WriteBlock(buf *codec.Buffer, tag byte) error

WriteBlock encode struct

func (*ProxyInfo) WriteTo

func (st *ProxyInfo) WriteTo(buf *codec.Buffer) (err error)

WriteTo encode struct to buffer

type StatF

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

StatF struct

func (*StatF) Dispatch

func (obj *StatF) Dispatch(ksfCtx context.Context, val interface{}, ksfReq *requestf.RequestPacket, ksfResp *requestf.ResponsePacket, withContext bool) (err error)

Dispatch is used to call the server side implement for the method defined in the ksf file. withContext shows using context or not.

func (*StatF) KsfSetProtocol

func (obj *StatF) KsfSetProtocol(p m.Protocol)

KsfSetProtocol sets the protocol for the servant.

func (*StatF) KsfSetTimeout

func (obj *StatF) KsfSetTimeout(timeout int)

KsfSetTimeout sets the timeout for the servant which is in ms.

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 ksf file, with the context

func (*StatF) ReportMicMsgOneWayWithContext

func (obj *StatF) ReportMicMsgOneWayWithContext(ksfCtx 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 ksf file, with the context

func (*StatF) ReportMicMsgWithContext

func (obj *StatF) ReportMicMsgWithContext(ksfCtx 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 ksf 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 ksf file, with the context

func (*StatF) ReportSampleMsgOneWayWithContext

func (obj *StatF) ReportSampleMsgOneWayWithContext(ksfCtx context.Context, msg []StatSampleMsg, opts ...map[string]string) (ret int32, err error)

ReportSampleMsgOneWayWithContext is the proxy function for the method defined in the ksf file, with the context

func (*StatF) ReportSampleMsgWithContext

func (obj *StatF) ReportSampleMsgWithContext(ksfCtx context.Context, msg []StatSampleMsg, opts ...map[string]string) (ret int32, err error)

ReportSampleMsgWithContext is the proxy function for the method defined in the ksf file, with the context

func (*StatF) SetServant

func (obj *StatF) SetServant(servant m.Servant)

SetServant sets servant for the service.

type StatFServant

type StatFServant interface {
	ReportMicMsg(msg map[StatMicMsgHead]StatMicMsgBody, bFromClient bool) (ret int32, err error)
	ReportSampleMsg(msg []StatSampleMsg) (ret int32, err error)
}

type StatFServantWithContext

type StatFServantWithContext interface {
	ReportMicMsg(ksfCtx context.Context, msg map[StatMicMsgHead]StatMicMsgBody, bFromClient bool) (ret int32, err error)
	ReportSampleMsg(ksfCtx 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) ReadBlock

func (st *StatMicMsgBody) ReadBlock(readBuf *codec.Reader, tag byte, require bool) error

ReadBlock reads struct from the given tag , require or optional.

func (*StatMicMsgBody) ReadFrom

func (st *StatMicMsgBody) ReadFrom(readBuf *codec.Reader) error

ReadFrom reads from readBuf and put into struct.

func (*StatMicMsgBody) ResetDefault

func (st *StatMicMsgBody) ResetDefault()

func (*StatMicMsgBody) WriteBlock

func (st *StatMicMsgBody) WriteBlock(buf *codec.Buffer, tag byte) error

WriteBlock encode struct

func (*StatMicMsgBody) WriteTo

func (st *StatMicMsgBody) WriteTo(buf *codec.Buffer) (err error)

WriteTo encode struct to buffer

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"`
	KsfVersion    string `json:"ksfVersion"`
}

StatMicMsgHead struct implement

func (*StatMicMsgHead) ReadBlock

func (st *StatMicMsgHead) ReadBlock(readBuf *codec.Reader, tag byte, require bool) error

ReadBlock reads struct from the given tag , require or optional.

func (*StatMicMsgHead) ReadFrom

func (st *StatMicMsgHead) ReadFrom(readBuf *codec.Reader) error

ReadFrom reads from readBuf and put into struct.

func (*StatMicMsgHead) ResetDefault

func (st *StatMicMsgHead) ResetDefault()

func (*StatMicMsgHead) WriteBlock

func (st *StatMicMsgHead) WriteBlock(buf *codec.Buffer, tag byte) error

WriteBlock encode struct

func (*StatMicMsgHead) WriteTo

func (st *StatMicMsgHead) WriteTo(buf *codec.Buffer) (err error)

WriteTo encode struct to buffer

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

func (st *StatSampleMsg) ReadBlock(readBuf *codec.Reader, tag byte, require bool) error

ReadBlock reads struct from the given tag , require or optional.

func (*StatSampleMsg) ReadFrom

func (st *StatSampleMsg) ReadFrom(readBuf *codec.Reader) error

ReadFrom reads from readBuf and put into struct.

func (*StatSampleMsg) ResetDefault

func (st *StatSampleMsg) ResetDefault()

func (*StatSampleMsg) WriteBlock

func (st *StatSampleMsg) WriteBlock(buf *codec.Buffer, tag byte) error

WriteBlock encode struct

func (*StatSampleMsg) WriteTo

func (st *StatSampleMsg) WriteTo(buf *codec.Buffer) (err error)

WriteTo encode struct to buffer