googlecloud

Documentation

Index

• type GoogleCloudOutput
  • func (g *GoogleCloudOutput) IsTooLargeError(err error) bool
  • func (g *GoogleCloudOutput) Process(ctx context.Context, e *entry.Entry) error
  • func (g *GoogleCloudOutput) Send(ctx context.Context, entries []*entry.Entry) error
  • func (g *GoogleCloudOutput) Start() error
  • func (g *GoogleCloudOutput) Stop() error
• type GoogleCloudOutputConfig
  • func NewGoogleCloudOutputConfig(operatorID string) *GoogleCloudOutputConfig
  • func (c GoogleCloudOutputConfig) Build(bc operator.BuildContext) ([]operator.Operator, error)

Types

type GoogleCloudOutput

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

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

func (*GoogleCloudOutput) IsTooLargeError

func (g *GoogleCloudOutput) IsTooLargeError(err error) bool

func (*GoogleCloudOutput) Process

func (g *GoogleCloudOutput) Process(ctx context.Context, e *entry.Entry) error

Process processes an entry

func (*GoogleCloudOutput) Send

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

func (*GoogleCloudOutput) Start

func (g *GoogleCloudOutput) Start() error

Start will start the google cloud logger.

func (*GoogleCloudOutput) Stop

func (g *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"`
	FlusherConfig       flusher.Config  `json:"flusher,omitempty" yaml:"flusher,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"`
	LocationField       *entry.Field    `json:"location_field,omitempty"   yaml:"location_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             helper.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

NewGoogleCloudOutputConfig creates a new google cloud output config with default

func (GoogleCloudOutputConfig) Build

func (c GoogleCloudOutputConfig) Build(bc operator.BuildContext) ([]operator.Operator, error)

Build will build a google cloud output operator.