Documentation ¶
Index ¶
- Variables
- type Config
- type DataSource
- func (*DataSource) Descriptor() ([]byte, []int)deprecated
- func (x *DataSource) GetFile() string
- func (x *DataSource) GetInline() *wrapperspb.BytesValue
- func (x *DataSource) GetInlineString() string
- func (x *DataSource) GetSecret() string
- func (m *DataSource) GetType() isDataSource_Type
- func (*DataSource) ProtoMessage()
- func (x *DataSource) ProtoReflect() protoreflect.Message
- func (x *DataSource) Reset()
- func (x *DataSource) String() string
- type DataSource_File
- type DataSource_Inline
- type DataSource_InlineString
- type DataSource_Secret
- type KDSServiceStats
- func (*KDSServiceStats) Descriptor() ([]byte, []int)deprecated
- func (x *KDSServiceStats) GetResponsesAcknowledged() uint64
- func (x *KDSServiceStats) GetResponsesRejected() uint64
- func (x *KDSServiceStats) GetResponsesSent() uint64
- func (*KDSServiceStats) ProtoMessage()
- func (x *KDSServiceStats) ProtoReflect() protoreflect.Message
- func (x *KDSServiceStats) Reset()
- func (x *KDSServiceStats) String() string
- type KDSSubscription
- func (*KDSSubscription) Descriptor() ([]byte, []int)deprecated
- func (x *KDSSubscription) GetConnectTime() *timestamppb.Timestamp
- func (x *KDSSubscription) GetDisconnectTime() *timestamppb.Timestamp
- func (x *KDSSubscription) GetGlobalInstanceId() string
- func (x *KDSSubscription) GetId() string
- func (x *KDSSubscription) GetStatus() *KDSSubscriptionStatus
- func (x *KDSSubscription) GetVersion() *Version
- func (*KDSSubscription) ProtoMessage()
- func (x *KDSSubscription) ProtoReflect() protoreflect.Message
- func (x *KDSSubscription) Reset()
- func (x *KDSSubscription) String() string
- type KDSSubscriptionStatus
- func (*KDSSubscriptionStatus) Descriptor() ([]byte, []int)deprecated
- func (x *KDSSubscriptionStatus) GetLastUpdateTime() *timestamppb.Timestamp
- func (x *KDSSubscriptionStatus) GetStat() map[string]*KDSServiceStats
- func (x *KDSSubscriptionStatus) GetTotal() *KDSServiceStats
- func (*KDSSubscriptionStatus) ProtoMessage()
- func (x *KDSSubscriptionStatus) ProtoReflect() protoreflect.Message
- func (x *KDSSubscriptionStatus) Reset()
- func (x *KDSSubscriptionStatus) String() string
- type KumaCpVersion
- func (*KumaCpVersion) Descriptor() ([]byte, []int)deprecated
- func (x *KumaCpVersion) GetBuildDate() string
- func (x *KumaCpVersion) GetGitCommit() string
- func (x *KumaCpVersion) GetGitTag() string
- func (x *KumaCpVersion) GetVersion() string
- func (*KumaCpVersion) ProtoMessage()
- func (x *KumaCpVersion) ProtoReflect() protoreflect.Message
- func (x *KumaCpVersion) Reset()
- func (x *KumaCpVersion) String() string
- type Secret
- type Version
- type Zone
- type ZoneInsight
- func (*ZoneInsight) Descriptor() ([]byte, []int)deprecated
- func (m *ZoneInsight) GetLatestSubscription() (*KDSSubscription, *time.Time)
- func (m *ZoneInsight) GetSubscription(id string) (int, *KDSSubscription)
- func (x *ZoneInsight) GetSubscriptions() []*KDSSubscription
- func (m *ZoneInsight) IsOnline() bool
- func (*ZoneInsight) ProtoMessage()
- func (x *ZoneInsight) ProtoReflect() protoreflect.Message
- func (x *ZoneInsight) Reset()
- func (x *ZoneInsight) String() string
- func (m *ZoneInsight) Sum(v func(*KDSSubscription) uint64) uint64
- func (m *ZoneInsight) UpdateSubscription(s *KDSSubscription)
- type ZoneOverview
- func (*ZoneOverview) Descriptor() ([]byte, []int)deprecated
- func (x *ZoneOverview) GetZone() *Zone
- func (x *ZoneOverview) GetZoneInsight() *ZoneInsight
- func (*ZoneOverview) ProtoMessage()
- func (x *ZoneOverview) ProtoReflect() protoreflect.Message
- func (x *ZoneOverview) Reset()
- func (x *ZoneOverview) String() string
Constants ¶
This section is empty.
Variables ¶
var File_system_v1alpha1_config_proto protoreflect.FileDescriptor
var File_system_v1alpha1_datasource_proto protoreflect.FileDescriptor
var File_system_v1alpha1_secret_proto protoreflect.FileDescriptor
var File_system_v1alpha1_zone_insight_proto protoreflect.FileDescriptor
var File_system_v1alpha1_zone_overview_proto protoreflect.FileDescriptor
var File_system_v1alpha1_zone_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { // configuration that is stored (ex. in JSON) Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
Config is a entity that represents dynamic configuration that is stored in underlying storage. For now it's used only for internal mechanisms.
func (*Config) Descriptor
deprecated
func (*Config) ProtoMessage ¶
func (*Config) ProtoMessage()
func (*Config) ProtoReflect ¶
func (x *Config) ProtoReflect() protoreflect.Message
type DataSource ¶
type DataSource struct { // Types that are assignable to Type: // *DataSource_Secret // *DataSource_File // *DataSource_Inline // *DataSource_InlineString Type isDataSource_Type `protobuf_oneof:"type"` // contains filtered or unexported fields }
DataSource defines the source of bytes to use.
func (*DataSource) Descriptor
deprecated
func (*DataSource) Descriptor() ([]byte, []int)
Deprecated: Use DataSource.ProtoReflect.Descriptor instead.
func (*DataSource) GetFile ¶
func (x *DataSource) GetFile() string
func (*DataSource) GetInline ¶
func (x *DataSource) GetInline() *wrapperspb.BytesValue
func (*DataSource) GetInlineString ¶
func (x *DataSource) GetInlineString() string
func (*DataSource) GetSecret ¶
func (x *DataSource) GetSecret() string
func (*DataSource) GetType ¶
func (m *DataSource) GetType() isDataSource_Type
func (*DataSource) ProtoMessage ¶
func (*DataSource) ProtoMessage()
func (*DataSource) ProtoReflect ¶
func (x *DataSource) ProtoReflect() protoreflect.Message
func (*DataSource) Reset ¶
func (x *DataSource) Reset()
func (*DataSource) String ¶
func (x *DataSource) String() string
type DataSource_File ¶
type DataSource_File struct { // Data source is a path to a file. File string `protobuf:"bytes,2,opt,name=file,proto3,oneof"` }
type DataSource_Inline ¶
type DataSource_Inline struct { // Data source is inline bytes. Inline *wrapperspb.BytesValue `protobuf:"bytes,3,opt,name=inline,proto3,oneof"` }
type DataSource_InlineString ¶
type DataSource_InlineString struct { // Data source is inline string InlineString string `protobuf:"bytes,4,opt,name=inlineString,proto3,oneof"` }
type DataSource_Secret ¶
type DataSource_Secret struct { // Data source is a secret with given Secret key. Secret string `protobuf:"bytes,1,opt,name=secret,proto3,oneof"` }
type KDSServiceStats ¶
type KDSServiceStats struct { // Number of xDS responses sent to the Dataplane. ResponsesSent uint64 `protobuf:"varint,1,opt,name=responses_sent,json=responsesSent,proto3" json:"responses_sent,omitempty"` // Number of xDS responses ACKed by the Dataplane. ResponsesAcknowledged uint64 `protobuf:"varint,2,opt,name=responses_acknowledged,json=responsesAcknowledged,proto3" json:"responses_acknowledged,omitempty"` // Number of xDS responses NACKed by the Dataplane. ResponsesRejected uint64 `protobuf:"varint,3,opt,name=responses_rejected,json=responsesRejected,proto3" json:"responses_rejected,omitempty"` // contains filtered or unexported fields }
DiscoveryServiceStats defines all stats over a single xDS service.
func (*KDSServiceStats) Descriptor
deprecated
func (*KDSServiceStats) Descriptor() ([]byte, []int)
Deprecated: Use KDSServiceStats.ProtoReflect.Descriptor instead.
func (*KDSServiceStats) GetResponsesAcknowledged ¶
func (x *KDSServiceStats) GetResponsesAcknowledged() uint64
func (*KDSServiceStats) GetResponsesRejected ¶
func (x *KDSServiceStats) GetResponsesRejected() uint64
func (*KDSServiceStats) GetResponsesSent ¶
func (x *KDSServiceStats) GetResponsesSent() uint64
func (*KDSServiceStats) ProtoMessage ¶
func (*KDSServiceStats) ProtoMessage()
func (*KDSServiceStats) ProtoReflect ¶
func (x *KDSServiceStats) ProtoReflect() protoreflect.Message
func (*KDSServiceStats) Reset ¶
func (x *KDSServiceStats) Reset()
func (*KDSServiceStats) String ¶
func (x *KDSServiceStats) String() string
type KDSSubscription ¶
type KDSSubscription struct { // Unique id per KDS subscription. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Global CP instance that handled given subscription. GlobalInstanceId string `protobuf:"bytes,2,opt,name=global_instance_id,json=globalInstanceId,proto3" json:"global_instance_id,omitempty"` // Time when a given Zone connected to the Global. ConnectTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=connect_time,json=connectTime,proto3" json:"connect_time,omitempty"` // Time when a given Zone disconnected from the Global. DisconnectTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=disconnect_time,json=disconnectTime,proto3" json:"disconnect_time,omitempty"` // Status of the KDS subscription. Status *KDSSubscriptionStatus `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"` // Version of Zone Kuma CP. Version *Version `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
KDSSubscription describes a single KDS subscription created by a Zone to the Global. Ideally, there should be only one such subscription per Zone lifecycle. Presence of multiple subscriptions might indicate one of the following events: - transient loss of network connection between Zone and Global Control Planes - Zone Kuma CP restarts (i.e. hot restart or crash) - Global Kuma CP restarts (i.e. rolling update or crash) - etc
func (*KDSSubscription) Descriptor
deprecated
func (*KDSSubscription) Descriptor() ([]byte, []int)
Deprecated: Use KDSSubscription.ProtoReflect.Descriptor instead.
func (*KDSSubscription) GetConnectTime ¶
func (x *KDSSubscription) GetConnectTime() *timestamppb.Timestamp
func (*KDSSubscription) GetDisconnectTime ¶
func (x *KDSSubscription) GetDisconnectTime() *timestamppb.Timestamp
func (*KDSSubscription) GetGlobalInstanceId ¶
func (x *KDSSubscription) GetGlobalInstanceId() string
func (*KDSSubscription) GetId ¶
func (x *KDSSubscription) GetId() string
func (*KDSSubscription) GetStatus ¶
func (x *KDSSubscription) GetStatus() *KDSSubscriptionStatus
func (*KDSSubscription) GetVersion ¶
func (x *KDSSubscription) GetVersion() *Version
func (*KDSSubscription) ProtoMessage ¶
func (*KDSSubscription) ProtoMessage()
func (*KDSSubscription) ProtoReflect ¶
func (x *KDSSubscription) ProtoReflect() protoreflect.Message
func (*KDSSubscription) Reset ¶
func (x *KDSSubscription) Reset()
func (*KDSSubscription) String ¶
func (x *KDSSubscription) String() string
type KDSSubscriptionStatus ¶
type KDSSubscriptionStatus struct { // Time when status of a given KDS subscription was most recently updated. LastUpdateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=last_update_time,json=lastUpdateTime,proto3" json:"last_update_time,omitempty"` // Total defines an aggregate over individual KDS stats. Total *KDSServiceStats `protobuf:"bytes,2,opt,name=total,proto3" json:"total,omitempty"` Stat map[string]*KDSServiceStats `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
KDSSubscriptionStatus defines status of an KDS subscription.
func NewSubscriptionStatus ¶
func NewSubscriptionStatus() *KDSSubscriptionStatus
func (*KDSSubscriptionStatus) Descriptor
deprecated
func (*KDSSubscriptionStatus) Descriptor() ([]byte, []int)
Deprecated: Use KDSSubscriptionStatus.ProtoReflect.Descriptor instead.
func (*KDSSubscriptionStatus) GetLastUpdateTime ¶
func (x *KDSSubscriptionStatus) GetLastUpdateTime() *timestamppb.Timestamp
func (*KDSSubscriptionStatus) GetStat ¶
func (x *KDSSubscriptionStatus) GetStat() map[string]*KDSServiceStats
func (*KDSSubscriptionStatus) GetTotal ¶
func (x *KDSSubscriptionStatus) GetTotal() *KDSServiceStats
func (*KDSSubscriptionStatus) ProtoMessage ¶
func (*KDSSubscriptionStatus) ProtoMessage()
func (*KDSSubscriptionStatus) ProtoReflect ¶
func (x *KDSSubscriptionStatus) ProtoReflect() protoreflect.Message
func (*KDSSubscriptionStatus) Reset ¶
func (x *KDSSubscriptionStatus) Reset()
func (*KDSSubscriptionStatus) String ¶
func (x *KDSSubscriptionStatus) String() string
type KumaCpVersion ¶
type KumaCpVersion struct { // Version number of Kuma ControlPlane Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // Git tag of Kuma ControlPlane version GitTag string `protobuf:"bytes,2,opt,name=gitTag,proto3" json:"gitTag,omitempty"` // Git commit of Kuma ControlPlane version GitCommit string `protobuf:"bytes,3,opt,name=gitCommit,proto3" json:"gitCommit,omitempty"` // Build date of Kuma ControlPlane version BuildDate string `protobuf:"bytes,4,opt,name=buildDate,proto3" json:"buildDate,omitempty"` // contains filtered or unexported fields }
KumaCpVersion describes details of Kuma ControlPlane version
func (*KumaCpVersion) Descriptor
deprecated
func (*KumaCpVersion) Descriptor() ([]byte, []int)
Deprecated: Use KumaCpVersion.ProtoReflect.Descriptor instead.
func (*KumaCpVersion) GetBuildDate ¶
func (x *KumaCpVersion) GetBuildDate() string
func (*KumaCpVersion) GetGitCommit ¶
func (x *KumaCpVersion) GetGitCommit() string
func (*KumaCpVersion) GetGitTag ¶
func (x *KumaCpVersion) GetGitTag() string
func (*KumaCpVersion) GetVersion ¶
func (x *KumaCpVersion) GetVersion() string
func (*KumaCpVersion) ProtoMessage ¶
func (*KumaCpVersion) ProtoMessage()
func (*KumaCpVersion) ProtoReflect ¶
func (x *KumaCpVersion) ProtoReflect() protoreflect.Message
func (*KumaCpVersion) Reset ¶
func (x *KumaCpVersion) Reset()
func (*KumaCpVersion) String ¶
func (x *KumaCpVersion) String() string
type Secret ¶
type Secret struct { // Value of the secret Data *wrapperspb.BytesValue `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
Secret defines an encrypted value in Kuma.
func (*Secret) Descriptor
deprecated
func (*Secret) GetData ¶
func (x *Secret) GetData() *wrapperspb.BytesValue
func (*Secret) ProtoMessage ¶
func (*Secret) ProtoMessage()
func (*Secret) ProtoReflect ¶
func (x *Secret) ProtoReflect() protoreflect.Message
type Version ¶
type Version struct { // Version of Zone Kuma CP KumaCp *KumaCpVersion `protobuf:"bytes,1,opt,name=kumaCp,proto3" json:"kumaCp,omitempty"` // contains filtered or unexported fields }
Version defines version of Kuma ControlPlane
func NewVersion ¶
func NewVersion() *Version
func (*Version) Descriptor
deprecated
func (*Version) GetKumaCp ¶
func (x *Version) GetKumaCp() *KumaCpVersion
func (*Version) ProtoMessage ¶
func (*Version) ProtoMessage()
func (*Version) ProtoReflect ¶
func (x *Version) ProtoReflect() protoreflect.Message
type Zone ¶
type Zone struct { // enable allows to turn the zone on/off and exclude the whole zone from // balancing traffic on it Enabled *wrapperspb.BoolValue `protobuf:"bytes,1,opt,name=enabled,proto3" json:"enabled,omitempty"` // contains filtered or unexported fields }
Zone defines the Zone configuration used at the Global Control Plane within a distributed deployment
func (*Zone) Descriptor
deprecated
func (*Zone) GetEnabled ¶
func (x *Zone) GetEnabled() *wrapperspb.BoolValue
func (*Zone) ProtoMessage ¶
func (*Zone) ProtoMessage()
func (*Zone) ProtoReflect ¶
func (x *Zone) ProtoReflect() protoreflect.Message
type ZoneInsight ¶
type ZoneInsight struct { // List of KDS subscriptions created by a given Zone Kuma CP. Subscriptions []*KDSSubscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"` // contains filtered or unexported fields }
ZoneInsight defines the observed state of a Zone Kuma CP.
func (*ZoneInsight) Descriptor
deprecated
func (*ZoneInsight) Descriptor() ([]byte, []int)
Deprecated: Use ZoneInsight.ProtoReflect.Descriptor instead.
func (*ZoneInsight) GetLatestSubscription ¶
func (m *ZoneInsight) GetLatestSubscription() (*KDSSubscription, *time.Time)
func (*ZoneInsight) GetSubscription ¶
func (m *ZoneInsight) GetSubscription(id string) (int, *KDSSubscription)
func (*ZoneInsight) GetSubscriptions ¶
func (x *ZoneInsight) GetSubscriptions() []*KDSSubscription
func (*ZoneInsight) IsOnline ¶
func (m *ZoneInsight) IsOnline() bool
func (*ZoneInsight) ProtoMessage ¶
func (*ZoneInsight) ProtoMessage()
func (*ZoneInsight) ProtoReflect ¶
func (x *ZoneInsight) ProtoReflect() protoreflect.Message
func (*ZoneInsight) Reset ¶
func (x *ZoneInsight) Reset()
func (*ZoneInsight) String ¶
func (x *ZoneInsight) String() string
func (*ZoneInsight) Sum ¶
func (m *ZoneInsight) Sum(v func(*KDSSubscription) uint64) uint64
func (*ZoneInsight) UpdateSubscription ¶
func (m *ZoneInsight) UpdateSubscription(s *KDSSubscription)
type ZoneOverview ¶
type ZoneOverview struct { Zone *Zone `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"` ZoneInsight *ZoneInsight `protobuf:"bytes,2,opt,name=zone_insight,json=zoneInsight,proto3" json:"zone_insight,omitempty"` // contains filtered or unexported fields }
ZoneOverview defines the projected state of a Zone.
func (*ZoneOverview) Descriptor
deprecated
func (*ZoneOverview) Descriptor() ([]byte, []int)
Deprecated: Use ZoneOverview.ProtoReflect.Descriptor instead.
func (*ZoneOverview) GetZone ¶
func (x *ZoneOverview) GetZone() *Zone
func (*ZoneOverview) GetZoneInsight ¶
func (x *ZoneOverview) GetZoneInsight() *ZoneInsight
func (*ZoneOverview) ProtoMessage ¶
func (*ZoneOverview) ProtoMessage()
func (*ZoneOverview) ProtoReflect ¶
func (x *ZoneOverview) ProtoReflect() protoreflect.Message
func (*ZoneOverview) Reset ¶
func (x *ZoneOverview) Reset()
func (*ZoneOverview) String ¶
func (x *ZoneOverview) String() string