istio: Index | Files

package config

import ""


Package Files



var (
    ErrInvalidLengthConfig = fmt.Errorf("proto: negative length found during unmarshaling")
    ErrIntOverflowConfig   = fmt.Errorf("proto: integer overflow")

type Params Uses

type Params struct {
    // Address of listening fluentd daemon. Example: fluentd-server:24224
    // Default value is localhost:24224
    Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
    // Convert attributes of type duration to integers of unit ms in
    // logs. Default behaviour is a string representation including
    // unit.
    IntegerDuration bool `protobuf:"varint,2,opt,name=integer_duration,json=integerDuration,proto3" json:"integer_duration,omitempty"`
    // Controls the size of the queue of log entries awaiting processing by the
    // data push goroutine. This impacts the overall size of the backlog of
    // log entries that the handler will accept. If the handler falls behind and
    // the number of outstanding instances exceeds this limit, the handler will
    // begin to drop log entries.
    // Defaults to 1024.
    InstanceBufferSize int64 `protobuf:"varint,3,opt,name=instance_buffer_size,json=instanceBufferSize,proto3" json:"instance_buffer_size,omitempty"`
    // Controls the number of data bytes that are encoded and buffered by the handler before
    // they are pushed to the fluentd backend. This impacts the size and frequency of requests
    // sent to the fluentd backend. Once the buffer exceeds this limit, the handler will attempt to push
    // data to the backend.
    // Defaults to 8,388,608 (8 MiB).
    MaxBatchSizeBytes int64 `protobuf:"varint,4,opt,name=max_batch_size_bytes,json=maxBatchSizeBytes,proto3" json:"max_batch_size_bytes,omitempty"`
    // Duration interval for pushing batched data to the fluentd backend. At least once every duration,
    // the handler will attempt to push data.
    // Default to 1m.
    PushIntervalDuration time.Duration `protobuf:"bytes,5,opt,name=push_interval_duration,json=pushIntervalDuration,proto3,stdduration" json:"push_interval_duration"`
    // Timeout duration for pushing batched data to the fluentd backend. If a request takes longer than
    // the configured timeout, the request will be cancelled and dropped.
    // Default to 1m.
    PushTimeoutDuration time.Duration `protobuf:"bytes,6,opt,name=push_timeout_duration,json=pushTimeoutDuration,proto3,stdduration" json:"push_timeout_duration"`

Configuration parameters for the fluentd adapter.

This adapter accepts logentry instance. It then routes those logentries to a listening fluentd daemon with minimal transformation. Fluentd uses a "tag" for all logs. The "Name" of the logentry is used as the "tag", unless the logentry already has a variable "tag".

func (*Params) Descriptor Uses

func (*Params) Descriptor() ([]byte, []int)

func (*Params) Marshal Uses

func (m *Params) Marshal() (dAtA []byte, err error)

func (*Params) MarshalTo Uses

func (m *Params) MarshalTo(dAtA []byte) (int, error)

func (*Params) MarshalToSizedBuffer Uses

func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Params) ProtoMessage Uses

func (*Params) ProtoMessage()

func (*Params) Reset Uses

func (m *Params) Reset()

func (*Params) Size Uses

func (m *Params) Size() (n int)

func (*Params) String Uses

func (this *Params) String() string

func (*Params) Unmarshal Uses

func (m *Params) Unmarshal(dAtA []byte) error

func (*Params) XXX_DiscardUnknown Uses

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal Uses

func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Params) XXX_Merge Uses

func (m *Params) XXX_Merge(src proto.Message)

func (*Params) XXX_Size Uses

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal Uses

func (m *Params) XXX_Unmarshal(b []byte) error

Package config imports 10 packages (graph) and is imported by 4 packages. Updated 2019-10-27. Refresh now. Tools for package owners.