transport

Documentation

Index

• func GetTransports() []string
• func RegisterTransportDriver(name string, t TransportDriver)
• type Transport
  • func FindTransport(ctx context.Context, name string) (*Transport, error)
  • func (t *Transport) Close(ctx context.Context)
  • func (t *Transport) Send(key, data []byte) error
• type TransportDriver
• type TransportInterface

Functions

func GetTransports

func GetTransports() []string

func RegisterTransportDriver

func RegisterTransportDriver(name string, t TransportDriver)

Types

type Transport

type Transport struct {
	// contains filtered or unexported fields
}

func FindTransport

func FindTransport(ctx context.Context, name string) (*Transport, error)

func (*Transport) Close

func (t *Transport) Close(ctx context.Context)

func (*Transport) Send

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

type TransportDriver

type TransportDriver interface {
	Prepare() error              // Prepare driver (eg: flag registration)
	Init(context.Context) error  // Initialize driver (eg: start connections, open files...)
	Close(context.Context) 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
}