googlecloud

Documentation

Index

• type GoogleCloudOutput
  • func (p *GoogleCloudOutput) ProcessMulti(ctx context.Context, entries []*entry.Entry) error
  • func (p *GoogleCloudOutput) Start() error
  • func (p *GoogleCloudOutput) Stop() error
• type GoogleCloudOutputConfig
  • func NewGoogleCloudOutputConfig(operatorID string) *GoogleCloudOutputConfig
  • func (c GoogleCloudOutputConfig) Build(buildContext operator.BuildContext) (operator.Operator, error)

Types

type GoogleCloudOutput

type GoogleCloudOutput struct {
	helper.OutputOperator
	buffer.Buffer
	// contains filtered or unexported fields
}

GoogleCloudOutput is an operator that sends logs to google cloud logging.

func (*GoogleCloudOutput) ProcessMulti

func (p *GoogleCloudOutput) ProcessMulti(ctx context.Context, entries []*entry.Entry) error

ProcessMulti will process multiple log entries and send them in batch to google cloud logging.

func (*GoogleCloudOutput) Start

func (p *GoogleCloudOutput) Start() error

Start will start the google cloud logger.

func (*GoogleCloudOutput) Stop

func (p *GoogleCloudOutput) Stop() error

Stop will flush the google cloud logger and close the underlying connection

type GoogleCloudOutputConfig

type GoogleCloudOutputConfig struct {
	helper.OutputConfig `yaml:",inline"`
	BufferConfig        buffer.Config `json:"buffer,omitempty" yaml:"buffer,omitempty"`

	Credentials     string            `json:"credentials,omitempty"      yaml:"credentials,omitempty"`
	CredentialsFile string            `json:"credentials_file,omitempty" yaml:"credentials_file,omitempty"`
	ProjectID       string            `json:"project_id"                 yaml:"project_id"`
	LogNameField    *entry.Field      `json:"log_name_field,omitempty"   yaml:"log_name_field,omitempty"`
	TraceField      *entry.Field      `json:"trace_field,omitempty"      yaml:"trace_field,omitempty"`
	SpanIDField     *entry.Field      `json:"span_id_field,omitempty"    yaml:"span_id_field,omitempty"`
	Timeout         operator.Duration `json:"timeout,omitempty"          yaml:"timeout,omitempty"`
	UseCompression  bool              `json:"use_compression,omitempty"  yaml:"use_compression,omitempty"`
}

GoogleCloudOutputConfig is the configuration of a google cloud output operator.

func NewGoogleCloudOutputConfig

func NewGoogleCloudOutputConfig(operatorID string) *GoogleCloudOutputConfig

func (GoogleCloudOutputConfig) Build

func (c GoogleCloudOutputConfig) Build(buildContext operator.BuildContext) (operator.Operator, error)

Build will build a google cloud output operator.