queryf

Documentation

Overview

Code generated by ksf2go 1.3.21, DO NOT EDIT. This file was generated from QueryF.ksf Package queryf comment

Index

• type QueryF
  • func NewQueryF() *QueryF
  • func (obj *QueryF) Dispatch(ksfCtx context.Context, val interface{}, ksfReq *requestf.RequestPacket, ...) (err error)
  • func (obj *QueryF) Endpoints() []*endpoint.Endpoint
  • func (obj *QueryF) FindObjectById(id string, opts ...map[string]string) ([]endpointf.EndpointF, error)
  • func (obj *QueryF) FindObjectById4All(id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, ...) (int32, error)
  • func (obj *QueryF) FindObjectById4AllOneWayWithContext(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, ...) (ret int32, err error)
  • func (obj *QueryF) FindObjectById4AllWithContext(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, ...) (ret int32, err error)
  • func (obj *QueryF) FindObjectById4Any(id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, ...) (int32, error)
  • func (obj *QueryF) FindObjectById4AnyOneWayWithContext(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, ...) (ret int32, err error)
  • func (obj *QueryF) FindObjectById4AnyWithContext(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, ...) (ret int32, err error)
  • func (obj *QueryF) FindObjectByIdInSameGroup(id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, ...) (int32, error)
  • func (obj *QueryF) FindObjectByIdInSameGroupOneWayWithContext(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, ...) (ret int32, err error)
  • func (obj *QueryF) FindObjectByIdInSameGroupWithContext(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, ...) (ret int32, err error)
  • func (obj *QueryF) FindObjectByIdInSameSet(id string, setId string, activeEp *[]endpointf.EndpointF, ...) (int32, error)
  • func (obj *QueryF) FindObjectByIdInSameSetOneWayWithContext(ksfCtx context.Context, id string, setId string, ...) (ret int32, err error)
  • func (obj *QueryF) FindObjectByIdInSameSetWithContext(ksfCtx context.Context, id string, setId string, ...) (ret int32, err error)
  • func (obj *QueryF) FindObjectByIdInSameStation(id string, sStation string, activeEp *[]endpointf.EndpointF, ...) (int32, error)
  • func (obj *QueryF) FindObjectByIdInSameStationOneWayWithContext(ksfCtx context.Context, id string, sStation string, ...) (ret int32, err error)
  • func (obj *QueryF) FindObjectByIdInSameStationWithContext(ksfCtx context.Context, id string, sStation string, ...) (ret int32, err error)
  • func (obj *QueryF) FindObjectByIdOneWayWithContext(ksfCtx context.Context, id string, opts ...map[string]string) (ret []endpointf.EndpointF, err error)
  • func (obj *QueryF) FindObjectByIdWithContext(ksfCtx context.Context, id string, opts ...map[string]string) (ret []endpointf.EndpointF, err error)
  • func (obj *QueryF) GetServant() (servant *model.Servant)
  • func (obj *QueryF) KsfPing()
  • func (obj *QueryF) KsfPingWithContext(ksfCtx context.Context)
  • func (obj *QueryF) KsfSetProtocol(p model.Protocol)
  • func (obj *QueryF) KsfSetTimeout(timeout int)
  • func (obj *QueryF) SetOnCloseCallback(callback func(string))
  • func (obj *QueryF) SetOnConnectCallback(callback func(string))
  • func (obj *QueryF) SetPushCallback(callback func([]byte))
  • func (obj *QueryF) SetServant(servant model.Servant)
• type QueryFServant
• type QueryFServantWithContext

Types

type QueryF

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

QueryF struct

func NewQueryF

func NewQueryF() *QueryF

NewQueryF creates a new QueryF servant.

func (*QueryF) Dispatch

func (obj *QueryF) 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 (*QueryF) Endpoints

func (obj *QueryF) Endpoints() []*endpoint.Endpoint

Endpoints returns all active endpoint.Endpoint

func (*QueryF) FindObjectById

func (obj *QueryF) FindObjectById(id string, opts ...map[string]string) ([]endpointf.EndpointF, error)

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

func (*QueryF) FindObjectById4All

