client

Documentation

Index

• type GRPCBackoffFunc
• type GRPCCallOption
  • func GRPCOptionHeaders(h map[string]string) GRPCCallOption
  • func GRPCOptionMaxCallRecvMsgSize(bytes int) GRPCCallOption
  • func GRPCOptionMaxCallSendMsgSize(bytes int) GRPCCallOption
  • func GRPCOptionRequestTimeout(timeout time.Duration) GRPCCallOption
• type GRPCCallOptions
• type GRPCClient
• type GRPCRequest
  • func NewGRPCRequest(method, service string, body interface{}, headers map[string]string) *GRPCRequest
  • func (r *GRPCRequest) Body() interface{}
  • func (r *GRPCRequest) Headers() map[string]string
  • func (r *GRPCRequest) Method() string
  • func (r *GRPCRequest) Service() string
• type GRPCRetryFunc
• type GRPCStream
• type HTTPClient

Types

type GRPCBackoffFunc

type GRPCBackoffFunc func(ctx context.Context, req *GRPCRequest, attempts int) (time.Duration, error)

type GRPCCallOption

type GRPCCallOption func(*GRPCCallOptions)

func GRPCOptionHeaders

func GRPCOptionHeaders(h map[string]string) GRPCCallOption

func GRPCOptionMaxCallRecvMsgSize

func GRPCOptionMaxCallRecvMsgSize(bytes int) GRPCCallOption

func GRPCOptionMaxCallSendMsgSize

func GRPCOptionMaxCallSendMsgSize(bytes int) GRPCCallOption

func GRPCOptionRequestTimeout

func GRPCOptionRequestTimeout(timeout time.Duration) GRPCCallOption

type GRPCCallOptions

type GRPCCallOptions struct {
	Backoff               GRPCBackoffFunc
	Retries               time.Duration
	RequestTimeout        time.Duration
	Context               context.Context
	Headers               map[string]string
	MaxCallSendMsgSize    int
	MaxCallRecvMsgSize    int
	MaxRetryRPCBufferSize int
	CallContentSubtype    string
}

type GRPCClient

type GRPCClient interface {
	GetResolver() resolver.Resolver
	SetResolver(resolver resolver.Resolver)
	Conn(pool string) (grpc.ClientConnInterface, error)
	Call(ctx context.Context, service, method string, req, rsp interface{}, opts ...GRPCCallOption) error
	Stream(ctx context.Context, service, method string, body interface{}, opts ...GRPCCallOption) (grpc.ClientStream, error)
}

type GRPCRequest

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

func NewGRPCRequest

func NewGRPCRequest(method, service string, body interface{}, headers map[string]string) *GRPCRequest

func (*GRPCRequest) Body

func (r *GRPCRequest) Body() interface{}

func (*GRPCRequest) Headers

func (r *GRPCRequest) Headers() map[string]string

func (*GRPCRequest) Method

func (r *GRPCRequest) Method() string

func (*GRPCRequest) Service

func (r *GRPCRequest) Service() string

type GRPCRetryFunc

type GRPCRetryFunc func(ctx context.Context, req *GRPCRequest, retryCount int, err error) (bool, error)

type GRPCStream

type GRPCStream grpc.ClientStream

type HTTPClient

type HTTPClient interface {
	Get() error
	Post() error
}