offhand

Documentation

Index

• type Commit
  • func (c *Commit) Cancel()
  • func (c *Commit) Close()
  • func (c *Commit) Engage()
• type Puller
  • func NewPuller() Puller
• type Pusher
  • func NewListenPusher(listener net.Listener, tlsConfig *tls.Config, logger func(error)) Pusher
• type Stats

Types

type Commit

type Commit struct {
	Message   [][]byte
	StartTime time.Time
	// contains filtered or unexported fields
}

func (*Commit) Cancel

func (c *Commit) Cancel()

func (*Commit) Close

func (c *Commit) Close()

func (*Commit) Engage

func (c *Commit) Engage()

type Puller

type Puller interface {
	Connect(network, addr string, tlsConfig *tls.Config)
	RecvChannel() <-chan *Commit
}

func NewPuller

func NewPuller() Puller

type Pusher

type Pusher interface {
	SendMultipart(ctx context.Context, message [][]byte, startTime time.Time) (bool, error)
	Close()
	LoadStats(s *Stats)
}

func NewListenPusher

func NewListenPusher(listener net.Listener, tlsConfig *tls.Config, logger func(error)) Pusher

type Stats

type Stats struct {
	Conns          int32
	Queued         int32
	TotalDelayUs   uint64
	TotalSent      uint64
	TotalTimeouts  uint64
	TotalErrors    uint64
	TotalCancelled uint64
}