kubespan

package
v1.7.1 Latest Latest
Warning

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

Go to latest
Published: May 1, 2024 License: MPL-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_resource_definitions_kubespan_kubespan_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ConfigSpec

type ConfigSpec struct {
	Enabled                     bool     `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	ClusterId                   string   `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	SharedSecret                string   `protobuf:"bytes,3,opt,name=shared_secret,json=sharedSecret,proto3" json:"shared_secret,omitempty"`
	ForceRouting                bool     `protobuf:"varint,4,opt,name=force_routing,json=forceRouting,proto3" json:"force_routing,omitempty"`
	AdvertiseKubernetesNetworks bool     `` /* 145-byte string literal not displayed */
	Mtu                         uint32   `protobuf:"varint,6,opt,name=mtu,proto3" json:"mtu,omitempty"`
	EndpointFilters             []string `protobuf:"bytes,7,rep,name=endpoint_filters,json=endpointFilters,proto3" json:"endpoint_filters,omitempty"`
	HarvestExtraEndpoints       bool     `` /* 127-byte string literal not displayed */
	// 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) GetAdvertiseKubernetesNetworks

func (x *ConfigSpec) GetAdvertiseKubernetesNetworks() bool

func (*ConfigSpec) GetClusterId

func (x *ConfigSpec) GetClusterId() string

func (*ConfigSpec) GetEnabled

func (x *ConfigSpec) GetEnabled() bool

func (*ConfigSpec) GetEndpointFilters

func (x *ConfigSpec) GetEndpointFilters() []string

func (*ConfigSpec) GetForceRouting

func (x *ConfigSpec) GetForceRouting() bool

func (*ConfigSpec) GetHarvestExtraEndpoints added in v1.6.0

func (x *ConfigSpec) GetHarvestExtraEndpoints() bool

func (*ConfigSpec) GetMtu

func (x *ConfigSpec) GetMtu() uint32

func (*ConfigSpec) GetSharedSecret

func (x *ConfigSpec) GetSharedSecret() string

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 EndpointSpec

type EndpointSpec struct {
	AffiliateId string            `protobuf:"bytes,1,opt,name=affiliate_id,json=affiliateId,proto3" json:"affiliate_id,omitempty"`
	Endpoint    *common.NetIPPort `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

EndpointSpec describes Endpoint state.

func (*EndpointSpec) Descriptor deprecated

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

Deprecated: Use EndpointSpec.ProtoReflect.Descriptor instead.

func (*EndpointSpec) GetAffiliateId

func (x *EndpointSpec) GetAffiliateId() string

func (*EndpointSpec) GetEndpoint

func (x *EndpointSpec) GetEndpoint() *common.NetIPPort

func (*EndpointSpec) MarshalToSizedBufferVT

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

func (*EndpointSpec) MarshalToVT

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

func (*EndpointSpec) MarshalVT

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

func (*EndpointSpec) ProtoMessage

func (*EndpointSpec) ProtoMessage()

func (*EndpointSpec) ProtoReflect

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

func (*EndpointSpec) Reset

func (x *EndpointSpec) Reset()

func (*EndpointSpec) SizeVT

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

func (*EndpointSpec) String

func (x *EndpointSpec) String() string

func (*EndpointSpec) UnmarshalVT

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

type IdentitySpec

type IdentitySpec struct {
	Address    *common.NetIPPrefix `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Subnet     *common.NetIPPrefix `protobuf:"bytes,2,opt,name=subnet,proto3" json:"subnet,omitempty"`
	PrivateKey string              `protobuf:"bytes,3,opt,name=private_key,json=privateKey,proto3" json:"private_key,omitempty"`
	PublicKey  string              `protobuf:"bytes,4,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// contains filtered or unexported fields
}

IdentitySpec describes KubeSpan keys and address.

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) GetAddress

func (x *IdentitySpec) GetAddress() *common.NetIPPrefix

func (*IdentitySpec) GetPrivateKey

func (x *IdentitySpec) GetPrivateKey() string

func (*IdentitySpec) GetPublicKey

func (x *IdentitySpec) GetPublicKey() string

func (*IdentitySpec) GetSubnet

func (x *IdentitySpec) GetSubnet() *common.NetIPPrefix

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 PeerSpecSpec

type PeerSpecSpec struct {
	Address    *common.NetIP         `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	AllowedIps []*common.NetIPPrefix `protobuf:"bytes,2,rep,name=allowed_ips,json=allowedIps,proto3" json:"allowed_ips,omitempty"`
	Endpoints  []*common.NetIPPort   `protobuf:"bytes,3,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	Label      string                `protobuf:"bytes,4,opt,name=label,proto3" json:"label,omitempty"`
	// contains filtered or unexported fields
}

PeerSpecSpec describes PeerSpec state.

func (*PeerSpecSpec) Descriptor deprecated

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

Deprecated: Use PeerSpecSpec.ProtoReflect.Descriptor instead.

func (*PeerSpecSpec) GetAddress

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

func (*PeerSpecSpec) GetAllowedIps

func (x *PeerSpecSpec) GetAllowedIps() []*common.NetIPPrefix

func (*PeerSpecSpec) GetEndpoints

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

func (*PeerSpecSpec) GetLabel

func (x *PeerSpecSpec) GetLabel() string

func (*PeerSpecSpec) MarshalToSizedBufferVT

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

func (*PeerSpecSpec) MarshalToVT

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

func (*PeerSpecSpec) MarshalVT

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

func (*PeerSpecSpec) ProtoMessage

func (*PeerSpecSpec) ProtoMessage()

func (*PeerSpecSpec) ProtoReflect

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

func (*PeerSpecSpec) Reset

func (x *PeerSpecSpec) Reset()

func (*PeerSpecSpec) SizeVT

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

func (*PeerSpecSpec) String

func (x *PeerSpecSpec) String() string

func (*PeerSpecSpec) UnmarshalVT

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

type PeerStatusSpec

type PeerStatusSpec struct {
	Endpoint           *common.NetIPPort       `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Label              string                  `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	State              enums.KubespanPeerState `protobuf:"varint,3,opt,name=state,proto3,enum=talos.resource.definitions.enums.KubespanPeerState" json:"state,omitempty"`
	ReceiveBytes       int64                   `protobuf:"varint,4,opt,name=receive_bytes,json=receiveBytes,proto3" json:"receive_bytes,omitempty"`
	TransmitBytes      int64                   `protobuf:"varint,5,opt,name=transmit_bytes,json=transmitBytes,proto3" json:"transmit_bytes,omitempty"`
	LastHandshakeTime  *timestamppb.Timestamp  `protobuf:"bytes,6,opt,name=last_handshake_time,json=lastHandshakeTime,proto3" json:"last_handshake_time,omitempty"`
	LastUsedEndpoint   *common.NetIPPort       `protobuf:"bytes,7,opt,name=last_used_endpoint,json=lastUsedEndpoint,proto3" json:"last_used_endpoint,omitempty"`
	LastEndpointChange *timestamppb.Timestamp  `protobuf:"bytes,8,opt,name=last_endpoint_change,json=lastEndpointChange,proto3" json:"last_endpoint_change,omitempty"`
	// contains filtered or unexported fields
}

PeerStatusSpec describes PeerStatus state.

func (*PeerStatusSpec) Descriptor deprecated

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

Deprecated: Use PeerStatusSpec.ProtoReflect.Descriptor instead.

func (*PeerStatusSpec) GetEndpoint

func (x *PeerStatusSpec) GetEndpoint() *common.NetIPPort

func (*PeerStatusSpec) GetLabel

func (x *PeerStatusSpec) GetLabel() string

func (*PeerStatusSpec) GetLastEndpointChange

func (x *PeerStatusSpec) GetLastEndpointChange() *timestamppb.Timestamp

func (*PeerStatusSpec) GetLastHandshakeTime

func (x *PeerStatusSpec) GetLastHandshakeTime() *timestamppb.Timestamp

func (*PeerStatusSpec) GetLastUsedEndpoint

func (x *PeerStatusSpec) GetLastUsedEndpoint() *common.NetIPPort

func (*PeerStatusSpec) GetReceiveBytes

func (x *PeerStatusSpec) GetReceiveBytes() int64

func (*PeerStatusSpec) GetState

func (x *PeerStatusSpec) GetState() enums.KubespanPeerState

func (*PeerStatusSpec) GetTransmitBytes

func (x *PeerStatusSpec) GetTransmitBytes() int64

func (*PeerStatusSpec) MarshalToSizedBufferVT

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

func (*PeerStatusSpec) MarshalToVT

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

func (*PeerStatusSpec) MarshalVT

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

func (*PeerStatusSpec) ProtoMessage

func (*PeerStatusSpec) ProtoMessage()

func (*PeerStatusSpec) ProtoReflect

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

func (*PeerStatusSpec) Reset

func (x *PeerStatusSpec) Reset()

func (*PeerStatusSpec) SizeVT

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

func (*PeerStatusSpec) String

func (x *PeerStatusSpec) String() string

func (*PeerStatusSpec) UnmarshalVT

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL