sender

Documentation

Index

• type Config
• type HTTPSender
  • func (s *HTTPSender) Send()
  • func (s *HTTPSender) Start()
  • func (s *HTTPSender) Stop()
• type Sender
  • func NewSender(cfg Config, in chan *profile_models.ProfileInfo) Sender

Types

type Config

type Config struct {
	Sock string

	Schema  string
	Host    string
	Timeout time.Duration

	BackoffInterval time.Duration
	RetryCount      int

	Logger logger.Logger
}

type HTTPSender

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

func (*HTTPSender) Send

func (s *HTTPSender) Send()

Send is an empty method to distinguish from other interfaces

func (*HTTPSender) Start

func (s *HTTPSender) Start()

func (*HTTPSender) Stop

func (s *HTTPSender) Stop()

type Sender

type Sender interface {
	Start()
	Stop()

	Send()
}

func NewSender

func NewSender(cfg Config, in chan *profile_models.ProfileInfo) Sender