transport

Documentation

Index

• type Buffered
  • func NewBuffered(inner rollbar.Transport, bufSize int) *Buffered
  • func (t *Buffered) Close() error
  • func (t *Buffered) Send(body map[string]interface{}) error
  • func (t *Buffered) Wait()

Types

type Buffered

type Buffered struct {
	rollbar.Transport
	// contains filtered or unexported fields
}

Buffered is an alternative to rollbar's AsyncTransport, providing threadsafe and predictable message delivery built on top of the SyncTransport.

func NewBuffered

func NewBuffered(inner rollbar.Transport, bufSize int) *Buffered

NewBuffered wraps the provided transport for async delivery.

func (*Buffered) Close

func (t *Buffered) Close() error

Close shuts down the transport and waits for queued messages to be delivered.

func (*Buffered) Send

func (t *Buffered) Send(body map[string]interface{}) error

Send enqueues delivery of the message body to Rollbar without waiting for the result. If the buffer is full, it will immediately return an error.

func (*Buffered) Wait

func (t *Buffered) Wait()

Wait blocks until all messages buffered before calling Wait are delivered.