output

package

Go to main page

Versions in this module

v2

v2.9.0

Jun 13, 2024

Changes in this version

type Elasticsearch

+ TotalLimitSize string

type Forward

+ Tag string

v2.8.0

Apr 22, 2024

Changes in this version

type Elasticsearch

+ WriteOperation string

type S3

+ Profile string

v2.7.0

Dec 18, 2023

v2.6.0

Nov 22, 2023

v2.5.0

Sep 13, 2023

Changes in this version

type Elasticsearch

+ Compress string

+ type Gelf struct

+ Compress *bool

+ FullMessageKey string

+ Host string

+ HostKey string

+ LevelKey string

+ Mode string

+ PacketSize *int32

+ Port *int32

+ ShortMessageKey string

+ TimestampKey string

+ func (_ *Gelf) Name() string

+ func (g *Gelf) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ func (in *Gelf) DeepCopy() *Gelf

+ func (in *Gelf) DeepCopyInto(out *Gelf)

+ type PrometheusExporter struct

+ AddLabels map[string]string

+ Host string

+ Port *int32

+ func (_ *PrometheusExporter) Name() string

+ func (in *PrometheusExporter) DeepCopy() *PrometheusExporter

+ func (in *PrometheusExporter) DeepCopyInto(out *PrometheusExporter)

+ func (p *PrometheusExporter) Params(sl plugins.SecretLoader) (*params.KVs, error)

v2.4.0

Jul 19, 2023

Changes in this version

type OpenSearch

+ TotalLimitSize string

+ type S3 struct

+ AutoRetryRequests *bool

+ Bucket string

+ CannedAcl string

+ Compression string

+ ContentType string

+ Endpoint string

+ ExternalId string

+ JsonDateFormat string

+ JsonDateKey string

+ LogKey string

+ PreserveDataOrdering *bool

+ Region string

+ RetryLimit *int32

+ RoleArn string

+ S3KeyFormat string

+ S3KeyFormatTagDelimiters string

+ SendContentMd5 *bool

+ StaticFilePath *bool

+ StorageClass string

+ StoreDir string

+ StoreDirLimitSize string

+ StsEndpoint string

+ TotalFileSize string

+ UploadChunkSize string

+ UploadTimeout string

+ UsePutObject *bool

+ func (_ *S3) Name() string

+ func (in *S3) DeepCopy() *S3

+ func (in *S3) DeepCopyInto(out *S3)

+ func (o *S3) Params(sl plugins.SecretLoader) (*params.KVs, error)

v2.3.0

Jun 5, 2023

Changes in this version

+ type InfluxDB struct

+ AutoTags *bool

+ Bucket string

+ Database string

+ HTTPPasswd *plugins.Secret

+ HTTPToken *plugins.Secret

+ HTTPUser *plugins.Secret

+ Host string

+ Org string

+ Port *int32

+ SequenceTag string

+ TagKeys []string

+ TagsListEnabled *bool

+ TagsListKey string

+ func (_ *InfluxDB) Name() string

+ func (in *InfluxDB) DeepCopy() *InfluxDB

+ func (in *InfluxDB) DeepCopyInto(out *InfluxDB)

+ func (o *InfluxDB) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ type Kinesis struct

+ AutoRetryRequests *bool

+ Endpoint string

+ ExternalID string

+ LogKey string

+ Region string

+ RoleARN string

+ STSEndpoint string

+ Stream string

+ TimeKey string

+ TimeKeyFormat string

+ func (*Kinesis) Name() string

+ func (in *Kinesis) DeepCopy() *Kinesis

+ func (in *Kinesis) DeepCopyInto(out *Kinesis)

+ func (k *Kinesis) Params(_ plugins.SecretLoader) (*params.KVs, error)

type Loki

+ DropSingleKey string

+ LabelMapPath string

+ RemoveKeys []string

+ TenantIDKey string

type OpenTelemetry

+ LogsUri string

+ MetricsUri string

+ TracesUri string

v2.2.0

Apr 7, 2023

Changes in this version

+ type AzureBlob struct

+ AccountName string

