managerv1

package
v0.22.3 Latest Latest
Warning

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

 Go to latest Published: Feb 7, 2025 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_chalk_manager_v1_builder_proto protoreflect.FileDescriptor
View Source 
var File_chalk_manager_v1_status_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type CreateKafkaTopicsRequest added in v0.21.15 

type CreateKafkaTopicsRequest struct {
	Topics []*KafkaTopic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateKafkaTopicsRequest) Descriptor deprecated added in v0.21.15 

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

Deprecated: Use CreateKafkaTopicsRequest.ProtoReflect.Descriptor instead.

func (*CreateKafkaTopicsRequest) GetTopics added in v0.21.15 

func (x *CreateKafkaTopicsRequest) GetTopics() []*KafkaTopic

func (*CreateKafkaTopicsRequest) ProtoMessage added in v0.21.15 

func (*CreateKafkaTopicsRequest) ProtoMessage()

func (*CreateKafkaTopicsRequest) ProtoReflect added in v0.21.15 

func (x *CreateKafkaTopicsRequest) ProtoReflect() protoreflect.Message

func (*CreateKafkaTopicsRequest) Reset added in v0.21.15 

func (x *CreateKafkaTopicsRequest) Reset()

func (*CreateKafkaTopicsRequest) String added in v0.21.15 

func (x *CreateKafkaTopicsRequest) String() string

type CreateKafkaTopicsResponse added in v0.21.15 

type CreateKafkaTopicsResponse struct {
	// contains filtered or unexported fields
}

func (*CreateKafkaTopicsResponse) Descriptor deprecated added in v0.21.15 

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

Deprecated: Use CreateKafkaTopicsResponse.ProtoReflect.Descriptor instead.

func (*CreateKafkaTopicsResponse) ProtoMessage added in v0.21.15 

func (*CreateKafkaTopicsResponse) ProtoMessage()

func (*CreateKafkaTopicsResponse) ProtoReflect added in v0.21.15 

func (x *CreateKafkaTopicsResponse) ProtoReflect() protoreflect.Message

func (*CreateKafkaTopicsResponse) Reset added in v0.21.15 

func (x *CreateKafkaTopicsResponse) Reset()

func (*CreateKafkaTopicsResponse) String added in v0.21.15 

func (x *CreateKafkaTopicsResponse) String() string

type GetClusterMetricsRequest 

