transmission

Sep 23, 2022

Changes in this version

type Honeycomb

+ BatchSendTimeout time.Duration

Jan 4, 2022

Changes in this version

+ type ReqReader interface

+ Len func() int

+ type SimpleReader struct

+ func (r SimpleReader) Close() error

Aug 21, 2020

Changes in this version

type Honeycomb

+ func (h *Honeycomb) Flush() (err error)

type MockSender

+ Flushed int

+ func (m *MockSender) Flush() error

type Sender

+ Flush func() error

type WriterSender

+ func (w *WriterSender) Flush() error

Aug 15, 2019

Changes in this version

type Honeycomb

+ DisableCompression bool

Jun 27, 2019

Changes in this version

type Event

+ func (e *Event) MarshalMsgpack() (byts []byte, err error)

type Honeycomb

+ EnableMsgpackEncoding bool

type Response

+ func (r *Response) MarshalMsgpack() ([]byte, error)

+ func (r *Response) UnmarshalMsgpack(b []byte) error

Feb 22, 2019

Changes in this version

type Honeycomb

+ DisableGzipCompression bool

Feb 22, 2019

Changes in this version

+ var Version string

+ type DiscardSender struct

+ func (d *DiscardSender) Add(ev *Event)

+ type Event struct

+ APIHost string

+ APIKey string

+ Data map[string]interface{}

+ Dataset string

+ Metadata interface{}

+ SampleRate uint

+ Timestamp time.Time

+ func (e *Event) MarshalJSON() ([]byte, error)

+ type Honeycomb struct

+ BatchTimeout time.Duration

+ BlockOnResponse bool

+ BlockOnSend bool

+ Logger Logger

+ MaxBatchSize uint

+ MaxConcurrentBatches uint

+ Metrics Metrics

+ PendingWorkCapacity uint

+ Transport http.RoundTripper

+ UserAgentAddition string

+ func (h *Honeycomb) Add(ev *Event)

+ func (h *Honeycomb) SendResponse(r Response) bool

+ func (h *Honeycomb) Start() error

+ func (h *Honeycomb) Stop() error

+ func (h *Honeycomb) TxResponses() chan Response

+ type Logger interface

+ Printf func(msg string, args ...interface{})

+ type Metrics interface

+ Count func(string, interface{})

+ Gauge func(string, interface{})

+ Increment func(string)

+ type MockSender struct

+ BlockOnResponses bool

+ EventsCalled int

+ Started int

+ Stopped int

+ func (m *MockSender) Add(ev *Event)

+ func (m *MockSender) Events() []*Event

+ func (m *MockSender) SendResponse(r Response) bool

+ func (m *MockSender) Start() error

+ func (m *MockSender) Stop() error

+ func (m *MockSender) TxResponses() chan Response

+ type Response struct

+ Body []byte

+ Duration time.Duration

+ Err error

+ Metadata interface{}

+ StatusCode int

+ func (r *Response) UnmarshalJSON(b []byte) error

+ type Sender interface

+ Add func(ev *Event)

+ SendResponse func(Response) bool

+ Start func() error

+ Stop func() error

+ TxResponses func() chan Response

+ type WriterSender struct

+ BlockOnResponses bool

+ ResponseQueueSize uint

+ W io.Writer

+ func (w *WriterSender) Add(ev *Event)

+ func (w *WriterSender) SendResponse(r Response) bool

+ func (w *WriterSender) Start() error

+ func (w *WriterSender) Stop() error

+ func (w *WriterSender) TxResponses() chan Response