nodef

Documentation

Overview

Code generated by tars2go 1.2.3, DO NOT EDIT. This file was generated from NodeF.tars Package nodef comment

Code generated by tars2go 1.2.3, DO NOT EDIT. This file was generated from NodeF.tars Package nodef comment

Index

• type ServerF
  • func NewServerF() *ServerF
  • func (obj *ServerF) Dispatch(tarsCtx context.Context, val interface{}, tarsReq *requestf.RequestPacket, ...) (err error)
  • func (obj *ServerF) Endpoints() []*endpoint.Endpoint
  • func (obj *ServerF) GetLatestKeepAliveTime(opts ...map[string]string) (uint32, error)
  • func (obj *ServerF) GetLatestKeepAliveTimeOneWayWithContext(tarsCtx context.Context, opts ...map[string]string) (ret uint32, err error)
  • func (obj *ServerF) GetLatestKeepAliveTimeWithContext(tarsCtx context.Context, opts ...map[string]string) (ret uint32, err error)
  • func (obj *ServerF) KeepActiving(serverInfo *ServerInfo, opts ...map[string]string) (int32, error)
  • func (obj *ServerF) KeepActivingOneWayWithContext(tarsCtx context.Context, serverInfo *ServerInfo, opts ...map[string]string) (ret int32, err error)
  • func (obj *ServerF) KeepActivingWithContext(tarsCtx context.Context, serverInfo *ServerInfo, opts ...map[string]string) (ret int32, err error)
  • func (obj *ServerF) KeepAlive(serverInfo *ServerInfo, opts ...map[string]string) (int32, error)
  • func (obj *ServerF) KeepAliveOneWayWithContext(tarsCtx context.Context, serverInfo *ServerInfo, opts ...map[string]string) (ret int32, err error)
  • func (obj *ServerF) KeepAliveWithContext(tarsCtx context.Context, serverInfo *ServerInfo, opts ...map[string]string) (ret int32, err error)
  • func (obj *ServerF) ReportVersion(app string, serverName string, version string, opts ...map[string]string) (int32, error)
  • func (obj *ServerF) ReportVersionOneWayWithContext(tarsCtx context.Context, app string, serverName string, version string, ...) (ret int32, err error)
  • func (obj *ServerF) ReportVersionWithContext(tarsCtx context.Context, app string, serverName string, version string, ...) (ret int32, err error)
  • func (obj *ServerF) SetServant(servant model.Servant)
  • func (obj *ServerF) TarsSetProtocol(p model.Protocol)
  • func (obj *ServerF) TarsSetTimeout(timeout int)
• type ServerFServant
• type ServerFServantWithContext
• type ServerInfo
  • func (st *ServerInfo) ReadBlock(readBuf *codec.Reader, tag byte, require bool) error
  • func (st *ServerInfo) ReadFrom(readBuf *codec.Reader) error
  • func (st *ServerInfo) ResetDefault()
  • func (st *ServerInfo) WriteBlock(buf *codec.Buffer, tag byte) error
  • func (st *ServerInfo) WriteTo(buf *codec.Buffer) (err error)

Types

type ServerF

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

ServerF struct

func NewServerF

func NewServerF() *ServerF

NewServerF creates a new ServerF servant.

func (*ServerF) Dispatch

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

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

Endpoints returns all active endpoint.Endpoint

func (*ServerF) GetLatestKeepAliveTime

func (obj *ServerF) GetLatestKeepAliveTime(opts ...map[string]string) (uint32, error)

GetLatestKeepAliveTime is the proxy function for the method defined in the tars file, with the context

func (*ServerF) GetLatestKeepAliveTimeOneWayWithContext

func (obj *ServerF) GetLatestKeepAliveTimeOneWayWithContext(tarsCtx context.Context, opts ...map[string]string) (ret uint32, err error)

GetLatestKeepAliveTimeOneWayWithContext is the proxy function for the method defined in the tars file, with the context

func (*ServerF) GetLatestKeepAliveTimeWithContext

func (obj *ServerF) GetLatestKeepAliveTimeWithContext(tarsCtx context.Context, opts ...map[string]string) (ret uint32, err error)

GetLatestKeepAliveTimeWithContext is the proxy function for the method defined in the tars file, with the context

func (*ServerF) KeepActiving

func (obj *ServerF) KeepActiving(serverInfo *ServerInfo, opts ...map[string]string) (int32, error)

