_default

Documentation

Index

• type DefaultSender
  • func New() *DefaultSender
  • func (s *DefaultSender) AddProgress(count int)
  • func (s *DefaultSender) Client() *http.Client
  • func (s *DefaultSender) Progress() <-chan int
  • func (s *DefaultSender) Send(ctx context.Context, batch []byte) error
  • func (s *DefaultSender) WithHeaders(headers map[string]string) *DefaultSender
  • func (s *DefaultSender) WithURL(httpURL string) (*DefaultSender, error)

Types

type DefaultSender

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

func New

func New() *DefaultSender

func (*DefaultSender) AddProgress

func (s *DefaultSender) AddProgress(count int)

func (*DefaultSender) Client

func (s *DefaultSender) Client() *http.Client

func (*DefaultSender) Progress

func (s *DefaultSender) Progress() <-chan int

func (*DefaultSender) Send

func (s *DefaultSender) Send(ctx context.Context, batch []byte) error

func (*DefaultSender) WithHeaders

func (s *DefaultSender) WithHeaders(headers map[string]string) *DefaultSender

func (*DefaultSender) WithURL

func (s *DefaultSender) WithURL(httpURL string) (*DefaultSender, error)