engine

Documentation

Index

• type CloudLoggingImpl
  • func NewCloudLoggingImpl(sniff bool, logger log.Logger, registry *stats.SourceStats) *CloudLoggingImpl
  • func (p *CloudLoggingImpl) Do(msg parsers.Message, partition abstract.Partition) []abstract.ChangeItem
  • func (p *CloudLoggingImpl) DoBatch(batch parsers.MessageBatch) []abstract.ChangeItem

Types

type CloudLoggingImpl

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

func NewCloudLoggingImpl

func NewCloudLoggingImpl(sniff bool, logger log.Logger, registry *stats.SourceStats) *CloudLoggingImpl

func (*CloudLoggingImpl) Do

func (p *CloudLoggingImpl) Do(msg parsers.Message, partition abstract.Partition) []abstract.ChangeItem

func (*CloudLoggingImpl) DoBatch

func (p *CloudLoggingImpl) DoBatch(batch parsers.MessageBatch) []abstract.ChangeItem