client

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

type GRPCCallOption func(*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 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 struct {
	// contains filtered or unexported fields
}

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

type GRPCStream grpc.ClientStream

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