v1alpha1

package
v0.0.0-...-cfc66e3 Latest Latest
Warning

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

 Go to latest Published: Apr 20, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package v1alpha1 contains the v1alpha1 group Tarasque resources of the Crossplane provider. +kubebuilder:object:generate=true +groupName=tarasque.crossplane.io +versionName=v1alpha1

Index

Constants

View Source 
const (
	Group   = "tarasque.crossplane.io"
	Version = "v1alpha1"
)

Package type metadata.

Variables

View Source 
var (
	// SchemeGroupVersion is group version used to register these objects
	SchemeGroupVersion = schema.GroupVersion{Group: Group, Version: Version}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: SchemeGroupVersion}
)
View Source 
var (
	KafkaBenchKind             = reflect.TypeOf(KafkaBench{}).Name()
	KafkaBenchGroupKind        = schema.GroupKind{Group: Group, Kind: KafkaBenchKind}.String()
	KafkaBenchKindAPIVersion   = KafkaBenchKind + "." + SchemeGroupVersion.String()
	KafkaBenchGroupVersionKind = SchemeGroupVersion.WithKind(KafkaBenchKind)
)

KafkaBench type metadata.

Functions

This section is empty.

Types

type ConsumerBenchResultStats 

type ConsumerBenchResultStats struct {
	AssignedPartitions      []string          `json:"assignedPartitions,omitempty"`
	TotalMessagesReceived   int64             `json:"totalMessagesReceived,omitempty"`
	TotalBytesReceived      int64             `json:"totalBytesReceived,omitempty"`
	AverageMessageSizeBytes int64             `json:"averageMessageSizeBytes,omitempty"`
	AverageLatencyMs        float64           `json:"averageLatencyMs,omitempty"`
	P50LatencyMs            int64             `json:"p50LatencyMs,omitempty"`
	P95LatencyMs            int64             `json:"p95LatencyMs,omitempty"`
	P99LatencyMs            int64             `json:"p99LatencyMs,omitempty"`
	RecordProcessorStatus   map[string]string `json:"recordProcessorStatus,omitempty"`
}

A ConsumerBenchResultStats represents the benchmarking results obtained by the agent

func (*ConsumerBenchResultStats) DeepCopy 

func (in *ConsumerBenchResultStats) DeepCopy() *ConsumerBenchResultStats

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

func (*ConsumerBenchResultStats) DeepCopyInto 

func (in *ConsumerBenchResultStats) DeepCopyInto(out *ConsumerBenchResultStats)

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

type KafkaBench 

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

	Spec   KafkaBenchSpec   `json:"spec"`
	Status KafkaBenchStatus `json:"status,omitempty"`
}

A KafkaBench is an tarasque API type. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,template}

func (*KafkaBench) DeepCopy 

func (in *KafkaBench) DeepCopy() *KafkaBench

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

func (*KafkaBench) DeepCopyInto 

func (in *KafkaBench) DeepCopyInto(out *KafkaBench)

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

func (*KafkaBench) DeepCopyObject 

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

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

func (*KafkaBench) GetCondition 

func (mg *KafkaBench) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this KafkaBench.

func (*KafkaBench) GetDeletionPolicy 

func (mg *KafkaBench) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this KafkaBench.

func (*KafkaBench) GetProviderConfigReference 

func (mg *KafkaBench) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this KafkaBench.

func (*KafkaBench) GetProviderReference 

func (mg *KafkaBench) GetProviderReference() *xpv1.Reference

GetProviderReference of this KafkaBench. Deprecated: Use GetProviderConfigReference.

func (*KafkaBench) GetWriteConnectionSecretToReference 

func (mg *KafkaBench) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this KafkaBench.

func (*KafkaBench) SetConditions 

func (mg *KafkaBench) SetConditions(c ...xpv1.Condition)

SetConditions of this KafkaBench.

func (*KafkaBench) SetDeletionPolicy 

func (mg *KafkaBench) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this KafkaBench.

func (*KafkaBench) SetProviderConfigReference 

func (mg *KafkaBench) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this KafkaBench.

func (*KafkaBench) SetProviderReference 

func (mg *KafkaBench) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this KafkaBench. Deprecated: Use SetProviderConfigReference.

func (*KafkaBench) SetWriteConnectionSecretToReference 

func (mg *KafkaBench) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this KafkaBench.

type KafkaBenchList 

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

KafkaBenchList contains a list of KafkaBench

func (*KafkaBenchList) DeepCopy 

func (in *KafkaBenchList) DeepCopy() *KafkaBenchList

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

func (*KafkaBenchList) DeepCopyInto 

func (in *KafkaBenchList) DeepCopyInto(out *KafkaBenchList)

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

func (*KafkaBenchList) DeepCopyObject 

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

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

func (*KafkaBenchList) GetItems 

func (l *KafkaBenchList) GetItems() []resource.Managed

GetItems of this KafkaBenchList.

type KafkaBenchObservation 

type KafkaBenchObservation struct {
	TaskStatus     string                              `json:"taskStatus,omitempty"`
	TaskID         string                              `json:"taskId,omitempty"`
	WorkerID       int64                               `json:"workerId,omitempty"`
	ProducerStats  ProducerBenchResultStats            `json:"producerStats,omitempty"`
	ConsumerStats  map[string]ConsumerBenchResultStats `json:"consumerStats,omitempty"`
	RoundTripStats RoundTripBenchResultStats           `json:"roundTripStats,omitempty"`
}

