invoke

Documentation

Index

• type Invoke
  • func NewInvoke(c *context.Context, method string, opts ...InvokeOptions) (*context.Context, *Invoke, error)
  • func (invoke *Invoke) Address() string
  • func (invoke *Invoke) InvokeRR(c *context.Context, req, rsp proto.Message, cnn *conn.Conn) error
  • func (invoke *Invoke) Opts() InvokeOption
  • func (invoke *Invoke) Scope() string
• type InvokeOption
• type InvokeOptions
  • func Codec(cc codec.Codec) InvokeOptions
  • func InvokeBuffSize(buffSize int) InvokeOptions
  • func WithAddress(name, address string, version ...string) InvokeOptions
  • func WithName(name string, version ...string) InvokeOptions
  • func WithTracing(t string) InvokeOptions

Types

type Invoke

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

func NewInvoke

func NewInvoke(c *context.Context, method string, opts ...InvokeOptions) (*context.Context, *Invoke, error)

NewInvoke create a invoke

func (*Invoke) Address

func (invoke *Invoke) Address() string

func (*Invoke) InvokeRR

func (invoke *Invoke) InvokeRR(c *context.Context, req, rsp proto.Message, cnn *conn.Conn) error

InvokeRR invokeRR is invokeRequestResponse

func (*Invoke) Opts

func (invoke *Invoke) Opts() InvokeOption

func (*Invoke) Scope

func (invoke *Invoke) Scope() string

type InvokeOption

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

type InvokeOptions

type InvokeOptions func(*InvokeOption)

func Codec

func Codec(cc codec.Codec) InvokeOptions

func InvokeBuffSize

func InvokeBuffSize(buffSize int) InvokeOptions

InvokeBuffSize set buff size for requestChannel

func WithAddress

func WithAddress(name, address string, version ...string) InvokeOptions

WithAddress set service discover prefix with both service serviceName and address

func WithName

func WithName(name string, version ...string) InvokeOptions

WithName set service discover prefix with service serviceName

func WithTracing

func WithTracing(t string) InvokeOptions

WithTracing set tracing