rpc

Documentation

Index

• func InstallAsyncCallOptionsWatchDog(dog func(cc *AsyncCallOptions))
• func InstallCallOptionsWatchDog(dog func(cc *CallOptions))
• func InstallNoticeOptionsWatchDog(dog func(cc *NoticeOptions))
• type AsyncCallOption
  • func WithAsyncCallOptionMetadata(v metadata.MD) AsyncCallOption
  • func WithAsyncCallOptionResponseFilter(v AsyncResponseFilter) AsyncCallOption
  • func WithAsyncCallOptionTimeout(v time.Duration) AsyncCallOption
  • func WithAsyncCallOptionWaitFilter(v func(await func())) AsyncCallOption
• type AsyncCallOptions
  • func NewAsyncCallOptions(opts ...AsyncCallOption) *AsyncCallOptions
  • func (cc *AsyncCallOptions) ApplyOption(opts ...AsyncCallOption)
  • func (cc *AsyncCallOptions) GetSetOption(opt AsyncCallOption) AsyncCallOption
  • func (cc *AsyncCallOptions) SetOption(opt AsyncCallOption)
• type AsyncResponseFilter
• type CallOption
  • func WithCallOptionMetadata(v metadata.MD) CallOption
  • func WithCallOptionTimeout(v time.Duration) CallOption
• type CallOptions
  • func NewCallOptions(opts ...CallOption) *CallOptions
  • func (cc *CallOptions) ApplyOption(opts ...CallOption)
  • func (cc *CallOptions) GetSetOption(opt CallOption) CallOption
  • func (cc *CallOptions) SetOption(opt CallOption)
• type NoticeOption
  • func WithNoticeOptionMetadata(v metadata.MD) NoticeOption
  • func WithNoticeOptionTimeout(v time.Duration) NoticeOption
• type NoticeOptions
  • func NewNoticeOptions(opts ...NoticeOption) *NoticeOptions
  • func (cc *NoticeOptions) ApplyOption(opts ...NoticeOption)
  • func (cc *NoticeOptions) GetSetOption(opt NoticeOption) NoticeOption
  • func (cc *NoticeOptions) SetOption(opt NoticeOption)
• type RPCProcess
  • func NewRPCProcess(inner *process.InnerOptions, opts *process.ProcessOptions) *RPCProcess
  • func (p *RPCProcess) AsyncCall(ctx context.Context, uri interface{}, rq interface{}, af process.RouterFunc, ...) (err error)
  • func (p *RPCProcess) Call(ctx context.Context, uri interface{}, rq, rs interface{}, opts *CallOptions) (err error)
  • func (p *RPCProcess) Clean()
  • func (p *RPCProcess) Notify(ctx context.Context, uri interface{}, rq interface{}, opts *NoticeOptions) (err error)
  • func (p *RPCProcess) OnFailed(pkg interface{}, err error)
  • func (p *RPCProcess) OnReply(in interface{}) (filter bool)
• type RPCProcesser

Functions

func InstallAsyncCallOptionsWatchDog

func InstallAsyncCallOptionsWatchDog(dog func(cc *AsyncCallOptions))

InstallAsyncCallOptionsWatchDog install watch dog

func InstallCallOptionsWatchDog

func InstallCallOptionsWatchDog(dog func(cc *CallOptions))

InstallCallOptionsWatchDog install watch dog

func InstallNoticeOptionsWatchDog

func InstallNoticeOptionsWatchDog(dog func(cc *NoticeOptions))

InstallNoticeOptionsWatchDog install watch dog

Types

type AsyncCallOption

type AsyncCallOption func(cc *AsyncCallOptions) AsyncCallOption

AsyncCallOption option define

func WithAsyncCallOptionMetadata

func WithAsyncCallOptionMetadata(v metadata.MD) AsyncCallOption

metadata

func WithAsyncCallOptionResponseFilter

func WithAsyncCallOptionResponseFilter(v AsyncResponseFilter) AsyncCallOption

response filter. NOTE: req only valid in Filter func.

func WithAsyncCallOptionTimeout

func WithAsyncCallOptionTimeout(v time.Duration) AsyncCallOption

rpc call timeout

func WithAsyncCallOptionWaitFilter

func WithAsyncCallOptionWaitFilter(v func(await func())) AsyncCallOption

type AsyncCallOptions

type AsyncCallOptions struct {
	// rpc call timeout
	Timeout time.Duration
	// metadata
	Metadata metadata.MD
	// response filter. NOTE: req only valid in Filter func.
	ResponseFilter AsyncResponseFilter
	WaitFilter     func(await func())
}

CallOption rpc call options

func NewAsyncCallOptions

func NewAsyncCallOptions(opts ...AsyncCallOption) *AsyncCallOptions

NewAsyncCallOptions create options instance.

func (*AsyncCallOptions) ApplyOption

