transport

Documentation

Index

• Variables
• type Acceptor
• type AcceptorOption
• type AcceptorOptions
• type Channel
• type Connector
• type ConnectorOption
  • func WithStream() ConnectorOption
  • func WithTimeout(d time.Duration) ConnectorOption
• type ConnectorOptions
• type Message
• type Option
  • func Addrs(addrs ...string) Option
  • func Secure(b bool) Option
  • func TLSConfig(t *tls.Config) Option
  • func Timeout(t time.Duration) Option
• type Options
• type Transport

Variables

var (
	DefaultDialTimeout = time.Second * 5
)

Types

type Acceptor

type Acceptor interface {
	Addr() string

	Close() error

	Accept(func(Channel)) error
}

type AcceptorOption

type AcceptorOption func(*AcceptorOptions)

type AcceptorOptions

type AcceptorOptions struct {
	Context context.Context
}

type Channel

type Channel interface {
	Recv(*Message) error

	Send(*Message) error

	Close() error

	Local() string

	Remote() string
}

type Connector

type Connector interface {
	Channel
}

type ConnectorOption

type ConnectorOption func(*ConnectorOptions)

func WithStream

func WithStream() ConnectorOption

func WithTimeout

func WithTimeout(d time.Duration) ConnectorOption

type ConnectorOptions

type ConnectorOptions struct {
	Stream  bool
	Timeout time.Duration
	Context context.Context
}

type Message

type Message struct {
	Header map[string]string
	Body   []byte
}

type Option

type Option func(*Options)

func Addrs

func Addrs(addrs ...string) Option

func Secure

func Secure(b bool) Option

func TLSConfig

func TLSConfig(t *tls.Config) Option

func Timeout

func Timeout(t time.Duration) Option

type Options

type Options struct {
	Addrs     []string
	Secure    bool
	TLSConfig *tls.Config
	Timeout   time.Duration
	Context   context.Context
}

type Transport

type Transport interface {
	Init(...Option) error

	Options() Options

	Dial(addr string, opts ...ConnectorOption) (Connector, error)

	Listen(addr string, opts ...AcceptorOption) (Acceptor, error)

	String() string
}