transport

package
v2.1.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 24, 2024 License: BSD-3-Clause Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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
	// contains filtered or unexported fields
}

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 {
	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
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL