googlecloud

Dec 14, 2021

Changes in this version

+ type Client interface

+ Close func() error

+ WriteLogEntries func(ctx context.Context, req *logging.WriteLogEntriesRequest, ...) (*logging.WriteLogEntriesResponse, error)

+ type ClientBuilder = func(ctx context.Context, opts ...option.ClientOption) (Client, error)

+ type EntryBuilder interface

+ Build func(entry *entry.Entry) (*logging.LogEntry, error)

type GoogleCloudOutputConfig

+ MaxEntrySize helper.ByteSize

+ MaxRequestSize helper.ByteSize

+ type GoogleEntryBuilder struct

+ LocationField *entry.Field

+ LogNameField *entry.Field

+ MaxEntrySize int

+ ProjectID string

+ SpanIDField *entry.Field

+ TraceField *entry.Field

+ func (g *GoogleEntryBuilder) Build(entry *entry.Entry) (*logging.LogEntry, error)

+ type GoogleRequestBuilder struct

+ EntryBuilder EntryBuilder

+ MaxRequestSize int

+ ProjectID string

+ func (g *GoogleRequestBuilder) Build(entries []*entry.Entry) []*logging.WriteLogEntriesRequest

+ type RequestBuilder interface

+ Build func(entries []*entry.Entry) []*logging.WriteLogEntriesRequest

+ type ResourceKey = string

+ type ResourceType = string

Sep 22, 2021

Changes in this version

type GoogleCloudOutputConfig

+ LocationField *entry.Field

May 28, 2021

Changes in this version

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

type GoogleCloudOutputConfig

+ FlusherConfig flusher.Config

Aug 31, 2020

Changes in this version

+ type GoogleCloudOutput struct

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

+ func (p *GoogleCloudOutput) Start() error

+ func (p *GoogleCloudOutput) Stop() error

+ type GoogleCloudOutputConfig struct

+ BufferConfig buffer.Config

+ Credentials string

+ CredentialsFile string

+ LogNameField *entry.Field

+ ProjectID string

+ SpanIDField *entry.Field

+ Timeout operator.Duration

+ TraceField *entry.Field

+ UseCompression bool

+ func NewGoogleCloudOutputConfig(operatorID string) *GoogleCloudOutputConfig

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