transport

package

v1.2.8 Latest Latest Go to latest Published: Jan 30, 2021 License: MIT Imports: 3 Imported by: 3

Details

View Source

const (
	HeaderPath      = "path"
	HeaderError     = "error"
	HeaderRequestID = "reqid"
)

View Source

var ErrHeaderTooLong = errors.New("header is longer than 255 characters")

View Source

var ErrTooManyHeaders = errors.New("too many headers")

This section is empty.

type Listener interface {
	Close() error
	Accept(ctx context.Context, fn func(Socket)) error
}

type Message struct {
	Headers map[string]string
	Data    []byte
}

func NewMessage() *Message

func (m *Message) GetError() (err error, hasError bool)

func (m *Message) SetError(err error)

type Socket interface {
	Close() error
	Send(ctx context.Context, msg *Message) error
	Receive(ctx context.Context, msg *Message) error
}

type Transport interface {
	Listen(ctx context.Context, addr string) (Listener, error)
	Dial(ctx context.Context, addr string) (Socket, error)
}