skywalking

Documentation

Index

• Constants
• type AggregatorSkywalking
  • func NewAggregatorSkywalking() *AggregatorSkywalking
  • func (p *AggregatorSkywalking) Add(log *protocol.Log, ctx map[string]interface{}) error
  • func (*AggregatorSkywalking) Description() string
  • func (p *AggregatorSkywalking) Flush() []*protocol.LogGroup
  • func (p *AggregatorSkywalking) Init(context pipeline.Context, que pipeline.LogGroupQueue) (int, error)
  • func (p *AggregatorSkywalking) Reset()

Constants

const (
	MaxLogCount     = 1024
	MaxLogGroupSize = 3 * 1024 * 1024
)

const DefaultLogLogstore = "skywalking-logs"

const DefaultMetricsLogstore = "skywalking-metrics"

const DefaultTraceLogstore = "skywalking-traces"

Types

type AggregatorSkywalking

type AggregatorSkywalking struct {
	MaxLogGroupCount int
	MaxLogCount      int
	PackFlag         bool
	Topic            string
	MetricsLogstore  string
	TraceLogstore    string
	LogLogstore      string

	Lock *sync.Mutex
	// contains filtered or unexported fields
}

func NewAggregatorSkywalking

func NewAggregatorSkywalking() *AggregatorSkywalking

func (*AggregatorSkywalking) Add

func (p *AggregatorSkywalking) Add(log *protocol.Log, ctx map[string]interface{}) error

Add adds @log to aggregator. Add use first content as route key Add returns any error encountered, nil means success.

func (*AggregatorSkywalking) Description

func (*AggregatorSkywalking) Description() string

func (*AggregatorSkywalking) Flush

func (p *AggregatorSkywalking) Flush() []*protocol.LogGroup

func (*AggregatorSkywalking) Init

func (p *AggregatorSkywalking) Init(context pipeline.Context, que pipeline.LogGroupQueue) (int, error)

func (*AggregatorSkywalking) Reset

func (p *AggregatorSkywalking) Reset()