client

type BackoffFunc func(ctx context.Context, req Request, attempts int) (time.Duration, error)

type CallFunc func(ctx context.Context, req Request, rsp interface{}, opts CallOptions) error

type CallOption func(*CallOptions)

type CallOptions struct {
	// Address of remote hosts
	Address []string
	// Backoff func
	Backoff BackoffFunc
	// Check if retriable func
	Retry RetryFunc
	// Transport Dial Timeout
	DialTimeout time.Duration
	// Number of Call attempts
	Retries int
	// Request/Response timeout
	RequestTimeout time.Duration
	// Async
	Async bool

	// Middleware for low level call func
	CallWrappers []CallWrapper

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type CallWrapper func(CallFunc) CallFunc

type Client interface {
	Init(...Option) error
	Options() Options
	SetAService() error
	NewMessage(topic string, msg interface{}, opts ...MessageOption) Message
	NewRequest(service, endpoint string, req interface{}, reqOpts ...RequestOption) Request
	Call(ctx context.Context, req Request, rsp interface{}, opts ...CallOption) error
	Publish(ctx context.Context, msg Message, opts ...PublishOption) error
	String() string
}

type Message interface {
	Topic() string
	Payload() interface{}
	ContentType() string
}

type MessageOption func(*MessageOptions)

type MessageOptions struct {
	ContentType string
}

type Option func(*Options)

type Options struct {
	// Used to select codec
	ContentType string

	// Plugged interfaces
	Codecs map[string]codec.NewCodec

	// Connection Pool
	PoolSize int
	PoolTTL  time.Duration

	// Middleware for client
	Wrappers []Wrapper

	// Default Call Options
	CallOptions CallOptions

	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type PublishOption func(*PublishOptions)

type PublishOptions struct {
	// Exchange is the routing exchange for the message
	Exchange string
	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type Request interface {
	// The service to call
	Service() string
	// The action to take
	Method() string
	// The endpoint to invoke
	Endpoint() string
	// The content type
	ContentType() string
	// The unencoded request body
	Body() interface{}
	// Write to the encoded request writer. This is nil before a call is made
	Codec() codec.Writer
}

type RequestOption func(*RequestOptions)

type RequestOptions struct {
	ContentType string
	// Other options for implementations of the interface
	// can be stored in a context
	Context context.Context
}

type Response interface {
	// Read the response
	Codec() codec.Reader
	// read the header
	Header() map[string]string
	// Read the undecoded response
	Read() ([]byte, error)
}

type RetryFunc func(ctx context.Context, req Request, retryCount int, err error) (bool, error)

type Router interface {
	SendRequest(context.Context, Request) (Response, error)
}

type Wrapper func(Client) Client