cluster

package
v1.6.8 Latest Latest
Warning

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

 Go to latest Published: Jul 24, 2024 License: MPL-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_resource_definitions_cluster_cluster_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AffiliateSpec 

type AffiliateSpec struct {
	NodeId          string                 `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Addresses       []*common.NetIP        `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"`
	Hostname        string                 `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Nodename        string                 `protobuf:"bytes,4,opt,name=nodename,proto3" json:"nodename,omitempty"`
	OperatingSystem string                 `protobuf:"bytes,5,opt,name=operating_system,json=operatingSystem,proto3" json:"operating_system,omitempty"`
	MachineType     enums.MachineType      `` /* 145-byte string literal not displayed */
	KubeSpan        *KubeSpanAffiliateSpec `protobuf:"bytes,7,opt,name=kube_span,json=kubeSpan,proto3" json:"kube_span,omitempty"`
	ControlPlane    *ControlPlane          `protobuf:"bytes,8,opt,name=control_plane,json=controlPlane,proto3" json:"control_plane,omitempty"`
	// contains filtered or unexported fields
}

AffiliateSpec describes Affiliate state.

func (*AffiliateSpec) Descriptor deprecated 

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

Deprecated: Use AffiliateSpec.ProtoReflect.Descriptor instead.

func (*AffiliateSpec) GetAddresses 

func (x *AffiliateSpec) GetAddresses() []*common.NetIP

func (*AffiliateSpec) GetControlPlane added in v1.5.0 

func (x *AffiliateSpec) GetControlPlane() *ControlPlane

func (*AffiliateSpec) GetHostname 

func (x *AffiliateSpec) GetHostname() string

func (*AffiliateSpec) GetKubeSpan 

func (x *AffiliateSpec) GetKubeSpan() *KubeSpanAffiliateSpec

func (*AffiliateSpec) GetMachineType 

func (x *AffiliateSpec) GetMachineType() enums.MachineType

func (*AffiliateSpec) GetNodeId 

func (x *AffiliateSpec) GetNodeId() string

func (*AffiliateSpec) GetNodename 

func (x *AffiliateSpec) GetNodename() string

func (*AffiliateSpec) GetOperatingSystem 

func (x *AffiliateSpec) GetOperatingSystem() string

func (*AffiliateSpec) MarshalToSizedBufferVT 

func (m *AffiliateSpec) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*AffiliateSpec) MarshalToVT 

func (m *AffiliateSpec) MarshalToVT(dAtA []byte) (int, error)

func (*AffiliateSpec) MarshalVT 

func (m *AffiliateSpec) MarshalVT() (dAtA []byte, err error)

func (*AffiliateSpec) ProtoMessage 

func (*AffiliateSpec) ProtoMessage()

func (*AffiliateSpec) ProtoReflect 

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

func (*AffiliateSpec) Reset 

func (x *AffiliateSpec) Reset()

func (*AffiliateSpec) SizeVT 

func (m *AffiliateSpec) SizeVT() (n int)

func (*AffiliateSpec) String 

func (x *AffiliateSpec) String() string

func (*AffiliateSpec) UnmarshalVT 

func (m *AffiliateSpec) UnmarshalVT(dAtA []byte) error

type ConfigSpec 

type ConfigSpec struct {
	DiscoveryEnabled          bool   `protobuf:"varint,1,opt,name=discovery_enabled,json=discoveryEnabled,proto3" json:"discovery_enabled,omitempty"`
	RegistryKubernetesEnabled bool   `` /* 139-byte string literal not displayed */
	RegistryServiceEnabled    bool   `` /* 130-byte string literal not displayed */
	ServiceEndpoint           string `protobuf:"bytes,4,opt,name=service_endpoint,json=serviceEndpoint,proto3" json:"service_endpoint,omitempty"`
	ServiceEndpointInsecure   bool   `` /* 133-byte string literal not displayed */
	ServiceEncryptionKey      []byte `protobuf:"bytes,6,opt,name=service_encryption_key,json=serviceEncryptionKey,proto3" json:"service_encryption_key,omitempty"`
	ServiceClusterId          string `protobuf:"bytes,7,opt,name=service_cluster_id,json=serviceClusterId,proto3" json:"service_cluster_id,omitempty"`
	// contains filtered or unexported fields
}

ConfigSpec describes KubeSpan configuration.

func (*ConfigSpec) Descriptor deprecated 

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

Deprecated: Use ConfigSpec.ProtoReflect.Descriptor instead.

func (*ConfigSpec) GetDiscoveryEnabled 

func (x *ConfigSpec) GetDiscoveryEnabled() bool

func (*ConfigSpec) GetRegistryKubernetesEnabled 

func (x *ConfigSpec) GetRegistryKubernetesEnabled() bool

func (*ConfigSpec) GetRegistryServiceEnabled 

func (x *ConfigSpec) GetRegistryServiceEnabled() bool

func (*ConfigSpec) GetServiceClusterId 

func (x *ConfigSpec) GetServiceClusterId() string

func (*ConfigSpec) GetServiceEncryptionKey 

func (x *ConfigSpec) GetServiceEncryptionKey() []byte

func (*ConfigSpec) GetServiceEndpoint 

func (x *ConfigSpec) GetServiceEndpoint() string

func (*ConfigSpec) GetServiceEndpointInsecure 

func (x *ConfigSpec) GetServiceEndpointInsecure() bool

func (*ConfigSpec) MarshalToSizedBufferVT 

func (m *ConfigSpec) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ConfigSpec) MarshalToVT 

func (m *ConfigSpec) MarshalToVT(dAtA []byte) (int, error)

func (*ConfigSpec) MarshalVT 

func (m *ConfigSpec) MarshalVT() (dAtA []byte, err error)

func (*ConfigSpec) ProtoMessage 

func (*ConfigSpec) ProtoMessage()

func (*ConfigSpec) ProtoReflect 

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

func (*ConfigSpec) Reset 

func (x *ConfigSpec) Reset()

func (*ConfigSpec) SizeVT 

func (m *ConfigSpec) SizeVT() (n int)

func (*ConfigSpec) String 

func (x *ConfigSpec) String() string

func (*ConfigSpec) UnmarshalVT 

func (m *ConfigSpec) UnmarshalVT(dAtA []byte) error

type ControlPlane added in v1.5.0 

type ControlPlane struct {
	ApiServerPort int64 `protobuf:"varint,1,opt,name=api_server_port,json=apiServerPort,proto3" json:"api_server_port,omitempty"`
	// contains filtered or unexported fields
}

ControlPlane describes ControlPlane data if any.

func (*ControlPlane) Descriptor deprecated added in v1.5.0 

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

Deprecated: Use ControlPlane.ProtoReflect.Descriptor instead.

func (*ControlPlane) GetApiServerPort added in v1.5.0 

func (x *ControlPlane) GetApiServerPort() int64

func (*ControlPlane) MarshalToSizedBufferVT added in v1.5.0 

func (m *ControlPlane) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ControlPlane) MarshalToVT added in v1.5.0 

func (m *ControlPlane) MarshalToVT(dAtA []byte) (int, error)

func (*ControlPlane) MarshalVT added in v1.5.0 

func (m *ControlPlane) MarshalVT() (dAtA []byte, err error)

func (*ControlPlane) ProtoMessage added in v1.5.0 

func (*ControlPlane) ProtoMessage()

func (*ControlPlane) ProtoReflect added in v1.5.0 

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

func (*ControlPlane) Reset added in v1.5.0 

func (x *ControlPlane) Reset()

func (*ControlPlane) SizeVT added in v1.5.0 

func (m *ControlPlane) SizeVT() (n int)

func (*ControlPlane) String added in v1.5.0 

func (x *ControlPlane) String() string

func (*ControlPlane) UnmarshalVT added in v1.5.0 

func (m *ControlPlane) UnmarshalVT(dAtA []byte) error

type IdentitySpec 

type IdentitySpec struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

IdentitySpec describes status of rendered secrets.

Note: IdentitySpec is persisted on disk in the STATE partition, so YAML serialization should be kept backwards compatible.

func (*IdentitySpec) Descriptor deprecated 

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

Deprecated: Use IdentitySpec.ProtoReflect.Descriptor instead.

func (*IdentitySpec) GetNodeId 

func (x *IdentitySpec) GetNodeId() string

func (*IdentitySpec) MarshalToSizedBufferVT 

func (m *IdentitySpec) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*IdentitySpec) MarshalToVT 

func (m *IdentitySpec) MarshalToVT(dAtA []byte) (int, error)

func (*IdentitySpec) MarshalVT 

func (m *IdentitySpec) MarshalVT() (dAtA []byte, err error)

func (*IdentitySpec) ProtoMessage 

func (*IdentitySpec) ProtoMessage()

func (*IdentitySpec) ProtoReflect 

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

func (*IdentitySpec) Reset 

func (x *IdentitySpec) Reset()

func (*IdentitySpec) SizeVT 

func (m *IdentitySpec) SizeVT() (n int)

func (*IdentitySpec) String 

func (x *IdentitySpec) String() string

func (*IdentitySpec) UnmarshalVT 

func (m *IdentitySpec) UnmarshalVT(dAtA []byte) error

type InfoSpec added in v1.4.0 

type InfoSpec struct {
	ClusterId   string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	ClusterName string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	// contains filtered or unexported fields
}

InfoSpec describes cluster information.

func (*InfoSpec) Descriptor deprecated added in v1.4.0 

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

Deprecated: Use InfoSpec.ProtoReflect.Descriptor instead.

func (*InfoSpec) GetClusterId added in v1.4.0 

func (x *InfoSpec) GetClusterId() string

func (*InfoSpec) GetClusterName added in v1.4.0 

func (x *InfoSpec) GetClusterName() string

func (*InfoSpec) MarshalToSizedBufferVT added in v1.4.0 

func (m *InfoSpec) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*InfoSpec) MarshalToVT added in v1.4.0 

func (m *InfoSpec) MarshalToVT(dAtA []byte) (int, error)

func (*InfoSpec) MarshalVT added in v1.4.0 

func (m *InfoSpec) MarshalVT() (dAtA []byte, err error)

func (*InfoSpec) ProtoMessage added in v1.4.0 

func (*InfoSpec) ProtoMessage()

func (*InfoSpec) ProtoReflect added in v1.4.0 

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

func (*InfoSpec) Reset added in v1.4.0 

func (x *InfoSpec) Reset()

func (*InfoSpec) SizeVT added in v1.4.0 

func (m *InfoSpec) SizeVT() (n int)

func (*InfoSpec) String added in v1.4.0 

func (x *InfoSpec) String() string

func (*InfoSpec) UnmarshalVT added in v1.4.0 

func (m *InfoSpec) UnmarshalVT(dAtA []byte) error

type KubeSpanAffiliateSpec 

type KubeSpanAffiliateSpec struct {
	PublicKey           string                `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	Address             *common.NetIP         `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	AdditionalAddresses []*common.NetIPPrefix `protobuf:"bytes,3,rep,name=additional_addresses,json=additionalAddresses,proto3" json:"additional_addresses,omitempty"`
	Endpoints           []*common.NetIPPort   `protobuf:"bytes,4,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	// contains filtered or unexported fields
}

