logpull

Documentation

Index

• type Consumer
  • func (lc *Consumer) Start(c beat.Client, reg *registrar.Registrar, shutdown <-chan struct{}, ...)
• type ConsumerGroup
  • func New(cfg *config.ConsumerGroupConfig) (*ConsumerGroup, error)
  • func (cg *ConsumerGroup) Start(c beat.Client, reg *registrar.Registrar, shutdown chan struct{}, ...)
• type LogLinePublisher
  • func NewLogLinePublisher(client beat.Client, zone *cloudflare.Zone, unpubFields []string) *LogLinePublisher
  • func (llp *LogLinePublisher) GetLatestTime() time.Time
  • func (llp *LogLinePublisher) Write(p []byte) (n int, err error)

Types

type Consumer

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

func (*Consumer) Start

func (lc *Consumer) Start(c beat.Client, reg *registrar.Registrar, shutdown <-chan struct{}, done *sync.WaitGroup)

type ConsumerGroup

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

func New

func New(cfg *config.ConsumerGroupConfig) (*ConsumerGroup, error)

TODO: ensure RayID and EdgeStartTimestamp fields are specified!!

func (*ConsumerGroup) Start

func (cg *ConsumerGroup) Start(c beat.Client, reg *registrar.Registrar, shutdown chan struct{}, done *sync.WaitGroup)

type LogLinePublisher

type LogLinePublisher struct {
	NextState *state.State

	EdgeResponseTime bool
	// contains filtered or unexported fields
}

func NewLogLinePublisher

func NewLogLinePublisher(client beat.Client, zone *cloudflare.Zone, unpubFields []string) *LogLinePublisher

func (*LogLinePublisher) GetLatestTime

func (llp *LogLinePublisher) GetLatestTime() time.Time

func (*LogLinePublisher) Write

func (llp *LogLinePublisher) Write(p []byte) (n int, err error)