api

Feb 15, 2024

Changes in this version

+ const AddKubernetesInfraRuleType

+ const OpAddKubernetesInfra

+ const OtlpLogsType

+ const OtlpMetricsType

+ const OtlpTracesType

+ const PromFilterAbsence

+ const PromFilterExact

+ const PromFilterPresence

+ const PromFilterRegex

+ const StdinType

+ func MetricEncodeFilterTypeName(t string) string

+ func MetricEncodeOperationName(operation string) string

type API

+ EncodeOtlpLogs EncodeOtlpLogs

+ EncodeOtlpMetrics EncodeOtlpMetrics

+ EncodeOtlpTraces EncodeOtlpTraces

+ IngestStdin IngestStdin

+ type EncodeOtlpLogs struct

+ type EncodeOtlpMetrics struct

+ ExpiryTime Duration

+ Metrics MetricsItems

+ Prefix string

+ PushTimeInterval Duration

+ type EncodeOtlpTraces struct

+ SpanSplitter []string

+ type IngestStdin struct

+ type K8sInfraRule struct

+ InfraPrefix string

+ Inputs []string

+ Output string

+ type K8sRule struct

+ AddZone bool

+ type MetricEncodeFilterTypeEnum struct

+ Absence string

+ Exact string

+ Presence string

+ Regex string

+ type MetricEncodeOperationEnum struct

+ AggHistogram string

+ Counter string

+ Gauge string

+ Histogram string

+ type MetricsFilter struct

+ Key string

+ Type string

+ Value string

+ type MetricsItem struct

+ Buckets []float64

+ Filter MetricsFilter

+ Filters []MetricsFilter

+ Labels []string

+ Name string

+ Type string

+ ValueKey string

+ ValueScale float64

+ func (i *MetricsItem) GetFilters() []MetricsFilter

+ type MetricsItems []MetricsItem

type NetworkTransformRule

+ Kubernetes *K8sRule

+ KubernetesInfra *K8sInfraRule

+ type OtlpConnectionInfo struct

+ Address string

+ ConnectionType string

+ Headers map[string]string

+ Port int

+ TLS *ClientTLS

+ type PromConnectionInfo struct

+ Address string

+ Port int

+ TLS *PromTLSConf

type TransformFilterOperationEnum

+ AddField string

+ AddLabel string

+ AddLabelIf string

type TransformNetworkOperationEnum

+ AddKubernetesInfra string

Sep 8, 2023

Changes in this version

type OutputField

+ ReportMissing bool

type PromMetricsItem

+ Filters []PromMetricsFilter

+ func (i *PromMetricsItem) GetFilters() []PromMetricsFilter

type TimebasedFilterRule

+ IndexKeys []string

type TransformFilterOperationEnum

+ AddFieldIf string

+ AddRegExIf string

type TransformFilterRule

+ Assignee string

+ Output string

+ Parameters string

Jun 1, 2023

Changes in this version

+ const SyntheticType

+ func SASLTypeName(operation string) string

type AggregateDefinition

+ ExpiryTime Duration

+ type AggregateDefinitions []AggregateDefinition

+ type Aggregates struct

+ DefaultExpiryTime Duration

+ Rules AggregateDefinitions

type ConnTrack

+ TCPFlags ConnTrackTCPFlags

+ func (ct *ConnTrack) GetABFields() ([]string, []string)

type ConnTrackOperationEnum

+ First string

+ Last string

type ConnTrackSchedulingGroup

+ TerminatingTimeout Duration

+ type ConnTrackTCPFlags struct

+ DetectEndConnection bool

+ FieldName string

+ SwapAB bool

type EncodeKafka

+ SASL *SASLConfig

type IngestKafka

+ SASL *SASLConfig

+ type IngestSynthetic struct

+ BatchMaxLen int

+ Connections int

+ FlowLogsPerMin int

+ type SASLConfig struct

+ ClientIDPath string

+ ClientSecretPath string

+ Type string

+ type SASLTypeEnum struct

+ Plain string

+ ScramSHA512 string

Feb 16, 2023

Changes in this version

+ const IpfixType

type ConnTrack

+ MaxConnectionsTracked int

+ Scheduling []ConnTrackSchedulingGroup

type ConnTrackOutputRecordTypeEnum

+ Heartbeat string

+ type ConnTrackSchedulingGroup struct

+ EndConnectionTimeout Duration

+ HeartbeatInterval Duration

+ Selector map[string]interface{}

type FilterOperationEnum

+ FilterOperationCnt string

type PromEncode

+ MaxMetrics int

type TransformFilterOperationEnum

+ AddFieldIfDoesntExist string

+ type WriteIpfix struct

+ EnterpriseID int

+ TargetHost string

+ TargetPort int

+ Transport string

+ func (w *WriteIpfix) SetDefaults()

+ func (w *WriteIpfix) Validate() error

