Versions in this module Expand all Collapse all v0 v0.0.2 Aug 3, 2022 v0.0.1 Aug 2, 2022 Changes in this version + func NewHTTPTransport(opts ...Option) *httpTransport + type Client interface + type DialOption func(*DialOptions) + func WithStream() DialOption + func WithTimeout(d time.Duration) DialOption + type DialOptions struct + Context context.Context + Stream bool + Timeout time.Duration + type ListenOption func(*ListenOptions) + func NetListener(customListener net.Listener) ListenOption + type ListenOptions struct + Context context.Context + type Listener interface + Accept func(func(Socket)) error + Addr func() string + Close func() error + type Message struct + Body []byte + Header map[string]string + type Option func(*Options) + func Addrs(addrs ...string) Option + func Codec(c codec.Marshaler) Option + func Secure(b bool) Option + func TLSConfig(t *tls.Config) Option + func Timeout(t time.Duration) Option + type Options struct + Addrs []string + Codec codec.Marshaler + Context context.Context + Secure bool + TLSConfig *tls.Config + Timeout time.Duration + type Socket interface + Close func() error + Local func() string + Recv func(*Message) error + Remote func() string + Send func(*Message) error + type Transport interface + Dial func(addr string, opts ...DialOption) (Client, error) + Init func(...Option) error + Listen func(addr string, opts ...ListenOption) (Listener, error) + Options func() Options + String func() string + var DefaultDialTimeout = time.Second * 5 + var DefaultTransport Transport = NewHTTPTransport() + func NewMemoryTransport(opts ...Option) Transport
Go to main page