Documentation
¶
Index ¶
Constants ¶
View Source
const ( // Available is true if the code is compiled in Available = false )
Variables ¶
View Source
var ( // ErrPayloadFull is returned when the payload buffer is full ErrPayloadFull = errors.New("reached maximum payload size") // ErrItemTooBig is returned when a item alone exceeds maximum payload size ErrItemTooBig = errors.New("item alone exceeds maximum payload size") )
Functions ¶
This section is empty.
Types ¶
type Compressor ¶
type Compressor struct{}
Compressor is not implemented
func NewCompressor ¶
func NewCompressor(input, output *bytes.Buffer, header, footer []byte, separator []byte) (*Compressor, error)
NewCompressor not implemented
func (*Compressor) AddItem ¶
func (c *Compressor) AddItem(data []byte) error
AddItem not implemented
type JSONPayloadBuilder ¶
type JSONPayloadBuilder struct {
}
JSONPayloadBuilder is not implemented when zlib is not available.
func NewJSONPayloadBuilder ¶
func NewJSONPayloadBuilder(shareAndLockBuffers bool) *JSONPayloadBuilder
NewJSONPayloadBuilder is not implemented when zlib is not available.
func (*JSONPayloadBuilder) BuildWithOnErrItemTooBigPolicy ¶
func (b *JSONPayloadBuilder) BuildWithOnErrItemTooBigPolicy(marshaler.StreamJSONMarshaler, OnErrItemTooBigPolicy) (forwarder.Payloads, error)
BuildWithOnErrItemTooBigPolicy is not implemented when zlib is not available.
type OnErrItemTooBigPolicy ¶
type OnErrItemTooBigPolicy int
OnErrItemTooBigPolicy defines the behavior when OnErrItemTooBig occurs.
const ( // DropItemOnErrItemTooBig when founding an ErrItemTooBig, skips the error and continue DropItemOnErrItemTooBig OnErrItemTooBigPolicy = iota // FailOnErrItemTooBig when founding an ErrItemTooBig, returns the error and stop FailOnErrItemTooBig )
Source Files
Click to show internal directories.
Click to hide internal directories.