Jan 23, 2023

Changes in this version

+ const OpAddIPCategory

+ const OpReinterpretDirection

+ const ReinterpretDirectionRuleType

type GenericTransformRule

+ Multiplier int

+ type NetworkTransformDirectionInfo struct

+ DstHostField string

+ FlowDirectionField string

+ IfDirectionField string

+ ReporterIPField string

+ SrcHostField string

+ type NetworkTransformIPCategory struct

+ CIDRs []string

+ Name string

type TransformNetwork

+ DirectionInfo NetworkTransformDirectionInfo

+ IPCategories []NetworkTransformIPCategory

type TransformNetworkOperationEnum

+ AddIPCategory string

+ ReinterpretDirection string

Dec 19, 2022

Changes in this version

type EncodeS3

+ Secure bool

type PromEncode

+ Address string

Dec 6, 2022

Changes in this version

+ const IsFirstFieldName

+ const S3Type

type API

+ S3Encode EncodeS3

+ type EncodeS3 struct

+ AccessKeyId string

+ Account string

+ BatchSize int

+ Bucket string

+ Endpoint string

+ ObjectHeaderParameters map[string]interface{}

+ SecretAccessKey string

+ WriteTimeout Duration

Oct 14, 2022

Changes in this version

+ const OpAddIf

+ const OpAddKubernetes

+ const OpAddLocation

+ const OpAddRegexIf

+ const OpAddService

+ const OpAddSubnet

+ const TimebasedType

+ func FilterOperationName(operation string) string

type API

+ ExtractTimebased ExtractTimebased

type AggregateDefinition

+ GroupByKeys AggregateBy

+ OperationKey string

+ OperationType AggregateOperation

type ConnTrack

+ UpdateConnectionInterval Duration

+ func (ct *ConnTrack) Validate() error

type ConnTrackOutputRecordTypeEnum

+ UpdateConnection string

+ type ExtractTimebased struct

+ Rules []TimebasedFilterRule

+ type FilterOperationEnum struct

+ FilterOperationAvg string

+ FilterOperationDiff string

+ FilterOperationLast string

+ FilterOperationMax string

+ FilterOperationMin string

+ FilterOperationSum string

type IngestKafka

+ PullMaxBytes int

+ PullQueueCapacity int

type PromEncode

+ TLS *PromTLSConf

type PromEncodeOperationEnum

+ AggHistogram string

+ type PromTLSConf struct

+ CertPath string

+ KeyPath string

+ type TimebasedFilterRule struct

+ IndexKey string

+ Name string

+ OperationKey string

+ OperationType string

+ Reversed bool

+ TimeInterval Duration

+ TopK int

type TransformFilterOperationEnum

+ RemoveEntryIfEqual string

+ RemoveEntryIfNotEqual string

type TransformFilterRule

+ Value interface{}

type TransformNetwork

+ func (tn *TransformNetwork) GetServiceFiles() (string, string)

Aug 4, 2022

Changes in this version

+ const ConnTrackType

+ const FakeType

+ const HashIdFieldName

+ const RecordTypeFieldName

type API

+ ConnectionTracking ConnTrack

+ type ClientTLS struct

+ CACertPath string

+ InsecureSkipVerify bool

+ UserCertPath string

+ UserKeyPath string

+ func (c *ClientTLS) Build() (*tls.Config, error)

+ type Duration struct

+ func (d *Duration) UnmarshalJSON(b []byte) error

+ func (d *Duration) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (d Duration) MarshalJSON() ([]byte, error)

+ func (d Duration) MarshalYAML() (interface{}, error)

type EncodeKafka

+ TLS *ClientTLS

type IngestKafka

+ TLS *ClientTLS

type NetworkTransformRule

+ Assignee string

type WriteLoki

+ func (w *WriteLoki) SetDefaults()

Jun 26, 2022

Changes in this version

+ const AddIfRuleType

+ const AddKubernetesRuleType

+ const AddLocationRuleType

+ const AddRegExIfRuleType

+ const AddServiceRuleType

+ const AddSubnetRuleType

+ const AggregateType

+ const CollectorType

+ const ConnTrackingRuleType

+ const FileChunksType

+ const FileLoopType

+ const FileType

+ const FilterType

+ const GRPCType

+ const GenericType

+ const KafkaType

+ const LokiType

+ const NetworkType

+ const NoneType

+ const PromType

+ const StdoutType

+ const TagDoc

+ const TagEnum

+ const TagYaml

+ func ConnTrackOperationName(operation string) string

+ func ConnTrackOutputRecordTypeName(operation string) string

+ func DecoderName(decoder string) string

+ func GetEnumName(enum interface{}, operation string) string

+ func GetEnumReflectionTypeByFieldName(enumName string) reflect.Type

+ func KafkaEncodeBalancerName(operation string) string

+ func PromEncodeOperationName(operation string) string

