v1beta

package
v0.0.0-...-25befae Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 15, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// GroupVersion is group version used to register these objects
	GroupVersion = schema.GroupVersion{Group: "logging.vlo.io", Version: "v1beta"}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type Limit 

type Limit struct {
	Cpu    string `json:"cpu,omitempty"`
	Memory string `json:"memory,omitempty"`
}

func (*Limit) DeepCopy 

func (in *Limit) DeepCopy() *Limit

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Limit.

func (*Limit) DeepCopyInto 

func (in *Limit) DeepCopyInto(out *Limit)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Requests 

type Requests struct {
	Cpu    string `json:"cpu,omitempty"`
	Memory string `json:"memory,omitempty"`
}

func (*Requests) DeepCopy 

func (in *Requests) DeepCopy() *Requests

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Requests.

func (*Requests) DeepCopyInto 

func (in *Requests) DeepCopyInto(out *Requests)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Resources 

type Resources struct {
	Limit    Limit    `json:"limits,omitempty"`
	Requests Requests `json:"requests,omitempty"`
}

func (*Resources) DeepCopy 

func (in *Resources) DeepCopy() *Resources

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Resources.

func (*Resources) DeepCopyInto 

func (in *Resources) DeepCopyInto(out *Resources)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorAgent 

type VectorAgent struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   VectorAgentSpec   `json:"spec,omitempty"`
	Status VectorAgentStatus `json:"status,omitempty"`
}

VectorAgent is the Schema for the agents API

func (*VectorAgent) DeepCopy 

func (in *VectorAgent) DeepCopy() *VectorAgent

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAgent.

func (*VectorAgent) DeepCopyInto 

func (in *VectorAgent) DeepCopyInto(out *VectorAgent)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*VectorAgent) DeepCopyObject 

func (in *VectorAgent) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*VectorAgent) Default 

func (r *VectorAgent) Default()

func (*VectorAgent) SetupWebhookWithManager 

func (r *VectorAgent) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*VectorAgent) ValidateCreate 

func (r *VectorAgent) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*VectorAgent) ValidateDelete 

func (r *VectorAgent) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*VectorAgent) ValidateUpdate 

func (r *VectorAgent) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type VectorAgentList 

type VectorAgentList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []VectorAgent `json:"items"`
}

VectorAgentList contains a list of VectorAgent

func (*VectorAgentList) DeepCopy 

func (in *VectorAgentList) DeepCopy() *VectorAgentList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAgentList.

func (*VectorAgentList) DeepCopyInto 

func (in *VectorAgentList) DeepCopyInto(out *VectorAgentList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*VectorAgentList) DeepCopyObject 

func (in *VectorAgentList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type VectorAgentPipeline 

type VectorAgentPipeline struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   VectorAgentPipelineSpec   `json:"spec,omitempty"`
	Status VectorAgentPipelineStatus `json:"status,omitempty"`
}

VectorAgentPipeline is the Schema for the agents API

func (*VectorAgentPipeline) DeepCopy 

func (in *VectorAgentPipeline) DeepCopy() *VectorAgentPipeline

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAgentPipeline.

func (*VectorAgentPipeline) DeepCopyInto 

func (in *VectorAgentPipeline) DeepCopyInto(out *VectorAgentPipeline)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*VectorAgentPipeline) DeepCopyObject 

func (in *VectorAgentPipeline) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*VectorAgentPipeline) Default 

func (r *VectorAgentPipeline) Default()

func (*VectorAgentPipeline) SetupWebhookWithManager 

func (r *VectorAgentPipeline) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*VectorAgentPipeline) ValidateCreate 

func (r *VectorAgentPipeline) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*VectorAgentPipeline) ValidateDelete 

func (r *VectorAgentPipeline) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*VectorAgentPipeline) ValidateUpdate 

func (r *VectorAgentPipeline) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type VectorAgentPipelineList 

type VectorAgentPipelineList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []VectorAgentPipeline `json:"items"`
}

VectorAgentPipelineList contains a list of VectorAgentPipeline

func (*VectorAgentPipelineList) DeepCopy 

func (in *VectorAgentPipelineList) DeepCopy() *VectorAgentPipelineList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAgentPipelineList.

func (*VectorAgentPipelineList) DeepCopyInto 

func (in *VectorAgentPipelineList) DeepCopyInto(out *VectorAgentPipelineList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*VectorAgentPipelineList) DeepCopyObject 

