kubespan

package
v1.3.4 Latest Latest
Warning

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

 Go to latest Published: Feb 9, 2023 License: MPL-2.0 Imports: 11 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_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"`
	// 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) 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

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.