func (cc *AsyncCallOptions) ApplyOption(opts ...AsyncCallOption)

ApplyOption modify options

func (*AsyncCallOptions) GetSetOption

func (cc *AsyncCallOptions) GetSetOption(opt AsyncCallOption) AsyncCallOption

GetSetOption modify and get last option

func (*AsyncCallOptions) SetOption

func (cc *AsyncCallOptions) SetOption(opt AsyncCallOption)

SetOption modify options

type AsyncResponseFilter

type AsyncResponseFilter func(ctx process.Context, req, rsp interface{})

AsyncResponseFilter 异步请回回复调用

type CallOption

type CallOption func(cc *CallOptions) CallOption

CallOption option define

func WithCallOptionMetadata

func WithCallOptionMetadata(v metadata.MD) CallOption

metadata

func WithCallOptionTimeout

func WithCallOptionTimeout(v time.Duration) CallOption

rpc call timeout

type CallOptions

type CallOptions struct {
	// rpc call timeout
	Timeout time.Duration
	// metadata
	Metadata metadata.MD
}

CallOption rpc call options

func NewCallOptions

func NewCallOptions(opts ...CallOption) *CallOptions

NewCallOptions create options instance.

func (*CallOptions) ApplyOption

func (cc *CallOptions) ApplyOption(opts ...CallOption)

ApplyOption modify options

func (*CallOptions) GetSetOption

func (cc *CallOptions) GetSetOption(opt CallOption) CallOption

GetSetOption modify and get last option

func (*CallOptions) SetOption

func (cc *CallOptions) SetOption(opt CallOption)

SetOption modify options

type NoticeOption

type NoticeOption func(cc *NoticeOptions) NoticeOption

NoticeOption option define

func WithNoticeOptionMetadata

func WithNoticeOptionMetadata(v metadata.MD) NoticeOption

metadata

func WithNoticeOptionTimeout

func WithNoticeOptionTimeout(v time.Duration) NoticeOption

send message timeout

type NoticeOptions

type NoticeOptions struct {
	// send message timeout
	Timeout time.Duration
	// metadata
	Metadata metadata.MD
}

NoticeOption oneway rpc

func NewNoticeOptions

func NewNoticeOptions(opts ...NoticeOption) *NoticeOptions

NewNoticeOptions create options instance.

func (*NoticeOptions) ApplyOption

func (cc *NoticeOptions) ApplyOption(opts ...NoticeOption)

ApplyOption modify options

func (*NoticeOptions) GetSetOption

func (cc *NoticeOptions) GetSetOption(opt NoticeOption) NoticeOption

GetSetOption modify and get last option

func (*NoticeOptions) SetOption

func (cc *NoticeOptions) SetOption(opt NoticeOption)

SetOption modify options

type RPCProcess

type RPCProcess struct {
	process.Process
	// contains filtered or unexported fields
}

RPCProcess 通用rpc处理流程封装 封装

func NewRPCProcess

func NewRPCProcess(inner *process.InnerOptions, opts *process.ProcessOptions) *RPCProcess

func (*RPCProcess) AsyncCall

func (p *RPCProcess) AsyncCall(ctx context.Context, uri interface{}, rq interface{}, af process.RouterFunc, opts *AsyncCallOptions) (err error)

AsyncCall 异步RPC请求

func (*RPCProcess) Call

func (p *RPCProcess) Call(ctx context.Context, uri interface{}, rq, rs interface{}, opts *CallOptions) (err error)

Call 同步rpc请求

func (*RPCProcess) Clean

func (p *RPCProcess) Clean()

Clean session 清理（rpc请求等缓存清理）

func (*RPCProcess) Notify

func (p *RPCProcess) Notify(ctx context.Context, uri interface{}, rq interface{}, opts *NoticeOptions) (err error)

Notify 通知请求(one way)

func (*RPCProcess) OnFailed

func (p *RPCProcess) OnFailed(pkg interface{}, err error)

OnFailed 调度时候失败.

func (*RPCProcess) OnReply

func (p *RPCProcess) OnReply(in interface{}) (filter bool)

OnReply rpc请求返回处理

type RPCProcesser

type RPCProcesser interface {
	// OnReply rpc请求返回处理
	OnReply(in interface{}) (filter bool)
	// Call 同步rpc请求
	Call(ctx context.Context, uri interface{}, rq, rs interface{}, opts *CallOptions) (err error)
	// AsyncCall 异步RPC请求
	AsyncCall(ctx context.Context, uri interface{}, rq interface{}, af process.RouterFunc, opts *AsyncCallOptions) (err error)
	// Notify 通知请求(one way)
	Notify(ctx context.Context, uri interface{}, rq interface{}, opts *NoticeOptions) (err error)
	// Clean session 清理（rpc请求等缓存清理）
	Clean()
}

RPCProcess 通用rpc处理流程封装 封装