transport

Documentation

Index

• Variables
• func GetTransports() []string
• func RegisterTransportDriver(name string, t TransportDriver)
• type DriverTransportError
  • func (e *DriverTransportError) Error() string
  • func (e *DriverTransportError) Unwrap() []error
• type Transport
  • func FindTransport(name string) (*Transport, error)
  • func (t *Transport) Close() error
  • func (t *Transport) Send(key, data []byte) error
• type TransportDriver
• type TransportInterface

Variables

var (
	ErrorTransport = fmt.Errorf("transport error")
)

Functions

func GetTransports

func GetTransports() []string

func RegisterTransportDriver

func RegisterTransportDriver(name string, t TransportDriver)

Types

type DriverTransportError

type DriverTransportError struct {
	Driver string
	Err    error
}

func (*DriverTransportError) Error

func (e *DriverTransportError) Error() string

func (*DriverTransportError) Unwrap

func (e *DriverTransportError) Unwrap() []error

type Transport

type Transport struct {
	TransportDriver
}

func FindTransport

func FindTransport(name string) (*Transport, error)

func (*Transport) Close

func (t *Transport) Close() error

func (*Transport) Send

func (t *Transport) Send(key, data []byte) error

type TransportDriver

type TransportDriver interface {
	Name() string                // Get the name of the driver
	Prepare() error              // Prepare driver (eg: flag registration)
	Init() error                 // Initialize driver (eg: start connections, open files...)
	Close() error                // Close driver (eg: close connections and files...)
	Send(key, data []byte) error // Send a formatted message
}

type TransportInterface

type TransportInterface interface {
	Send(key, data []byte) error
}