transport

Documentation

Index

• func Register(name string, builder TransportBuilder) error
• func Unregister(name string) error
• type Transport
  • func New(name string) (Transport, error)
• type TransportBuilder

Functions

func Register

func Register(name string, builder TransportBuilder) error

func Unregister

func Unregister(name string) error

Types

type Transport

type Transport interface {
	Dial(network, address string)
	Listen(network, address string) <-chan store.Store
	Send(store.Store)
	Close()
}

func New

func New(name string) (Transport, error)

type TransportBuilder

type TransportBuilder func(opts ...options.Option) (Transport, error)