queuesender

Documentation

Overview

Package queuesender implements asynchronous http.

Index

• type Sender
  • func New(endpoint string, size int, name string, logger log.Logger) (*Sender, error)
  • func (s *Sender) ErrorCount() uint64
  • func (s *Sender) LastError() string
  • func (s *Sender) Register(name string) error
  • func (s *Sender) Send(endpoint string, json interface{})
  • func (s *Sender) SuccessCount() uint64

Types

type Sender

type Sender struct {
	// contains filtered or unexported fields
}

Sender sends JSON requests asynchronously

func New

func New(endpoint string, size int, name string, logger log.Logger) (
	*Sender, error)

New returns a new sender. endpoint is the common base of all endpoints. size is the size of the queue. name is the name of queue. Used strictly for logging. logger is the logger to receive the logs.

func (*Sender) ErrorCount

func (s *Sender) ErrorCount() uint64

func (*Sender) LastError

func (s *Sender) LastError() string

func (*Sender) Register

func (s *Sender) Register(name string) error

Register registers metrics for this instance with tricorder. Metrics registered under "/asyncWriters/<name>"

func (*Sender) Send

func (s *Sender) Send(endpoint string, json interface{})

Send sends given json to the given endpoint. Send will block if queue if full because of encountered errors.

func (*Sender) SuccessCount

func (s *Sender) SuccessCount() uint64