KeepActiving is the proxy function for the method defined in the tars file, with the context

func (*ServerF) KeepActivingOneWayWithContext

func (obj *ServerF) KeepActivingOneWayWithContext(tarsCtx context.Context, serverInfo *ServerInfo, opts ...map[string]string) (ret int32, err error)

KeepActivingOneWayWithContext is the proxy function for the method defined in the tars file, with the context

func (*ServerF) KeepActivingWithContext

func (obj *ServerF) KeepActivingWithContext(tarsCtx context.Context, serverInfo *ServerInfo, opts ...map[string]string) (ret int32, err error)

KeepActivingWithContext is the proxy function for the method defined in the tars file, with the context

func (*ServerF) KeepAlive

func (obj *ServerF) KeepAlive(serverInfo *ServerInfo, opts ...map[string]string) (int32, error)

KeepAlive is the proxy function for the method defined in the tars file, with the context

func (*ServerF) KeepAliveOneWayWithContext

func (obj *ServerF) KeepAliveOneWayWithContext(tarsCtx context.Context, serverInfo *ServerInfo, opts ...map[string]string) (ret int32, err error)

KeepAliveOneWayWithContext is the proxy function for the method defined in the tars file, with the context

func (*ServerF) KeepAliveWithContext

func (obj *ServerF) KeepAliveWithContext(tarsCtx context.Context, serverInfo *ServerInfo, opts ...map[string]string) (ret int32, err error)

KeepAliveWithContext is the proxy function for the method defined in the tars file, with the context

func (*ServerF) ReportVersion

func (obj *ServerF) ReportVersion(app string, serverName string, version string, opts ...map[string]string) (int32, error)

ReportVersion is the proxy function for the method defined in the tars file, with the context

func (*ServerF) ReportVersionOneWayWithContext

func (obj *ServerF) ReportVersionOneWayWithContext(tarsCtx context.Context, app string, serverName string, version string, opts ...map[string]string) (ret int32, err error)

ReportVersionOneWayWithContext is the proxy function for the method defined in the tars file, with the context

func (*ServerF) ReportVersionWithContext

func (obj *ServerF) ReportVersionWithContext(tarsCtx context.Context, app string, serverName string, version string, opts ...map[string]string) (ret int32, err error)

ReportVersionWithContext is the proxy function for the method defined in the tars file, with the context

func (*ServerF) SetServant

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

SetServant sets servant for the service.

func (*ServerF) TarsSetProtocol

func (obj *ServerF) TarsSetProtocol(p model.Protocol)

TarsSetProtocol sets the protocol for the servant.

func (*ServerF) TarsSetTimeout

func (obj *ServerF) TarsSetTimeout(timeout int)

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

type ServerFServant

type ServerFServant interface {
	KeepAlive(serverInfo *ServerInfo) (ret int32, err error)
	KeepActiving(serverInfo *ServerInfo) (ret int32, err error)
	ReportVersion(app string, serverName string, version string) (ret int32, err error)
	GetLatestKeepAliveTime() (ret uint32, err error)
}

type ServerFServantWithContext

type ServerFServantWithContext interface {
	KeepAlive(tarsCtx context.Context, serverInfo *ServerInfo) (ret int32, err error)
	KeepActiving(tarsCtx context.Context, serverInfo *ServerInfo) (ret int32, err error)
	ReportVersion(tarsCtx context.Context, app string, serverName string, version string) (ret int32, err error)
	GetLatestKeepAliveTime(tarsCtx context.Context) (ret uint32, err error)
}

type ServerInfo

type ServerInfo struct {
	Application string `json:"application" tars:"application,tag:0,require:true"`
	ServerName  string `json:"serverName" tars:"serverName,tag:1,require:true"`
	Pid         int32  `json:"pid" tars:"pid,tag:2,require:true"`
	Adapter     string `json:"adapter" tars:"adapter,tag:3,require:false"`
}

ServerInfo struct implement

func (*ServerInfo) ReadBlock

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

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

func (*ServerInfo) ReadFrom

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

ReadFrom reads from readBuf and put into struct.

func (*ServerInfo) ResetDefault

func (st *ServerInfo) ResetDefault()

func (*ServerInfo) WriteBlock

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

WriteBlock encode struct

func (*ServerInfo) WriteTo

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

WriteTo encode struct to buffer