transport

package

v0.0.0-...-766f130 Latest Latest Go to latest Published: Oct 19, 2016 License: MIT Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/caiofilipini/quibe

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func ReadFrame(r io.Reader) ([]byte, error)
func WriteFrame(frame interface{}, w io.Writer) error
func WriteMessage(clientID string, msg *Message, w io.Writer) error
func WriteResponse(clientID string, response string, w io.Writer) error
type ConsumeRequestFrame
- func ReadConsumeRequestFrame(r io.Reader) (*ConsumeRequestFrame, error)
type HandshakeRequestFrame
- func ReadHandshakeRequest(r io.Reader) (*HandshakeRequestFrame, error)
- func (f *HandshakeRequestFrame) Verify() error
type Header
type Message
- func NewMessage(body []byte) Message
- func (m *Message) BodyString() string
- func (m *Message) IsEmpty() bool
type MessageFrame
type ProduceRequestFrame
- func ReadProduceRequestFrame(r io.Reader) (*ProduceRequestFrame, error)
type ResponseFrame
type UUID
- func NewUUID() *UUID
- func (u *UUID) String() string

Constants ¶

View Source

const (
	ProtocolName    = "quibe"
	ProtocolVersion = "0.1"

	ClientTypeProducer = "P"
	ClientTypeConsumer = "C"

	Success              = "OK"
	ErrUnknownProtocol   = "UnknownProtocol"
	ErrInvalidVersion    = "InvalidVersion"
	ErrUnsupportedClient = "UnsupportedClient"
	ErrInvalidClientID   = "InvalidClientID"
	ErrInvalidQueueName  = "InvalidQueueName"
	ErrUnknownQueue      = "UnknownQueue"
	ErrInternal          = "InternalError"
)

Variables ¶

View Source

var (
	EmptyMessage = NewMessage([]byte(emptyBody))
)

Functions ¶

func ReadFrame ¶

func ReadFrame(r io.Reader) ([]byte, error)

TODO accept frame type as parameter and return that instead of []byte. It depends on having a common interface for frames.

func WriteFrame ¶

func WriteFrame(frame interface{}, w io.Writer) error

TODO interface{} here sucks!

func WriteMessage ¶

func WriteMessage(clientID string, msg *Message, w io.Writer) error

func WriteResponse ¶

func WriteResponse(clientID string, response string, w io.Writer) error

Types ¶

type ConsumeRequestFrame ¶

type ConsumeRequestFrame struct {
	ClientID string
	Queue    string
}

func ReadConsumeRequestFrame ¶

func ReadConsumeRequestFrame(r io.Reader) (*ConsumeRequestFrame, error)

type HandshakeRequestFrame ¶

type HandshakeRequestFrame struct {
	Protocol   string
	Version    string
	ClientType string
	Queue      string
}

func ReadHandshakeRequest ¶

func ReadHandshakeRequest(r io.Reader) (*HandshakeRequestFrame, error)

func (*HandshakeRequestFrame) Verify ¶

func (f *HandshakeRequestFrame) Verify() error

type Header ¶

type Header struct{}

type Message ¶

type Message struct {
	Headers map[string]Header
	Body    []byte
}

func NewMessage ¶

func NewMessage(body []byte) Message

func (*Message) BodyString ¶

func (m *Message) BodyString() string

func (*Message) IsEmpty ¶

func (m *Message) IsEmpty() bool

type MessageFrame ¶

type MessageFrame struct {
	ClientID string
	Message  Message
}

type ProduceRequestFrame ¶

type ProduceRequestFrame struct {
	ClientID string
	Queue    string
	Message  Message
}

func ReadProduceRequestFrame ¶

func ReadProduceRequestFrame(r io.Reader) (*ProduceRequestFrame, error)

type ResponseFrame ¶

type ResponseFrame struct {
	Protocol     string
	Version      string
	ClientID     string
	Success      bool
	Response     string
	ResponseCode uint32
}

type UUID ¶

type UUID [16]byte

Code taken from https://github.com/gorilla/feeds/blob/master/uuid.go

func NewUUID ¶

func NewUUID() *UUID

create a new uuid v4

func (*UUID) String ¶

func (u *UUID) String() string

Source Files ¶

View all Source files

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