func (in *VectorAgentPipelineList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type VectorAgentPipelineSpec 

type VectorAgentPipelineSpec struct {

	// Foo is an example field of VectorAgentPipeline. Edit agent_pipeline_types.go to remove/update
	Transforms string                `json:"transforms,omitempty"`
	Sinks      []VectorPipelineSinks `json:"sinks,omitempty"`
	Selector   map[string]string     `json:"selector"`
}

VectorAgentPipelineSpec defines the desired state of VectorAgentPipeline

func (*VectorAgentPipelineSpec) DeepCopy 

func (in *VectorAgentPipelineSpec) DeepCopy() *VectorAgentPipelineSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAgentPipelineSpec.

func (*VectorAgentPipelineSpec) DeepCopyInto 

func (in *VectorAgentPipelineSpec) DeepCopyInto(out *VectorAgentPipelineSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorAgentPipelineStatus 

type VectorAgentPipelineStatus struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

func (*VectorAgentPipelineStatus) DeepCopy 

func (in *VectorAgentPipelineStatus) DeepCopy() *VectorAgentPipelineStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAgentPipelineStatus.

func (*VectorAgentPipelineStatus) DeepCopyInto 

func (in *VectorAgentPipelineStatus) DeepCopyInto(out *VectorAgentPipelineStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorAgentSpec 

type VectorAgentSpec struct {
	Image                 string            `json:"image,omitempty"`
	Tag                   string            `json:"tag,omitempty"`
	MetricsScrapeInterval int               `json:"metricsScrapeInterval,omitempty"`
	InternalLogs          bool              `json:"internalLogs,omitempty"`
	LogLevel              string            `json:"logLevel,omitempty"`
	Resources             Resources         `json:"resources,omitempty"`
	PodAnnotations        map[string]string `json:"podAnnotations,omitempty"`
}

func (*VectorAgentSpec) DeepCopy 

func (in *VectorAgentSpec) DeepCopy() *VectorAgentSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAgentSpec.

func (*VectorAgentSpec) DeepCopyInto 

func (in *VectorAgentSpec) DeepCopyInto(out *VectorAgentSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorAgentStatus 

type VectorAgentStatus struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

func (*VectorAgentStatus) DeepCopy 

func (in *VectorAgentStatus) DeepCopy() *VectorAgentStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAgentStatus.

func (*VectorAgentStatus) DeepCopyInto 

func (in *VectorAgentStatus) DeepCopyInto(out *VectorAgentStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorAggregator 

type VectorAggregator struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`

	Spec   VectorAggregatorSpec   `json:"spec,omitempty"`
	Status VectorAggregatorStatus `json:"status,omitempty"`
}

VectorAggregator is the Schema for the agents API

func (*VectorAggregator) DeepCopy 

func (in *VectorAggregator) DeepCopy() *VectorAggregator

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAggregator.

func (*VectorAggregator) DeepCopyInto 

func (in *VectorAggregator) DeepCopyInto(out *VectorAggregator)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*VectorAggregator) DeepCopyObject 

func (in *VectorAggregator) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*VectorAggregator) Default 

func (r *VectorAggregator) Default()

func (*VectorAggregator) SetupWebhookWithManager 

func (r *VectorAggregator) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*VectorAggregator) ValidateCreate 

func (r *VectorAggregator) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*VectorAggregator) ValidateDelete 

func (r *VectorAggregator) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*VectorAggregator) ValidateUpdate 

func (r *VectorAggregator) ValidateUpdate(old runtime.Object) error

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type VectorAggregatorList 

type VectorAggregatorList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []VectorAggregator `json:"items"`
}

VectorAggregatorList contains a list of VectorAggregator

func (*VectorAggregatorList) DeepCopy 

func (in *VectorAggregatorList) DeepCopy() *VectorAggregatorList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAggregatorList.

func (*VectorAggregatorList) DeepCopyInto 

func (in *VectorAggregatorList) DeepCopyInto(out *VectorAggregatorList)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*VectorAggregatorList) DeepCopyObject 

func (in *VectorAggregatorList) DeepCopyObject() runtime.Object

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type VectorAggregatorSinks 

type VectorAggregatorSinks struct {
	S3            VectorPipelineSinksS3            `json:"s3,omitempty"`
	Console       VectorPipelineSinksConsole       `json:"console,omitempty"`
	File          VectorPipelineSinksFile          `json:"file,omitempty"`
	Elasticsearch VectorPipelineSinksElasticsearch `json:"elasticsearch,omitempty"`
	HTTP          VectorPipelineSinksHTTP          `json:"HTTP,omitempty"`
	Kafka         VectorPipelineSinksKafka         `json:"kafka,omitempty"`
	Loki          VectorPipelineSinksLoki          `json:"loki,omitempty"`
}

func (*VectorAggregatorSinks) DeepCopy 

func (in *VectorAggregatorSinks) DeepCopy() *VectorAggregatorSinks

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAggregatorSinks.

func (*VectorAggregatorSinks) DeepCopyInto 

func (in *VectorAggregatorSinks) DeepCopyInto(out *VectorAggregatorSinks)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorAggregatorSources 

type VectorAggregatorSources struct {
	Kafka  VectorPipelineSourcesKafka  `json:"kafka,omitempty"`
	Vector VectorPipelineSourcesVector `json:"vector,omitempty"`
	AMQP   VectorAggregatorSourcesAMQP `json:"amqp,omitempty"`
	S3     VectorAggregatorSourcesS3   `json:"s3,omitempty"`
}

func (*VectorAggregatorSources) DeepCopy 

func (in *VectorAggregatorSources) DeepCopy() *VectorAggregatorSources

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAggregatorSources.

func (*VectorAggregatorSources) DeepCopyInto 

func (in *VectorAggregatorSources) DeepCopyInto(out *VectorAggregatorSources)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorAggregatorSourcesAMQP 

type VectorAggregatorSourcesAMQP struct {
	Name       string `json:"name,omitempty"`
	Connection string `json:"connection"`
	GroupID    string `json:"groupID"`
	OffsetKey  string `json:"offsetKey,omitempty"`
}

func (*VectorAggregatorSourcesAMQP) DeepCopy 

func (in *VectorAggregatorSourcesAMQP) DeepCopy() *VectorAggregatorSourcesAMQP

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAggregatorSourcesAMQP.

func (*VectorAggregatorSourcesAMQP) DeepCopyInto 

func (in *VectorAggregatorSourcesAMQP) DeepCopyInto(out *VectorAggregatorSourcesAMQP)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorAggregatorSourcesS3 

type VectorAggregatorSourcesS3 struct {
	Name        string `json:"name,omitempty"`
	Region      string `json:"region"`
	SQS         string `json:"SQS"`
	Compression string `json:"compression,omitempty"`
	Endpoint    string `json:"endpoint,omitempty"`
}

func (*VectorAggregatorSourcesS3) DeepCopy 

func (in *VectorAggregatorSourcesS3) DeepCopy() *VectorAggregatorSourcesS3

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAggregatorSourcesS3.

func (*VectorAggregatorSourcesS3) DeepCopyInto 

func (in *VectorAggregatorSourcesS3) DeepCopyInto(out *VectorAggregatorSourcesS3)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorAggregatorSpec 

type VectorAggregatorSpec struct {
	Image                 string                    `json:"image,omitempty"`
	Tag                   string                    `json:"tag,omitempty"`
	MetricsScrapeInterval int                       `json:"metricsScrapeInterval,omitempty"`
	InternalLogs          bool                      `json:"internalLogs,omitempty"`
	LogLevel              string                    `json:"logLevel,omitempty"`
	Resources             Resources                 `json:"resources,omitempty"`
	Sources               []VectorAggregatorSources `json:"sources"`
	Transforms            string                    `json:"transforms,omitempty"`
	Sinks                 []VectorAggregatorSinks   `json:"sinks"`
}

func (*VectorAggregatorSpec) DeepCopy 

func (in *VectorAggregatorSpec) DeepCopy() *VectorAggregatorSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAggregatorSpec.

func (*VectorAggregatorSpec) DeepCopyInto 

func (in *VectorAggregatorSpec) DeepCopyInto(out *VectorAggregatorSpec)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorAggregatorStatus 

type VectorAggregatorStatus struct {
	// INSERT ADDITIONAL STATUS FIELD - define observed state of cluster
	// Important: Run "make" to regenerate code after modifying this file
	Conditions []metav1.Condition `json:"conditions,omitempty" patchStrategy:"merge" patchMergeKey:"type"`
}

VectorAggregatorStatus defines the observed state of Agent

func (*VectorAggregatorStatus) DeepCopy 

func (in *VectorAggregatorStatus) DeepCopy() *VectorAggregatorStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorAggregatorStatus.

func (*VectorAggregatorStatus) DeepCopyInto 

func (in *VectorAggregatorStatus) DeepCopyInto(out *VectorAggregatorStatus)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinks 

type VectorPipelineSinks struct {
	S3            VectorPipelineSinksS3            `json:"s3,omitempty"`
	Console       VectorPipelineSinksConsole       `json:"console,omitempty"`
	File          VectorPipelineSinksFile          `json:"file,omitempty"`
	Elasticsearch VectorPipelineSinksElasticsearch `json:"elasticsearch,omitempty"`
	HTTP          VectorPipelineSinksHTTP          `json:"HTTP,omitempty"`
	Kafka         VectorPipelineSinksKafka         `json:"kafka,omitempty"`
	Loki          VectorPipelineSinksLoki          `json:"loki,omitempty"`
	Vector        VectorPipelineSinksVector        `json:"vector,omitempty"`
}

func (*VectorPipelineSinks) DeepCopy 

func (in *VectorPipelineSinks) DeepCopy() *VectorPipelineSinks

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinks.

func (*VectorPipelineSinks) DeepCopyInto 

func (in *VectorPipelineSinks) DeepCopyInto(out *VectorPipelineSinks)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinksConsole 

type VectorPipelineSinksConsole struct {
	Name     string   `json:"name,omitempty"`
	Inputs   []string `json:"inputs,omitempty"`
	Target   string   `json:"target,omitempty"`
	Encoding string   `json:"encoding,omitempty"`
}

func (*VectorPipelineSinksConsole) DeepCopy 

func (in *VectorPipelineSinksConsole) DeepCopy() *VectorPipelineSinksConsole

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinksConsole.

func (*VectorPipelineSinksConsole) DeepCopyInto 

func (in *VectorPipelineSinksConsole) DeepCopyInto(out *VectorPipelineSinksConsole)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinksElasticsearch 

type VectorPipelineSinksElasticsearch struct {
	Name        string                                 `json:"name,omitempty"`
	Inputs      []string                               `json:"inputs,omitempty"`
	Compression string                                 `json:"compression,omitempty"`
	Endpoints   []string                               `json:"endpoints,omitempty"`
	Pipeline    string                                 `json:"pipeline,omitempty"`
	Index       string                                 `json:"index,omitempty"`
	Mode        string                                 `json:"mode,omitempty"`
	Secret      VectorPipelineSinksElasticsearchSecret `json:"secret,omitempty"`
	IDKey       string                                 `json:"idKey,omitempty"`
	TLSCA       string                                 `json:"tlsCA,omitempty"`
}

func (*VectorPipelineSinksElasticsearch) DeepCopy 

func (in *VectorPipelineSinksElasticsearch) DeepCopy() *VectorPipelineSinksElasticsearch

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinksElasticsearch.

func (*VectorPipelineSinksElasticsearch) DeepCopyInto 

func (in *VectorPipelineSinksElasticsearch) DeepCopyInto(out *VectorPipelineSinksElasticsearch)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinksElasticsearchSecret 

type VectorPipelineSinksElasticsearchSecret struct {
	Name        string `json:"name"`
	UsernameKey string `json:"usernameKey"`
	PasswordKey string `json:"passwordKey"`
}

func (*VectorPipelineSinksElasticsearchSecret) DeepCopy 

func (in *VectorPipelineSinksElasticsearchSecret) DeepCopy() *VectorPipelineSinksElasticsearchSecret

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinksElasticsearchSecret.

func (*VectorPipelineSinksElasticsearchSecret) DeepCopyInto 

func (in *VectorPipelineSinksElasticsearchSecret) DeepCopyInto(out *VectorPipelineSinksElasticsearchSecret)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinksFile 

type VectorPipelineSinksFile struct {
	Name        string   `json:"name,omitempty"`
	Inputs      []string `json:"inputs,omitempty"`
	Compression string   `json:"compression,omitempty"`
	Path        string   `json:"path"`
	Encoding    string   `json:"encoding,omitempty"`
}

func (*VectorPipelineSinksFile) DeepCopy 

func (in *VectorPipelineSinksFile) DeepCopy() *VectorPipelineSinksFile

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinksFile.

func (*VectorPipelineSinksFile) DeepCopyInto 

func (in *VectorPipelineSinksFile) DeepCopyInto(out *VectorPipelineSinksFile)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinksHTTP 

type VectorPipelineSinksHTTP struct {
	Name        string                        `json:"name,omitempty"`
	Inputs      []string                      `json:"inputs,omitempty"`
	Compression string                        `json:"compression,omitempty"`
	URI         string                        `json:"uri"`
	Encoding    string                        `json:"encoding,omitempty"`
	Secret      VectorPipelineSinksHTTPSecret `json:"secret,omitempty"`
	Method      string                        `json:"method,omitempty"`
	TLSCA       string                        `json:"tlsCA,omitempty"`
}

func (*VectorPipelineSinksHTTP) DeepCopy 

func (in *VectorPipelineSinksHTTP) DeepCopy() *VectorPipelineSinksHTTP

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinksHTTP.

func (*VectorPipelineSinksHTTP) DeepCopyInto 

func (in *VectorPipelineSinksHTTP) DeepCopyInto(out *VectorPipelineSinksHTTP)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinksHTTPSecret 

type VectorPipelineSinksHTTPSecret struct {
	Name        string `json:"name"`
	UsernameKey string `json:"usernameKey"`
	PasswordKey string `json:"passwordKey"`
}

func (*VectorPipelineSinksHTTPSecret) DeepCopy 

func (in *VectorPipelineSinksHTTPSecret) DeepCopy() *VectorPipelineSinksHTTPSecret

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinksHTTPSecret.

func (*VectorPipelineSinksHTTPSecret) DeepCopyInto 

func (in *VectorPipelineSinksHTTPSecret) DeepCopyInto(out *VectorPipelineSinksHTTPSecret)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinksKafka 

type VectorPipelineSinksKafka struct {
	Name             string                       `json:"name,omitempty"`
	Inputs           []string                     `json:"inputs,omitempty"`
	BootstrapServers string                       `json:"bootstrapServers"`
	KeyField         string                       `json:"keyField,omitempty"`
	Topic            string                       `json:"topic"`
	Compression      string                       `json:"compression,omitempty"`
	Encoding         string                       `json:"encoding,omitempty"`
	Sasl             VectorPipelineSinksKafkaSasl `json:"sasl,omitempty"`
}

func (*VectorPipelineSinksKafka) DeepCopy 

func (in *VectorPipelineSinksKafka) DeepCopy() *VectorPipelineSinksKafka

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinksKafka.

func (*VectorPipelineSinksKafka) DeepCopyInto 

func (in *VectorPipelineSinksKafka) DeepCopyInto(out *VectorPipelineSinksKafka)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinksKafkaSasl 

type VectorPipelineSinksKafkaSasl struct {
	Mechanism string                             `json:"mechanism"`
	Secret    VectorPipelineSinksKafkaSaslSecret `json:"secret"`
}

func (*VectorPipelineSinksKafkaSasl) DeepCopy 

func (in *VectorPipelineSinksKafkaSasl) DeepCopy() *VectorPipelineSinksKafkaSasl

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinksKafkaSasl.

func (*VectorPipelineSinksKafkaSasl) DeepCopyInto 

func (in *VectorPipelineSinksKafkaSasl) DeepCopyInto(out *VectorPipelineSinksKafkaSasl)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinksKafkaSaslSecret 

type VectorPipelineSinksKafkaSaslSecret struct {
	Name        string `json:"name"`
	UsernameKey string `json:"usernameKey"`
	PasswordKey string `json:"passwordKey"`
}

func (*VectorPipelineSinksKafkaSaslSecret) DeepCopy 

func (in *VectorPipelineSinksKafkaSaslSecret) DeepCopy() *VectorPipelineSinksKafkaSaslSecret

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinksKafkaSaslSecret.

func (*VectorPipelineSinksKafkaSaslSecret) DeepCopyInto 

func (in *VectorPipelineSinksKafkaSaslSecret) DeepCopyInto(out *VectorPipelineSinksKafkaSaslSecret)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinksLoki 

type VectorPipelineSinksLoki struct {
	Name         string            `json:"name,omitempty"`
	Inputs       []string          `json:"inputs,omitempty"`
	Endpoint     string            `json:"endpoint"`
	Labels       map[string]string `json:"labels,omitempty"`
	Compression  string            `json:"compression,omitempty"`
	Encoding     string            `json:"encoding,omitempty"`
	ExceptFields []string          `json:"exceptFields,omitempty"`
	TenantId     string            `json:"tenantId,omitempty"`
}

func (*VectorPipelineSinksLoki) DeepCopy 

func (in *VectorPipelineSinksLoki) DeepCopy() *VectorPipelineSinksLoki

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinksLoki.

func (*VectorPipelineSinksLoki) DeepCopyInto 

func (in *VectorPipelineSinksLoki) DeepCopyInto(out *VectorPipelineSinksLoki)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinksS3 

type VectorPipelineSinksS3 struct {
	Name                 string                      `json:"name,omitempty"`
	Inputs               []string                    `json:"inputs,omitempty"`
	Bucket               string                      `json:"bucket"`
	Region               string                      `json:"region"`
	ACL                  string                      `json:"acl"`
	Compression          string                      `json:"compression,omitempty"`
	ContentType          string                      `json:"contentType,omitempty"`
	Encoding             string                      `json:"encoding,omitempty"`
	Endpoint             string                      `json:"endpoint,omitempty"`
	KeyPrefix            string                      `json:"keyPrefix,omitempty"`
	ServerSideEncryption string                      `json:"serverSideEncryption"`
	Secret               VectorPipelineSinksS3Secret `json:"secret"`
}

func (*VectorPipelineSinksS3) DeepCopy 

func (in *VectorPipelineSinksS3) DeepCopy() *VectorPipelineSinksS3

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinksS3.

func (*VectorPipelineSinksS3) DeepCopyInto 

func (in *VectorPipelineSinksS3) DeepCopyInto(out *VectorPipelineSinksS3)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinksS3Secret 

type VectorPipelineSinksS3Secret struct {
	Name string `json:"name"`
}

func (*VectorPipelineSinksS3Secret) DeepCopy 

func (in *VectorPipelineSinksS3Secret) DeepCopy() *VectorPipelineSinksS3Secret

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinksS3Secret.

func (*VectorPipelineSinksS3Secret) DeepCopyInto 

func (in *VectorPipelineSinksS3Secret) DeepCopyInto(out *VectorPipelineSinksS3Secret)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSinksVector 

type VectorPipelineSinksVector struct {
	Name        string   `json:"name,omitempty"`
	Inputs      []string `json:"inputs,omitempty"`
	Address     string   `json:"address"`
	Compression string   `json:"compression,omitempty"`
}

func (*VectorPipelineSinksVector) DeepCopy 

func (in *VectorPipelineSinksVector) DeepCopy() *VectorPipelineSinksVector

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSinksVector.

func (*VectorPipelineSinksVector) DeepCopyInto 

func (in *VectorPipelineSinksVector) DeepCopyInto(out *VectorPipelineSinksVector)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSourcesKafka 

type VectorPipelineSourcesKafka struct {
	Name             string                       `json:"name,omitempty"`
	BootstrapServers string                       `json:"bootstrapServers"`
	KeyField         string                       `json:"keyField,omitempty"`
	Topics           []string                     `json:"topics,omitempty"`
	Decoding         string                       `json:"decoding,omitempty"`
	GroupID          string                       `json:"groupID"`
	Sasl             VectorPipelineSinksKafkaSasl `json:"sasl,omitempty"`
	AutoOffsetReset  string                       `json:"autoOffsetReset"`
}

func (*VectorPipelineSourcesKafka) DeepCopy 

func (in *VectorPipelineSourcesKafka) DeepCopy() *VectorPipelineSourcesKafka

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSourcesKafka.

func (*VectorPipelineSourcesKafka) DeepCopyInto 

func (in *VectorPipelineSourcesKafka) DeepCopyInto(out *VectorPipelineSourcesKafka)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type VectorPipelineSourcesVector 

type VectorPipelineSourcesVector struct {
	Name    string `json:"name,omitempty"`
	Host    string `json:"host"`
	Port    int32  `json:"port"`
	Version string `json:"version,omitempty"`
}

func (*VectorPipelineSourcesVector) DeepCopy 

func (in *VectorPipelineSourcesVector) DeepCopy() *VectorPipelineSourcesVector

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VectorPipelineSourcesVector.

func (*VectorPipelineSourcesVector) DeepCopyInto 

func (in *VectorPipelineSourcesVector) DeepCopyInto(out *VectorPipelineSourcesVector)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.