KubeSpanAffiliateSpec describes additional information specific for the KubeSpan.

func (*KubeSpanAffiliateSpec) Descriptor deprecated 

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

Deprecated: Use KubeSpanAffiliateSpec.ProtoReflect.Descriptor instead.

func (*KubeSpanAffiliateSpec) GetAdditionalAddresses 

func (x *KubeSpanAffiliateSpec) GetAdditionalAddresses() []*common.NetIPPrefix

func (*KubeSpanAffiliateSpec) GetAddress 

func (x *KubeSpanAffiliateSpec) GetAddress() *common.NetIP

func (*KubeSpanAffiliateSpec) GetEndpoints 

func (x *KubeSpanAffiliateSpec) GetEndpoints() []*common.NetIPPort

func (*KubeSpanAffiliateSpec) GetPublicKey 

func (x *KubeSpanAffiliateSpec) GetPublicKey() string

func (*KubeSpanAffiliateSpec) MarshalToSizedBufferVT 

func (m *KubeSpanAffiliateSpec) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*KubeSpanAffiliateSpec) MarshalToVT 

func (m *KubeSpanAffiliateSpec) MarshalToVT(dAtA []byte) (int, error)

func (*KubeSpanAffiliateSpec) MarshalVT 

func (m *KubeSpanAffiliateSpec) MarshalVT() (dAtA []byte, err error)