type GetClusterMetricsRequest struct {
	GetMask *fieldmaskpb.FieldMask `protobuf:"bytes,1,opt,name=get_mask,json=getMask,proto3" json:"get_mask,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClusterMetricsRequest) Descriptor deprecated 

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

Deprecated: Use GetClusterMetricsRequest.ProtoReflect.Descriptor instead.

func (*GetClusterMetricsRequest) GetGetMask added in v0.21.21 

func (x *GetClusterMetricsRequest) GetGetMask() *fieldmaskpb.FieldMask

func (*GetClusterMetricsRequest) ProtoMessage 

func (*GetClusterMetricsRequest) ProtoMessage()

func (*GetClusterMetricsRequest) ProtoReflect 

func (x *GetClusterMetricsRequest) ProtoReflect() protoreflect.Message

func (*GetClusterMetricsRequest) Reset 

func (x *GetClusterMetricsRequest) Reset()

func (*GetClusterMetricsRequest) String 

func (x *GetClusterMetricsRequest) String() string

type GetClusterMetricsResponse 

type GetClusterMetricsResponse struct {

	// Deprecated: Marked as deprecated in chalk/manager/v1/status.proto.
	Metrics        string  `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	CnpgMetrics    *string `protobuf:"bytes,2,opt,name=cnpg_metrics,json=cnpgMetrics,proto3,oneof" json:"cnpg_metrics,omitempty"`
	EnvoyMetrics   *string `protobuf:"bytes,3,opt,name=envoy_metrics,json=envoyMetrics,proto3,oneof" json:"envoy_metrics,omitempty"`
	KubeletMetrics *string `protobuf:"bytes,4,opt,name=kubelet_metrics,json=kubeletMetrics,proto3,oneof" json:"kubelet_metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*GetClusterMetricsResponse) Descriptor deprecated 

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

Deprecated: Use GetClusterMetricsResponse.ProtoReflect.Descriptor instead.

func (*GetClusterMetricsResponse) GetCnpgMetrics added in v0.21.21 

func (x *GetClusterMetricsResponse) GetCnpgMetrics() string

func (*GetClusterMetricsResponse) GetEnvoyMetrics added in v0.21.21 

func (x *GetClusterMetricsResponse) GetEnvoyMetrics() string

func (*GetClusterMetricsResponse) GetKubeletMetrics added in v0.21.21 

func (x *GetClusterMetricsResponse) GetKubeletMetrics() string

func (*GetClusterMetricsResponse) GetMetrics deprecated 

func (x *GetClusterMetricsResponse) GetMetrics() string

Deprecated: Marked as deprecated in chalk/manager/v1/status.proto.

func (*GetClusterMetricsResponse) ProtoMessage 

func (*GetClusterMetricsResponse) ProtoMessage()

func (*GetClusterMetricsResponse) ProtoReflect 

func (x *GetClusterMetricsResponse) ProtoReflect() protoreflect.Message

func (*GetClusterMetricsResponse) Reset 

func (x *GetClusterMetricsResponse) Reset()

func (*GetClusterMetricsResponse) String 

func (x *GetClusterMetricsResponse) String() string

type GetKafkaTopicsRequest added in v0.21.15 

type GetKafkaTopicsRequest struct {
	// contains filtered or unexported fields
}

func (*GetKafkaTopicsRequest) Descriptor deprecated added in v0.21.15 

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

Deprecated: Use GetKafkaTopicsRequest.ProtoReflect.Descriptor instead.

func (*GetKafkaTopicsRequest) ProtoMessage added in v0.21.15 

func (*GetKafkaTopicsRequest) ProtoMessage()

func (*GetKafkaTopicsRequest) ProtoReflect added in v0.21.15 

func (x *GetKafkaTopicsRequest) ProtoReflect() protoreflect.Message

func (*GetKafkaTopicsRequest) Reset added in v0.21.15 

func (x *GetKafkaTopicsRequest) Reset()

func (*GetKafkaTopicsRequest) String added in v0.21.15 

func (x *GetKafkaTopicsRequest) String() string

type GetKafkaTopicsResponse added in v0.21.15 

type GetKafkaTopicsResponse struct {
	Topics []*KafkaTopic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*GetKafkaTopicsResponse) Descriptor deprecated added in v0.21.15 

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

Deprecated: Use GetKafkaTopicsResponse.ProtoReflect.Descriptor instead.

func (*GetKafkaTopicsResponse) GetTopics added in v0.21.15 

func (x *GetKafkaTopicsResponse) GetTopics() []*KafkaTopic

func (*GetKafkaTopicsResponse) ProtoMessage added in v0.21.15 

func (*GetKafkaTopicsResponse) ProtoMessage()

func (*GetKafkaTopicsResponse) ProtoReflect added in v0.21.15 

func (x *GetKafkaTopicsResponse) ProtoReflect() protoreflect.Message

func (*GetKafkaTopicsResponse) Reset added in v0.21.15 

func (x *GetKafkaTopicsResponse) Reset()

func (*GetKafkaTopicsResponse) String added in v0.21.15 

func (x *GetKafkaTopicsResponse) String() string

type KafkaTopic added in v0.21.15 

type KafkaTopic struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Partitions  int32  `protobuf:"varint,2,opt,name=partitions,proto3" json:"partitions,omitempty"`
	Replication *int32 `protobuf:"varint,3,opt,name=replication,proto3,oneof" json:"replication,omitempty"`
	RetentionMs int32  `protobuf:"varint,4,opt,name=retention_ms,json=retentionMs,proto3" json:"retention_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*KafkaTopic) Descriptor deprecated added in v0.21.15 

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

Deprecated: Use KafkaTopic.ProtoReflect.Descriptor instead.

func (*KafkaTopic) GetName added in v0.21.15 

func (x *KafkaTopic) GetName() string

func (*KafkaTopic) GetPartitions added in v0.21.15 

func (x *KafkaTopic) GetPartitions() int32

func (*KafkaTopic) GetReplication added in v0.21.15 

func (x *KafkaTopic) GetReplication() int32

func (*KafkaTopic) GetRetentionMs added in v0.21.15 

func (x *KafkaTopic) GetRetentionMs() int32

func (*KafkaTopic) ProtoMessage added in v0.21.15 

func (*KafkaTopic) ProtoMessage()

func (*KafkaTopic) ProtoReflect added in v0.21.15 

func (x *KafkaTopic) ProtoReflect() protoreflect.Message

func (*KafkaTopic) Reset added in v0.21.15 

func (x *KafkaTopic) Reset()

func (*KafkaTopic) String added in v0.21.15 

func (x *KafkaTopic) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.