+ func TransformFilterOperationName(operation string) string

+ func TransformGenericOperationName(operation string) string

+ func TransformNetworkOperationName(operation string) string

+ type API struct

+ ExtractAggregate AggregateDefinition

+ IngestCollector IngestCollector

+ IngestGRPCProto IngestGRPCProto

+ IngestKafka IngestKafka

+ KafkaEncode EncodeKafka

+ PromEncode PromEncode

+ TransformFilter TransformFilter

+ TransformGeneric TransformGeneric

+ TransformNetwork TransformNetwork

+ WriteLoki WriteLoki

+ WriteStdout WriteStdout

+ type AggregateBy []string

+ type AggregateDefinition struct

+ By AggregateBy

+ Name string

+ Operation AggregateOperation

+ RecordKey string

+ TopK int

+ type AggregateOperation string

+ type ConnTrack struct

+ EndConnectionTimeout time.Duration

+ KeyDefinition KeyDefinition

+ OutputFields []OutputField

+ OutputRecordTypes []string

+ type ConnTrackHash struct

+ FieldGroupARef string

+ FieldGroupBRef string

+ FieldGroupRefs []string

+ type ConnTrackOperationEnum struct

+ Count string

+ Max string

+ Min string

+ Sum string

+ type ConnTrackOutputRecordTypeEnum struct

+ EndConnection string

+ FlowLog string

+ NewConnection string

+ type Decoder struct

+ Type string

+ type DecoderEnum struct

+ JSON string

+ Protobuf string

+ type EncodeKafka struct

+ Address string

+ Balancer string

+ BatchBytes int64

+ BatchSize int

+ ReadTimeout int64

+ Topic string

+ WriteTimeout int64

+ type FieldGroup struct

+ Fields []string

+ Name string

+ type GenericTransform []GenericTransformRule

+ type GenericTransformRule struct

+ Input string

+ Output string

+ type IngestCollector struct

+ BatchMaxLen int

+ HostName string

+ Port int

+ PortLegacy int

+ type IngestGRPCProto struct

+ BufferLen int

+ Port int

+ type IngestKafka struct

+ BatchMaxLen int

+ BatchReadTimeout int64

+ Brokers []string

+ CommitInterval int64

+ Decoder Decoder

+ GroupBalancers []string

+ GroupId string

+ StartOffset string

+ Topic string

+ type KafkaEncodeBalancerEnum struct

+ Crc32 string

+ Hash string

+ LeastBytes string

+ Murmur2 string

+ RoundRobin string

+ type KeyDefinition struct

+ FieldGroups []FieldGroup

+ Hash ConnTrackHash

+ type NetworkTransformRule struct

+ Input string

+ Output string

+ Parameters string

+ Type string

+ type NetworkTransformRules []NetworkTransformRule

+ type OutputField struct

+ Input string

+ Name string

+ Operation string

+ SplitAB bool

+ type PromEncode struct

+ ExpiryTime int

+ Metrics PromMetricsItems

+ Port int

+ Prefix string

+ type PromEncodeOperationEnum struct

+ Counter string

+ Gauge string

+ Histogram string

+ type PromMetricsFilter struct

+ Key string

+ Value string

+ type PromMetricsItem struct

+ Buckets []float64

+ Filter PromMetricsFilter

+ Labels []string

+ Name string

+ Type string

+ ValueKey string

+ type PromMetricsItems []PromMetricsItem

+ type TransformFilter struct

+ Rules []TransformFilterRule

+ type TransformFilterOperationEnum struct

+ RemoveEntryIfDoesntExist string

+ RemoveEntryIfExists string

+ RemoveField string

+ type TransformFilterRule struct

+ Input string

+ Type string

+ type TransformGeneric struct

+ Policy string

+ Rules []GenericTransformRule

+ type TransformGenericOperationEnum struct

+ PreserveOriginalKeys string

+ ReplaceKeys string

+ type TransformNetwork struct

+ KubeConfigPath string

+ ProtocolsFile string

+ Rules NetworkTransformRules

+ ServicesFile string

+ type TransformNetworkOperationEnum struct

+ AddIf string

+ AddKubernetes string

+ AddLocation string

+ AddRegExIf string

+ AddService string

+ AddSubnet string

+ ConnTracking string

+ type WriteLoki struct

+ BatchSize int

+ BatchWait string

+ ClientConfig *promConfig.HTTPClientConfig

+ IgnoreList []string

+ Labels []string

+ MaxBackoff string

+ MaxRetries int

+ MinBackoff string

+ StaticLabels model.LabelSet

+ TenantID string

+ Timeout string

+ TimestampLabel model.LabelName

+ TimestampScale string

+ URL string

+ func GetWriteLokiDefaults() WriteLoki

+ func (wl *WriteLoki) Validate() error

+ type WriteStdout struct

+ Format string