exporter

Documentation

Index

• func RegisterExporter(name string, exporter Exporter)
• type Console
  • func (exporter *Console) Export(ctx context.Context, events chan *k8score.Event)
  • func (exporter *Console) Init(context.Context) error
  • func (exporter *Console) Name() string
• type ConsoleConfig
• type EventTemplate
  • func (tmplt *EventTemplate) Init() (err error)
• type Exporter
  • func GetExporter(name string) Exporter
• type SkyWalking
  • func (exporter *SkyWalking) Export(ctx context.Context, events chan *k8score.Event)
  • func (exporter *SkyWalking) Init(ctx context.Context) error
  • func (exporter *SkyWalking) Name() string
• type SkyWalkingConfig
• type SourceTemplate

Functions

func RegisterExporter

func RegisterExporter(name string, exporter Exporter)

Types

type Console

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

Console Exporter exports the events into console logs, this exporter is typically used for debugging.

func (*Console) Export

func (exporter *Console) Export(ctx context.Context, events chan *k8score.Event)

func (*Console) Init

func (exporter *Console) Init(context.Context) error

func (*Console) Name

func (exporter *Console) Name() string

type ConsoleConfig

type ConsoleConfig struct {
	Template *EventTemplate `mapstructure:"template"`
}

type EventTemplate

type EventTemplate struct {
	Source event.Source `mapstructure:"source"`

	Message string `mapstructure:"message"`
	// contains filtered or unexported fields
}

func (*EventTemplate) Init

func (tmplt *EventTemplate) Init() (err error)

type Exporter

type Exporter interface {
	Name() string
	Init(ctx context.Context) error
	Export(ctx context.Context, events chan *v1.Event)
}

func GetExporter

func GetExporter(name string) Exporter

type SkyWalking

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

SkyWalking Exporter exports the events into Apache SkyWalking OAP server.

func (*SkyWalking) Export

func (exporter *SkyWalking) Export(ctx context.Context, events chan *k8score.Event)

func (*SkyWalking) Init

func (exporter *SkyWalking) Init(ctx context.Context) error

func (*SkyWalking) Name

func (exporter *SkyWalking) Name() string

type SkyWalkingConfig

type SkyWalkingConfig struct {
	Address            string         `mapstructure:"address"`
	Template           *EventTemplate `mapstructure:"template"`
	EnableTLS          bool           `mapstructure:"enableTLS"`
	ClientCertPath     string         `mapstructure:"clientCertPath"`
	ClientKeyPath      string         `mapstructure:"clientKeyPath"`
	TrustedCertPath    string         `mapstructure:"trustedCertPath"`
	InsecureSkipVerify bool           `mapstructure:"insecureSkipVerify"`
}

type SourceTemplate

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