Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BoolValue ¶
type BoolValue bool
An BoolValue provides eventstream encoding, and representation of a Go bool value.
type BytesValue ¶
type BytesValue []byte
An BytesValue provides eventstream encoding, and representation of a Go byte slice.
type ChecksumError ¶
type ChecksumError struct{}
ChecksumError provides the error for message checksum invalidation errors.
type Decoder ¶
type Decoder struct {
// contains filtered or unexported fields
}
Decoder provides decoding of an Event Stream messages.
func NewDecoder ¶
func NewDecoder(r io.Reader) *Decoder
NewDecoder initializes and returns a Decoder for decoding event stream messages from the reader provided.
type Encoder ¶
type Encoder struct {
// contains filtered or unexported fields
}
Encoder provides EventStream message encoding.
func NewEncoder ¶
func NewEncoder(w io.Writer) *Encoder
NewEncoder initializes and returns an Encoder to encode Event Stream messages to an io.Writer.
type Header ¶
type Header struct {
Name string
Value Value
}
Header is a single EventStream Key Value header pair.
type Headers ¶
type Headers []Header
Headers are a collection of EventStream header values.
func (*Headers) Del ¶
func (hs *Headers) Del(name string)
Del deletes the value in the Headers if it exists.
type Int16Value ¶
type Int16Value int16
An Int16Value provides eventstream encoding, and representation of a Go int16 value.
type Int32Value ¶
type Int32Value int32
An Int32Value provides eventstream encoding, and representation of a Go int32 value.
type Int64Value ¶
type Int64Value int64
An Int64Value provides eventstream encoding, and representation of a Go int64 value.
type Int8Value ¶
type Int8Value int8
An Int8Value provides eventstream encoding, and representation of a Go int8 value.
type LengthError ¶
type LengthError struct {
Part string
Want int
Have int
Value interface{}
}
LengthError provides the error for items being larger than a maximum length.
type Message ¶
type Message struct {
Headers Headers
Payload []byte
}
A Message provides the eventstream message representation.
type StringValue ¶
type StringValue string
An StringValue provides eventstream encoding, and representation of a Go string.
type TimestampValue ¶
type TimestampValue time.Time
An TimestampValue provides eventstream encoding, and representation of a Go timestamp.
Source Files
Directories