func (obj *QueryF) FindObjectById4All(id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (int32, error)

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

func (*QueryF) FindObjectById4AllOneWayWithContext

func (obj *QueryF) FindObjectById4AllOneWayWithContext(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (ret int32, err error)

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

func (*QueryF) FindObjectById4AllWithContext

func (obj *QueryF) FindObjectById4AllWithContext(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (ret int32, err error)

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

func (*QueryF) FindObjectById4Any

func (obj *QueryF) FindObjectById4Any(id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (int32, error)

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

func (*QueryF) FindObjectById4AnyOneWayWithContext

func (obj *QueryF) FindObjectById4AnyOneWayWithContext(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (ret int32, err error)

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

func (*QueryF) FindObjectById4AnyWithContext

func (obj *QueryF) FindObjectById4AnyWithContext(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (ret int32, err error)

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

func (*QueryF) FindObjectByIdInSameGroup

func (obj *QueryF) FindObjectByIdInSameGroup(id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (int32, error)

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

func (*QueryF) FindObjectByIdInSameGroupOneWayWithContext

func (obj *QueryF) FindObjectByIdInSameGroupOneWayWithContext(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (ret int32, err error)

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

func (*QueryF) FindObjectByIdInSameGroupWithContext

func (obj *QueryF) FindObjectByIdInSameGroupWithContext(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (ret int32, err error)

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

func (*QueryF) FindObjectByIdInSameSet

func (obj *QueryF) FindObjectByIdInSameSet(id string, setId string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (int32, error)

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

func (*QueryF) FindObjectByIdInSameSetOneWayWithContext

func (obj *QueryF) FindObjectByIdInSameSetOneWayWithContext(ksfCtx context.Context, id string, setId string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (ret int32, err error)

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

func (*QueryF) FindObjectByIdInSameSetWithContext

func (obj *QueryF) FindObjectByIdInSameSetWithContext(ksfCtx context.Context, id string, setId string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (ret int32, err error)

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

func (*QueryF) FindObjectByIdInSameStation

func (obj *QueryF) FindObjectByIdInSameStation(id string, sStation string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (int32, error)

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

func (*QueryF) FindObjectByIdInSameStationOneWayWithContext

func (obj *QueryF) FindObjectByIdInSameStationOneWayWithContext(ksfCtx context.Context, id string, sStation string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (ret int32, err error)

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

func (*QueryF) FindObjectByIdInSameStationWithContext

func (obj *QueryF) FindObjectByIdInSameStationWithContext(ksfCtx context.Context, id string, sStation string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF, opts ...map[string]string) (ret int32, err error)

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

func (*QueryF) FindObjectByIdOneWayWithContext

func (obj *QueryF) FindObjectByIdOneWayWithContext(ksfCtx context.Context, id string, opts ...map[string]string) (ret []endpointf.EndpointF, err error)

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

func (*QueryF) FindObjectByIdWithContext

func (obj *QueryF) FindObjectByIdWithContext(ksfCtx context.Context, id string, opts ...map[string]string) (ret []endpointf.EndpointF, err error)

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

func (*QueryF) GetServant

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

GetServant gets servant for the service.

func (*QueryF) KsfPing

func (obj *QueryF) KsfPing()

KsfPing

func (*QueryF) KsfPingWithContext

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

KsfPingWithContext

func (*QueryF) KsfSetProtocol

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

KsfSetProtocol sets the protocol for the servant.

func (*QueryF) KsfSetTimeout

func (obj *QueryF) KsfSetTimeout(timeout int)

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

func (*QueryF) SetOnCloseCallback

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

SetOnCloseCallback

func (*QueryF) SetOnConnectCallback

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

SetOnConnectCallback

func (*QueryF) SetPushCallback

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

SetPushCallback

func (*QueryF) SetServant

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

SetServant sets servant for the service.

type QueryFServant

type QueryFServant interface {
	FindObjectById(id string) (ret []endpointf.EndpointF, err error)
	FindObjectById4Any(id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF) (ret int32, err error)
	FindObjectById4All(id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF) (ret int32, err error)
	FindObjectByIdInSameGroup(id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF) (ret int32, err error)
	FindObjectByIdInSameStation(id string, sStation string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF) (ret int32, err error)
	FindObjectByIdInSameSet(id string, setId string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF) (ret int32, err error)
}

type QueryFServantWithContext

type QueryFServantWithContext interface {
	FindObjectById(ksfCtx context.Context, id string) (ret []endpointf.EndpointF, err error)
	FindObjectById4Any(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF) (ret int32, err error)
	FindObjectById4All(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF) (ret int32, err error)
	FindObjectByIdInSameGroup(ksfCtx context.Context, id string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF) (ret int32, err error)
	FindObjectByIdInSameStation(ksfCtx context.Context, id string, sStation string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF) (ret int32, err error)
	FindObjectByIdInSameSet(ksfCtx context.Context, id string, setId string, activeEp *[]endpointf.EndpointF, inactiveEp *[]endpointf.EndpointF) (ret int32, err error)
	DoClose(ctx context.Context)
}