+ AutoCreateContainer *bool

+ BlobType string

+ ContainerName string

+ EmulatorMode *bool

+ Endpoint string

+ Path string

+ SharedKey *plugins.Secret

+ TLS *bool

+ func (_ *AzureBlob) Name() string

+ func (in *AzureBlob) DeepCopy() *AzureBlob

+ func (in *AzureBlob) DeepCopyInto(out *AzureBlob)

+ func (o *AzureBlob) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ type AzureLogAnalytics struct

+ CustomerID *plugins.Secret

+ LogType string

+ SharedKey *plugins.Secret

+ TimeGenerated *bool

+ TimeKey string

+ func (_ *AzureLogAnalytics) Name() string

+ func (in *AzureLogAnalytics) DeepCopy() *AzureLogAnalytics

+ func (in *AzureLogAnalytics) DeepCopyInto(out *AzureLogAnalytics)

+ func (o *AzureLogAnalytics) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ type CloudWatch struct

+ AutoCreateGroup *bool

+ AutoRetryRequests *bool

+ Endpoint string

+ ExternalID string

+ LogFormat string

+ LogGroupName string

+ LogGroupTemplate string

+ LogKey string

+ LogRetentionDays *int32

+ LogStreamName string

+ LogStreamPrefix string

+ LogStreamTemplate string

+ MetricDimensions string

+ MetricNamespace string

+ Region string

+ RoleArn string

+ StsEndpoint string

+ func (_ *CloudWatch) Name() string

+ func (in *CloudWatch) DeepCopy() *CloudWatch

+ func (in *CloudWatch) DeepCopyInto(out *CloudWatch)

+ func (o *CloudWatch) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ type DataDog struct

+ APIKey string

+ Compress string

+ Host string

+ IncludeTagKey *bool

+ JSONDateKey string

+ MessageKey string

+ Provider string

+ Proxy string

+ Service string

+ Source string

+ TLS *bool

+ TagKey string

+ Tags string

+ func (_ *DataDog) Name() string

+ func (in *DataDog) DeepCopy() *DataDog

+ func (in *DataDog) DeepCopyInto(out *DataDog)

+ func (s *DataDog) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ type Elasticsearch struct

+ AWSAuth string

+ AWSExternalID string

+ AWSRegion string

+ AWSRoleARN string

+ AWSSTSEndpoint string

+ BufferSize string

+ CloudAuth string

+ CloudID string

+ CurrentTimeIndex *bool

+ GenerateID *bool

+ HTTPPasswd *plugins.Secret

+ HTTPUser *plugins.Secret

+ Host string

+ IdKey string

+ IncludeTagKey *bool

+ Index string

+ LogstashDateFormat string

+ LogstashFormat *bool

+ LogstashPrefix string

+ LogstashPrefixKey string

+ Path string

+ Pipeline string

+ Port *int32

+ ReplaceDots *bool

+ SuppressTypeName string

+ TagKey string

+ TimeKey string

+ TimeKeyFormat string

+ TimeKeyNanos *bool

+ TraceError *bool

+ TraceOutput *bool

+ Type string

+ func (_ *Elasticsearch) Name() string

+ func (es *Elasticsearch) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ func (in *Elasticsearch) DeepCopy() *Elasticsearch

+ func (in *Elasticsearch) DeepCopyInto(out *Elasticsearch)

+ type File struct

+ Delimiter string

+ File string

+ Format string

+ LabelDelimiter string

+ Path string

+ Template string

+ func (_ *File) Name() string

+ func (f *File) Params(_ plugins.SecretLoader) (*params.KVs, error)

+ func (in *File) DeepCopy() *File

+ func (in *File) DeepCopyInto(out *File)

+ type Firehose struct

+ AutoRetryRequests *bool

+ DataKeys *string

+ DeliveryStream string

+ Endpoint *string

+ LogKey *string

+ Region string

+ RoleARN *string

+ STSEndpoint *string

+ TimeKey *string

+ TimeKeyFormat *string

+ func (_ *Firehose) Name() string

+ func (in *Firehose) DeepCopy() *Firehose