func (*KubeSpanAffiliateSpec) ProtoMessage 

func (*KubeSpanAffiliateSpec) ProtoMessage()

func (*KubeSpanAffiliateSpec) ProtoReflect 

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

func (*KubeSpanAffiliateSpec) Reset 

func (x *KubeSpanAffiliateSpec) Reset()

func (*KubeSpanAffiliateSpec) SizeVT 

func (m *KubeSpanAffiliateSpec) SizeVT() (n int)

func (*KubeSpanAffiliateSpec) String 

func (x *KubeSpanAffiliateSpec) String() string

func (*KubeSpanAffiliateSpec) UnmarshalVT 

func (m *KubeSpanAffiliateSpec) UnmarshalVT(dAtA []byte) error

type MemberSpec 

type MemberSpec struct {
	NodeId          string            `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Addresses       []*common.NetIP   `protobuf:"bytes,2,rep,name=addresses,proto3" json:"addresses,omitempty"`
	Hostname        string            `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	MachineType     enums.MachineType `` /* 145-byte string literal not displayed */
	OperatingSystem string            `protobuf:"bytes,5,opt,name=operating_system,json=operatingSystem,proto3" json:"operating_system,omitempty"`
	ControlPlane    *ControlPlane     `protobuf:"bytes,6,opt,name=control_plane,json=controlPlane,proto3" json:"control_plane,omitempty"`
	// contains filtered or unexported fields
}

