client

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

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

type CallOption func(*CallOptions)

type CallOptions struct {

	// Router to use for this call
	Caller message.Caller
}

type CallWrapper func(CallFunc) CallFunc

type Client interface {
	NewMessage(msg interface{}, opts ...MessageOption) Message
	NewRequest(service *service.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
	Stream(ctx context.Context, req Request, opts ...CallOption) (Stream, 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
	// Proxy address to send requests via
	Proxy string

	// 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() *service.Service
	// 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.Codec
	// indicates whether the request will be a streaming one rather than unary
	Stream() bool
}

type RequestOption func(*RequestOptions)

type RequestOptions struct {
	ContentType string
	Stream      bool

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

type Response interface {
	// Read the response
	Codec() codec.Codec
	// 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 Stream interface {
	// Context for the stream
	Context() context.Context
	// The request made
	Request() Request
	// The response read
	Response() Response
	// Send will encode and send a request
	Send(interface{}) error
	// Recv will decode and read a response
	Recv(interface{}) error
	// Error returns the stream error
	Error() error
	// Close closes the stream
	Close() error
}

type Wrapper func(Client) Client