+ func (in *Firehose) DeepCopyInto(out *Firehose)

+ func (l *Firehose) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ type Forward struct

+ EmptySharedKey *bool

+ Host string

+ Password *plugins.Secret

+ Port *int32

+ RequireAckResponse *bool

+ SelfHostname string

+ SendOptions *bool

+ SharedKey string

+ TimeAsInteger *bool

+ Username *plugins.Secret

+ func (_ *Forward) Name() string

+ func (f *Forward) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ func (in *Forward) DeepCopy() *Forward

+ func (in *Forward) DeepCopyInto(out *Forward)

+ type HTTP struct

+ AllowDuplicatedHeaders *bool

+ Compress string

+ Format string

+ GelfFullMessageKey string

+ GelfHostKey string

+ GelfLevelKey string

+ GelfShortMessageKey string

+ GelfTimestampKey string

+ HTTPPasswd *plugins.Secret

+ HTTPUser *plugins.Secret

+ HeaderTag string

+ Headers map[string]string

+ Host string

+ JsonDateFormat string

+ JsonDateKey string

+ Port *int32

+ Proxy string

+ Uri string

+ func (*HTTP) Name() string

+ func (h *HTTP) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ func (in *HTTP) DeepCopy() *HTTP

+ func (in *HTTP) DeepCopyInto(out *HTTP)

+ type Kafka struct

+ Brokers string

+ DynamicTopic *bool

+ Format string

+ MessageKey string

+ MessageKeyField string

+ QueueFullRetries *int64

+ Rdkafka map[string]string

+ TimestampFormat string

+ TimestampKey string

+ TopicKey string

+ Topics string

+ func (*Kafka) Name() string

+ func (in *Kafka) DeepCopy() *Kafka

+ func (in *Kafka) DeepCopyInto(out *Kafka)

+ func (k *Kafka) Params(_ plugins.SecretLoader) (*params.KVs, error)

+ type Loki struct

+ AutoKubernetesLabels string

+ HTTPPasswd *plugins.Secret

+ HTTPUser *plugins.Secret

+ Host string

+ LabelKeys []string

+ Labels []string

+ LineFormat string

+ Port *int32

+ TenantID *plugins.Secret

+ func (_ *Loki) Name() string

+ func (in *Loki) DeepCopy() *Loki

+ func (in *Loki) DeepCopyInto(out *Loki)

+ func (l *Loki) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ type Null struct

+ func (_ *Null) Name() string

+ func (_ *Null) Params(_ plugins.SecretLoader) (*params.KVs, error)

+ func (in *Null) DeepCopy() *Null

+ func (in *Null) DeepCopyInto(out *Null)

+ type OpenSearch struct

+ AWSAuth string

+ AWSExternalID string

+ AWSRegion string

+ AWSRoleARN string

+ AWSSTSEndpoint string

+ BufferSize string

+ CurrentTimeIndex *bool

+ GenerateID *bool

+ HTTPPasswd *plugins.Secret

+ HTTPUser *plugins.Secret

+ Host string

+ IdKey string

+ IncludeTagKey *bool

+ Index string

+ LogstashDateFormat string

+ LogstashFormat *bool

+ LogstashPrefix string

+ LogstashPrefixKey string

+ Path string

+ Pipeline string

+ Port *int32

+ ReplaceDots *bool

+ SuppressTypeName *bool

+ TagKey string

+ TimeKey string

+ TimeKeyFormat string

+ TimeKeyNanos *bool

+ TraceError *bool

+ TraceOutput *bool

+ Type string

+ Workers *int32

+ WriteOperation string

+ func (_ *OpenSearch) Name() string

+ func (in *OpenSearch) DeepCopy() *OpenSearch

+ func (in *OpenSearch) DeepCopyInto(out *OpenSearch)

+ func (o *OpenSearch) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ type OpenTelemetry struct

+ AddLabel map[string]string

+ HTTPPasswd *plugins.Secret

+ HTTPUser *plugins.Secret

+ Header map[string]string

+ Host string

+ LogResponsePayload *bool

+ Port *int32

+ Proxy string

+ Uri string