KafkaBenchObservation are the observable fields of a KafkaBench.

func (*KafkaBenchObservation) DeepCopy 

func (in *KafkaBenchObservation) DeepCopy() *KafkaBenchObservation

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

func (*KafkaBenchObservation) DeepCopyInto 

func (in *KafkaBenchObservation) DeepCopyInto(out *KafkaBenchObservation)

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

type KafkaBenchSpec 

type KafkaBenchSpec struct {
	xpv1.ResourceSpec       `json:",inline"`
	Class                   string                 `json:"class,omitempty"`
	DurationMs              int64                  `json:"durationMs,omitempty"`
	ProducerNode            string                 `json:"producerNode,omitempty"`
	ConsumerNode            string                 `json:"consumerNode,omitempty"`
	ClientNode              string                 `json:"clientNode,omitempty"`
	ConsumerGroup           string                 `json:"consumerGroup,omitempty"`
	ThreadsPerWorker        int32                  `json:"threadsPerWorker,omitempty"`
	BootstrapServers        string                 `json:"bootstrapServers,omitempty"`
	TargetMessagesPerSec    int32                  `json:"targetMessagesPerSec,omitempty"`
	MaxMessages             int64                  `json:"maxMessages,omitempty"`
	ActiveTopics            map[string]KafkaTopics `json:"activeTopics,omitempty"`
	InactiveTopics          map[string]KafkaTopics `json:"inactiveTopics,omitempty"`
	ProducerConf            map[string]string      `json:"producerConf,omitempty"`
	ConsumerConf            map[string]string      `json:"consumerConf,omitempty"`
	CommonClientConf        map[string]string      `json:"commonClientConf,omitempty"`
	AdminClientConf         map[string]string      `json:"adminClientConf,omitempty"`
	TargetConnectionsPerSec int32                  `json:"targetConnectionsPerSec,omitempty"`
	NumThreads              int32                  `json:"numThreads,omitempty"`
	Action                  string                 `json:"action,omitempty"`
}

A KafkaBenchSpec defines the desired state of a KafkaBench.

func (*KafkaBenchSpec) DeepCopy 

func (in *KafkaBenchSpec) DeepCopy() *KafkaBenchSpec

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

func (*KafkaBenchSpec) DeepCopyInto 

func (in *KafkaBenchSpec) DeepCopyInto(out *KafkaBenchSpec)

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

type KafkaBenchStatus 

type KafkaBenchStatus struct {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          KafkaBenchObservation `json:"atProvider,omitempty"`
}

A KafkaBenchStatus represents the observed state of a KafkaBench.

func (*KafkaBenchStatus) DeepCopy 

func (in *KafkaBenchStatus) DeepCopy() *KafkaBenchStatus

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

func (*KafkaBenchStatus) DeepCopyInto 

func (in *KafkaBenchStatus) DeepCopyInto(out *KafkaBenchStatus)

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

type KafkaTopics 

type KafkaTopics struct {
	NumPartitions     int16 `json:"numPartitions,omitempty"`
	ReplicationFactor int8  `json:"replicationFactor,omitempty"`
}

KafkaTopics are part of the desired state fields

func (*KafkaTopics) DeepCopy 

func (in *KafkaTopics) DeepCopy() *KafkaTopics

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

func (*KafkaTopics) DeepCopyInto 

func (in *KafkaTopics) DeepCopyInto(out *KafkaTopics)

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

type ProducerBenchResultStats 

type ProducerBenchResultStats struct {
	TotalSent             int64   `mapstructure:"totalSent" json:"totalSent,omitempty"`
	AverageLatencyMs      float64 `mapstructure:"averageLatencyMs" json:"averageLatencyMs,omitempty"`
	P50LatencyMs          int64   `mapstructure:"p50LatencyMs" json:"p50LatencyMs,omitempty"`
	P95LatencyMs          int64   `mapstructure:"p95LatencyMs" json:"p95LatencyMs,omitempty"`
	P99LatencyMs          int64   `mapstructure:"p99LatencyMs" json:"p99LatencyMs,omitempty"`
	TransactionsCommitted int64   `mapstructure:"transactionsCommitted" json:"transactionsCommitted,omitempty"`
}

A ProducerBenchResultStats represents the benchmarking results obtained by the agent

func (*ProducerBenchResultStats) DeepCopy 

func (in *ProducerBenchResultStats) DeepCopy() *ProducerBenchResultStats

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

func (*ProducerBenchResultStats) DeepCopyInto 

func (in *ProducerBenchResultStats) DeepCopyInto(out *ProducerBenchResultStats)

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

type RoundTripBenchResultStats 

type RoundTripBenchResultStats struct {
	TotalUniqueSent int64 `mapstructure:"totalUniqueSent" json:"totalUniqueSent,omitempty"`
	TotalReceived   int64 `mapstructure:"totalReceived" json:"totalReceived,omitempty"`
}

A RoundTripBenchResultStats represents the benchmarking results obtained by the agent

func (*RoundTripBenchResultStats) DeepCopy 

func (in *RoundTripBenchResultStats) DeepCopy() *RoundTripBenchResultStats

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

func (*RoundTripBenchResultStats) DeepCopyInto 

func (in *RoundTripBenchResultStats) DeepCopyInto(out *RoundTripBenchResultStats)

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.