MemberSpec describes Member state.

func (*MemberSpec) Descriptor deprecated 

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

Deprecated: Use MemberSpec.ProtoReflect.Descriptor instead.

func (*MemberSpec) GetAddresses 

func (x *MemberSpec) GetAddresses() []*common.NetIP

func (*MemberSpec) GetControlPlane added in v1.5.0 

func (x *MemberSpec) GetControlPlane() *ControlPlane

func (*MemberSpec) GetHostname 

func (x *MemberSpec) GetHostname() string

func (*MemberSpec) GetMachineType 

func (x *MemberSpec) GetMachineType() enums.MachineType

func (*MemberSpec) GetNodeId 

func (x *MemberSpec) GetNodeId() string

func (*MemberSpec) GetOperatingSystem 

func (x *MemberSpec) GetOperatingSystem() string

func (*MemberSpec) MarshalToSizedBufferVT 

func (m *MemberSpec) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*MemberSpec) MarshalToVT 

func (m *MemberSpec) MarshalToVT(dAtA []byte) (int, error)

func (*MemberSpec) MarshalVT 

func (m *MemberSpec) MarshalVT() (dAtA []byte, err error)

func (*MemberSpec) ProtoMessage 

func (*MemberSpec) ProtoMessage()

func (*MemberSpec) ProtoReflect 

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

func (*MemberSpec) Reset 

func (x *MemberSpec) Reset()

func (*MemberSpec) SizeVT 

func (m *MemberSpec) SizeVT() (n int)

func (*MemberSpec) String 

func (x *MemberSpec) String() string

func (*MemberSpec) UnmarshalVT 

func (m *MemberSpec) UnmarshalVT(dAtA []byte) error

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.