+ func (_ *OpenTelemetry) Name() string

+ func (in *OpenTelemetry) DeepCopy() *OpenTelemetry

+ func (in *OpenTelemetry) DeepCopyInto(out *OpenTelemetry)

+ func (o *OpenTelemetry) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ type PrometheusRemoteWrite struct

+ AddLabels map[string]string

+ HTTPPasswd *plugins.Secret

+ HTTPUser *plugins.Secret

+ Headers map[string]string

+ Host string

+ LogResponsePayload *bool

+ Port *int32

+ Proxy string

+ URI string

+ Workers *int32

+ func (_ *PrometheusRemoteWrite) Name() string

+ func (in *PrometheusRemoteWrite) DeepCopy() *PrometheusRemoteWrite

+ func (in *PrometheusRemoteWrite) DeepCopyInto(out *PrometheusRemoteWrite)

+ func (p *PrometheusRemoteWrite) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ type Splunk struct

+ Channel string

+ Compress string

+ EventFields []string

+ EventHost string

+ EventIndex string

+ EventIndexKey string

+ EventKey string

+ EventSource string

+ EventSourcetype string

+ EventSourcetypeKey string

+ HTTPBufferSize string

+ HTTPDebugBadRequest *bool

+ HTTPPasswd *plugins.Secret

+ HTTPUser *plugins.Secret

+ Host string

+ Port *int32

+ SplunkSendRaw *bool

+ SplunkToken *plugins.Secret

+ Workers *int32

+ func (_ *Splunk) Name() string

+ func (in *Splunk) DeepCopy() *Splunk

+ func (in *Splunk) DeepCopyInto(out *Splunk)

+ func (o *Splunk) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ type Stackdriver struct

+ AutoformatStackdriverTrace *bool

+ CustomK8sRegex string

+ ExportToProjectID string

+ GoogleServiceCredentials string

+ Job string

+ K8sClusterLocation string

+ K8sClusterName string

+ Labels []string

+ LabelsKey string

+ Location string

+ LogNameKey string

+ MetadataServer string

+ Namespace string

+ NodeID string

+ Resource string

+ ResourceLabels []string

+ ServiceAccountEmail *plugins.Secret

+ ServiceAccountSecret *plugins.Secret

+ SeverityKey string

+ TagPrefix string

+ TaskID string

+ Workers *int32

+ func (_ *Stackdriver) Name() string

+ func (in *Stackdriver) DeepCopy() *Stackdriver

+ func (in *Stackdriver) DeepCopyInto(out *Stackdriver)

+ func (o *Stackdriver) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ type Stdout struct

+ Format string

+ JsonDateFormat string

+ JsonDateKey string

+ func (_ *Stdout) Name() string

+ func (in *Stdout) DeepCopy() *Stdout

+ func (in *Stdout) DeepCopyInto(out *Stdout)

+ func (s *Stdout) Params(_ plugins.SecretLoader) (*params.KVs, error)

+ type Syslog struct

+ Host string

+ Mode string

+ Port *int32

+ SyslogAppnameKey string

+ SyslogFacilityKey string

+ SyslogFormat string

+ SyslogHostnameKey string

+ SyslogMaxSize *int32

+ SyslogMessageIDKey string

+ SyslogMessageKey string

+ SyslogProcessIDKey string

+ SyslogSDKey string

+ SyslogSeverityKey string

+ func (_ *Syslog) Name() string

+ func (in *Syslog) DeepCopy() *Syslog

+ func (in *Syslog) DeepCopyInto(out *Syslog)

+ func (s *Syslog) Params(sl plugins.SecretLoader) (*params.KVs, error)

+ type TCP struct

+ Format string

+ Host string

+ JsonDateFormat string

+ JsonDateKey string

+ Port *int32

+ func (_ *TCP) Name() string

+ func (in *TCP) DeepCopy() *TCP

+ func (in *TCP) DeepCopyInto(out *TCP)

+ func (t *TCP) Params(sl plugins.SecretLoader) (*params.KVs, error)

Other modules containing this package

github.com/fluent/fluent-operator

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL