client

Documentation

Index

• type Client
  • func InvokeRPC(conf *config.Config) (Client, error)
• type GenericClientBase
  • func (c *GenericClientBase) BuildCallOptions() (context.Context, error)
  • func (c *GenericClientBase) BuildClientOptions() error
  • func (c *GenericClientBase) BuildRequest() error
  • func (c *GenericClientBase) Call() error
  • func (c *GenericClientBase) GetMetaBackward() map[string]string
  • func (c *GenericClientBase) GetResponse() interface{}
  • func (c *GenericClientBase) HandleBizError(bizErr kerrors.BizStatusErrorIface) error
  • func (c *GenericClientBase) Output() error
• type PbGeneric
  • func NewPbGeneric() *PbGeneric
  • func (c *PbGeneric) Init(Conf *config.Config) error
• type ThriftGeneric
  • func NewThriftGeneric() *ThriftGeneric
  • func (c *ThriftGeneric) Init(Conf *config.Config) error

Types

type Client

type Client interface {
	Init(conf *config.Config) error
	Call() error
	HandleBizError(bizErr kerrors.BizStatusErrorIface) error
	Output() error
	GetResponse() interface{}
	GetMetaBackward() map[string]string
}

func InvokeRPC

func InvokeRPC(conf *config.Config) (Client, error)

type GenericClientBase

type GenericClientBase struct {
	Client       genericclient.Client
	Generic      generic.Generic
	Conf         *config.Config
	ClientOpts   []client.Option
	CallOptions  []callopt.Option
	Req          interface{}
	Resp         interface{}
	MetaBackward map[string]string
}

func (*GenericClientBase) BuildCallOptions

func (c *GenericClientBase) BuildCallOptions() (context.Context, error)

func (*GenericClientBase) BuildClientOptions

func (c *GenericClientBase) BuildClientOptions() error

func (*GenericClientBase) BuildRequest

func (c *GenericClientBase) BuildRequest() error

func (*GenericClientBase) Call

func (c *GenericClientBase) Call() error

func (*GenericClientBase) GetMetaBackward

func (c *GenericClientBase) GetMetaBackward() map[string]string

func (*GenericClientBase) GetResponse

func (c *GenericClientBase) GetResponse() interface{}

func (*GenericClientBase) HandleBizError

func (c *GenericClientBase) HandleBizError(bizErr kerrors.BizStatusErrorIface) error

func (*GenericClientBase) Output

func (c *GenericClientBase) Output() error

type PbGeneric

type PbGeneric struct {
	GenericClientBase
	Provider generic.PbDescriptorProviderDynamicGo
}

func NewPbGeneric

func NewPbGeneric() *PbGeneric

func (*PbGeneric) Init

func (c *PbGeneric) Init(Conf *config.Config) error

type ThriftGeneric

type ThriftGeneric struct {
	GenericClientBase
	Provider generic.DescriptorProvider
}

func NewThriftGeneric

func NewThriftGeneric() *ThriftGeneric

func (*ThriftGeneric) Init

func (c *ThriftGeneric) Init(Conf *config.Config) error