Documentation ¶
Overview ¶
Package is an interface for synchronous communication
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DialOption ¶
type DialOption func(*DialOptions)
func WithTimeout ¶
func WithTimeout(d time.Duration) DialOption
Timeout used when dialling the remote side
type DialOptions ¶
type ListenOption ¶
type ListenOption func(*ListenOptions)
type ListenOptions ¶
type Option ¶
type Option func(*Options)
func Codec ¶
Codec sets the codec used for encoding where the transport does not support message headers
type Transport ¶
type Transport interface { Init(...Option) error Options() Options Dial(addr string, opts ...DialOption) (Client, error) Listen(addr string, opts ...ListenOption) (Listener, error) String() string }
Transport is an interface which is used for communication between services. It uses socket send/recv semantics and had various implementations {HTTP, RabbitMQ, NATS, ...}
func NewTransport ¶
Click to show internal directories.
Click to hide internal directories.