propertyf

package
v1.4.41 Latest Latest
Warning

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

 Go to latest Published: Jun 26, 2024 License: BSD-3-Clause Imports: 14 Imported by: 0

Documentation

Overview

Code generated by ksf2go 1.3.22, DO NOT EDIT. This file was generated from /home/cc/workspace/KsfGo/ksf/protocol/res/PropertyF.ksf Package propertyf comment

Code generated by ksf2go 1.3.22, DO NOT EDIT. This file was generated from /home/cc/workspace/KsfGo/ksf/protocol/res/PropertyF.ksf Package propertyf comment

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type PropertyF 

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

PropertyF struct

func NewPropertyF added in v1.4.38 

func NewPropertyF() *PropertyF

NewPropertyF creates a new PropertyF servant.

func (*PropertyF) AllEndpoints added in v1.4.39 

func (obj *PropertyF) AllEndpoints() (active []*endpoint.Endpoint, inactive []*endpoint.Endpoint)

Endpoints returns all endpoint.Endpoint

func (*PropertyF) Dispatch 

func (obj *PropertyF) 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 (*PropertyF) Endpoints added in v1.4.38 

func (obj *PropertyF) Endpoints() (active []*endpoint.Endpoint)

Endpoints returns all active endpoint.Endpoint

func (*PropertyF) GetServant added in v1.4.38 

func (obj *PropertyF) GetServant() (servant *model.Servant)

GetServant gets servant for the service.

func (*PropertyF) KsfPing added in v1.4.38 

func (obj *PropertyF) KsfPing()

KsfPing

func (*PropertyF) KsfPingWithContext added in v1.4.38 

func (obj *PropertyF) KsfPingWithContext(ksfCtx context.Context)

KsfPingWithContext

func (*PropertyF) KsfSetProtocol 

func (obj *PropertyF) KsfSetProtocol(p model.Protocol)

KsfSetProtocol sets the protocol for the servant.

func (*PropertyF) KsfSetTimeout 

func (obj *PropertyF) KsfSetTimeout(timeout int)

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

func (*PropertyF) ReportPropMsg 

func (obj *PropertyF) ReportPropMsg(statmsg map[StatPropMsgHead]StatPropMsgBody, opts ...map[string]string) (int32, error)

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

func (*PropertyF) ReportPropMsgOneWayWithContext 

func (obj *PropertyF) ReportPropMsgOneWayWithContext(ksfCtx context.Context, statmsg map[StatPropMsgHead]StatPropMsgBody, opts ...map[string]string) (ret int32, err error)

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

func (*PropertyF) ReportPropMsgWithContext 

func (obj *PropertyF) ReportPropMsgWithContext(ksfCtx context.Context, statmsg map[StatPropMsgHead]StatPropMsgBody, opts ...map[string]string) (ret int32, err error)

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

func (*PropertyF) SetOnCloseCallback added in v1.4.38 

func (obj *PropertyF) SetOnCloseCallback(callback func(string))

SetOnCloseCallback

func (*PropertyF) SetOnConnectCallback added in v1.4.38 

func (obj *PropertyF) SetOnConnectCallback(callback func(string))

SetOnConnectCallback

func (*PropertyF) SetPushCallback added in v1.4.38 

func (obj *PropertyF) SetPushCallback(callback func([]byte))

SetPushCallback

func (*PropertyF) SetServant 

func (obj *PropertyF) SetServant(servant model.Servant)

SetServant sets servant for the service.

type PropertyFServant 

type PropertyFServant interface {
	ReportPropMsg(statmsg map[StatPropMsgHead]StatPropMsgBody) (ret int32, err error)
}

type PropertyFServantWithContext 

type PropertyFServantWithContext interface {
	ReportPropMsg(ksfCtx context.Context, statmsg map[StatPropMsgHead]StatPropMsgBody) (ret int32, err error)
	DoClose(ctx context.Context)
}

type StatPropInfo 

type StatPropInfo struct {
	Policy string `json:"policy" ksf:"policy,tag:0,require:true"`
	Value  string `json:"value" ksf:"value,tag:1,require:true"`
}

StatPropInfo struct implement

func (*StatPropInfo) ReadBlock 

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

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

func (*StatPropInfo) ReadFrom 

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

ReadFrom reads from readBuf and put into struct.

func (*StatPropInfo) ResetDefault 

func (st *StatPropInfo) ResetDefault()

func (*StatPropInfo) WriteBlock 

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

WriteBlock encode struct

func (*StatPropInfo) WriteTo 

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

WriteTo encode struct to buffer

type StatPropMsgBody 

type StatPropMsgBody struct {
	VInfo []StatPropInfo `json:"vInfo" ksf:"vInfo,tag:0,require:true"`
}

StatPropMsgBody struct implement

func (*StatPropMsgBody) ReadBlock 

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

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

func (*StatPropMsgBody) ReadFrom 

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

ReadFrom reads from readBuf and put into struct.

func (*StatPropMsgBody) ResetDefault 

func (st *StatPropMsgBody) ResetDefault()

func (*StatPropMsgBody) WriteBlock 

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

WriteBlock encode struct

func (*StatPropMsgBody) WriteTo 

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

WriteTo encode struct to buffer

type StatPropMsgHead 

type StatPropMsgHead struct {
	ModuleName   string `json:"moduleName" ksf:"moduleName,tag:0,require:true"`
	Ip           string `json:"ip" ksf:"ip,tag:1,require:true"`
	PropertyName string `json:"propertyName" ksf:"propertyName,tag:2,require:true"`
	SetName      string `json:"setName" ksf:"setName,tag:3,require:false"`
	SetArea      string `json:"setArea" ksf:"setArea,tag:4,require:false"`
	SetID        string `json:"setID" ksf:"setID,tag:5,require:false"`
	SContainer   string `json:"sContainer" ksf:"sContainer,tag:6,require:false"`
	IPropertyVer int32  `json:"iPropertyVer" ksf:"iPropertyVer,tag:7,require:false"`
}

StatPropMsgHead struct implement

func (*StatPropMsgHead) ReadBlock 

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

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

func (*StatPropMsgHead) ReadFrom 

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

ReadFrom reads from readBuf and put into struct.

func (*StatPropMsgHead) ResetDefault 

func (st *StatPropMsgHead) ResetDefault()

func (*StatPropMsgHead) WriteBlock 

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

WriteBlock encode struct

func (*StatPropMsgHead) WriteTo 

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

WriteTo encode struct to buffer

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.