management

package
v0.9.1 Latest Latest
Warning

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

 Go to latest Published: May 19, 2023 License: MPL-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package management is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	ManagementService_Kubeconfig_FullMethodName                 = "/management.ManagementService/Kubeconfig"
	ManagementService_Talosconfig_FullMethodName                = "/management.ManagementService/Talosconfig"
	ManagementService_Omniconfig_FullMethodName                 = "/management.ManagementService/Omniconfig"
	ManagementService_MachineLogs_FullMethodName                = "/management.ManagementService/MachineLogs"
	ManagementService_ValidateConfig_FullMethodName             = "/management.ManagementService/ValidateConfig"
	ManagementService_CreateServiceAccount_FullMethodName       = "/management.ManagementService/CreateServiceAccount"
	ManagementService_RenewServiceAccount_FullMethodName        = "/management.ManagementService/RenewServiceAccount"
	ManagementService_ListServiceAccounts_FullMethodName        = "/management.ManagementService/ListServiceAccounts"
	ManagementService_DestroyServiceAccount_FullMethodName      = "/management.ManagementService/DestroyServiceAccount"
	ManagementService_KubernetesUpgradePreChecks_FullMethodName = "/management.ManagementService/KubernetesUpgradePreChecks"
	ManagementService_KubernetesSyncManifests_FullMethodName    = "/management.ManagementService/KubernetesSyncManifests"
)

Variables

View Source 
var (
	KubernetesSyncManifestResponse_ResponseType_name = map[int32]string{
		0: "UNKNOWN",
		1: "MANIFEST",
		2: "ROLLOUT",
	}
	KubernetesSyncManifestResponse_ResponseType_value = map[string]int32{
		"UNKNOWN":  0,
		"MANIFEST": 1,
		"ROLLOUT":  2,
	}
)

Enum value maps for KubernetesSyncManifestResponse_ResponseType.

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_omni_management_management_proto protoreflect.FileDescriptor
View Source 
var ManagementService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "management.ManagementService",
	HandlerType: (*ManagementServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Kubeconfig",
			Handler:    _ManagementService_Kubeconfig_Handler,
		},
		{
			MethodName: "Talosconfig",
			Handler:    _ManagementService_Talosconfig_Handler,
		},
		{
			MethodName: "Omniconfig",
			Handler:    _ManagementService_Omniconfig_Handler,
		},
		{
			MethodName: "ValidateConfig",
			Handler:    _ManagementService_ValidateConfig_Handler,
		},
		{
			MethodName: "CreateServiceAccount",
			Handler:    _ManagementService_CreateServiceAccount_Handler,
		},
		{
			MethodName: "RenewServiceAccount",
			Handler:    _ManagementService_RenewServiceAccount_Handler,
		},
		{
			MethodName: "ListServiceAccounts",
			Handler:    _ManagementService_ListServiceAccounts_Handler,
		},
		{
			MethodName: "DestroyServiceAccount",
			Handler:    _ManagementService_DestroyServiceAccount_Handler,
		},
		{
			MethodName: "KubernetesUpgradePreChecks",
			Handler:    _ManagementService_KubernetesUpgradePreChecks_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "MachineLogs",
			Handler:       _ManagementService_MachineLogs_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "KubernetesSyncManifests",
			Handler:       _ManagementService_KubernetesSyncManifests_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "omni/management/management.proto",
}

ManagementService_ServiceDesc is the grpc.ServiceDesc for ManagementService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterManagementServiceHandler 

func RegisterManagementServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterManagementServiceHandler registers the http handlers for service ManagementService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterManagementServiceHandlerClient 

func RegisterManagementServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ManagementServiceClient) error

RegisterManagementServiceHandlerClient registers the http handlers for service ManagementService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ManagementServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ManagementServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ManagementServiceClient" to call the correct interceptors.

func RegisterManagementServiceHandlerFromEndpoint 

func RegisterManagementServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterManagementServiceHandlerFromEndpoint is same as RegisterManagementServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterManagementServiceHandlerServer 

func RegisterManagementServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ManagementServiceServer) error

RegisterManagementServiceHandlerServer registers the http handlers for service ManagementService to "mux". UnaryRPC :call ManagementServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterManagementServiceHandlerFromEndpoint instead.

func RegisterManagementServiceServer 

func RegisterManagementServiceServer(s grpc.ServiceRegistrar, srv ManagementServiceServer)

Types

type CreateServiceAccountRequest 

type CreateServiceAccountRequest struct {
	ArmoredPgpPublicKey string   `protobuf:"bytes,1,opt,name=armored_pgp_public_key,json=armoredPgpPublicKey,proto3" json:"armored_pgp_public_key,omitempty"`
	Scopes              []string `protobuf:"bytes,2,rep,name=scopes,proto3" json:"scopes,omitempty"`
	// If true, scopes will be ignored and the service account will be created with the scopes of the creating user.
	UseUserScopes bool `protobuf:"varint,3,opt,name=use_user_scopes,json=useUserScopes,proto3" json:"use_user_scopes,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateServiceAccountRequest) Descriptor deprecated 

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

Deprecated: Use CreateServiceAccountRequest.ProtoReflect.Descriptor instead.

func (*CreateServiceAccountRequest) EqualMessageVT 

func (this *CreateServiceAccountRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*CreateServiceAccountRequest) EqualVT 

func (this *CreateServiceAccountRequest) EqualVT(that *CreateServiceAccountRequest) bool

func (*CreateServiceAccountRequest) GetArmoredPgpPublicKey 

func (x *CreateServiceAccountRequest) GetArmoredPgpPublicKey() string

func (*CreateServiceAccountRequest) GetScopes 

func (x *CreateServiceAccountRequest) GetScopes() []string

func (*CreateServiceAccountRequest) GetUseUserScopes 

func (x *CreateServiceAccountRequest) GetUseUserScopes() bool

func (*CreateServiceAccountRequest) MarshalToSizedBufferVT 

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

func (*CreateServiceAccountRequest) MarshalToVT 

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

func (*CreateServiceAccountRequest) MarshalVT 

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

func (*CreateServiceAccountRequest) ProtoMessage 

func (*CreateServiceAccountRequest) ProtoMessage()

func (*CreateServiceAccountRequest) ProtoReflect 

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

func (*CreateServiceAccountRequest) Reset 

func (x *CreateServiceAccountRequest) Reset()

func (*CreateServiceAccountRequest) SizeVT 

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

func (*CreateServiceAccountRequest) String 

func (x *CreateServiceAccountRequest) String() string

func (*CreateServiceAccountRequest) UnmarshalVT 

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

type CreateServiceAccountResponse 

type CreateServiceAccountResponse struct {
	PublicKeyId string `protobuf:"bytes,1,opt,name=public_key_id,json=publicKeyId,proto3" json:"public_key_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateServiceAccountResponse) Descriptor deprecated 

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

Deprecated: Use CreateServiceAccountResponse.ProtoReflect.Descriptor instead.

func (*CreateServiceAccountResponse) EqualMessageVT 

func (this *CreateServiceAccountResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*CreateServiceAccountResponse) EqualVT 

func (this *CreateServiceAccountResponse) EqualVT(that *CreateServiceAccountResponse) bool

func (*CreateServiceAccountResponse) GetPublicKeyId 

func (x *CreateServiceAccountResponse) GetPublicKeyId() string

func (*CreateServiceAccountResponse) MarshalToSizedBufferVT 

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

func (*CreateServiceAccountResponse) MarshalToVT 

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

func (*CreateServiceAccountResponse) MarshalVT 

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

func (*CreateServiceAccountResponse) ProtoMessage 

func (*CreateServiceAccountResponse) ProtoMessage()

func (*CreateServiceAccountResponse) ProtoReflect 

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

func (*CreateServiceAccountResponse) Reset 

func (x *CreateServiceAccountResponse) Reset()

func (*CreateServiceAccountResponse) SizeVT 

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

func (*CreateServiceAccountResponse) String 

func (x *CreateServiceAccountResponse) String() string

func (*CreateServiceAccountResponse) UnmarshalVT 

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

type DestroyServiceAccountRequest 

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

func (*DestroyServiceAccountRequest) Descriptor deprecated 

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

Deprecated: Use DestroyServiceAccountRequest.ProtoReflect.Descriptor instead.

func (*DestroyServiceAccountRequest) EqualMessageVT 

func (this *DestroyServiceAccountRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*DestroyServiceAccountRequest) EqualVT 

func (this *DestroyServiceAccountRequest) EqualVT(that *DestroyServiceAccountRequest) bool

func (*DestroyServiceAccountRequest) GetName 

func (x *DestroyServiceAccountRequest) GetName() string

func (*DestroyServiceAccountRequest) MarshalToSizedBufferVT 

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

func (*DestroyServiceAccountRequest) MarshalToVT 

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

func (*DestroyServiceAccountRequest) MarshalVT 

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

func (*DestroyServiceAccountRequest) ProtoMessage 

func (*DestroyServiceAccountRequest) ProtoMessage()

func (*DestroyServiceAccountRequest) ProtoReflect 

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

func (*DestroyServiceAccountRequest) Reset 

func (x *DestroyServiceAccountRequest) Reset()

func (*DestroyServiceAccountRequest) SizeVT 

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

func (*DestroyServiceAccountRequest) String 

func (x *DestroyServiceAccountRequest) String() string

func (*DestroyServiceAccountRequest) UnmarshalVT 

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

type KubeconfigRequest 

type KubeconfigRequest struct {
	ServiceAccount       bool                 `protobuf:"varint,1,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	ServiceAccountTtl    *durationpb.Duration `protobuf:"bytes,2,opt,name=service_account_ttl,json=serviceAccountTtl,proto3" json:"service_account_ttl,omitempty"`
	ServiceAccountUser   string               `protobuf:"bytes,3,opt,name=service_account_user,json=serviceAccountUser,proto3" json:"service_account_user,omitempty"`
	ServiceAccountGroups []string             `protobuf:"bytes,4,rep,name=service_account_groups,json=serviceAccountGroups,proto3" json:"service_account_groups,omitempty"`
	// contains filtered or unexported fields
}

func (*KubeconfigRequest) Descriptor deprecated 

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

Deprecated: Use KubeconfigRequest.ProtoReflect.Descriptor instead.

func (*KubeconfigRequest) EqualMessageVT 

func (this *KubeconfigRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*KubeconfigRequest) EqualVT 

func (this *KubeconfigRequest) EqualVT(that *KubeconfigRequest) bool

func (*KubeconfigRequest) GetServiceAccount 

func (x *KubeconfigRequest) GetServiceAccount() bool

func (*KubeconfigRequest) GetServiceAccountGroups 

func (x *KubeconfigRequest) GetServiceAccountGroups() []string

func (*KubeconfigRequest) GetServiceAccountTtl 

func (x *KubeconfigRequest) GetServiceAccountTtl() *durationpb.Duration

func (*KubeconfigRequest) GetServiceAccountUser 

func (x *KubeconfigRequest) GetServiceAccountUser() string

func (*KubeconfigRequest) MarshalToSizedBufferVT 

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

func (*KubeconfigRequest) MarshalToVT 

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

func (*KubeconfigRequest) MarshalVT 

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

func (*KubeconfigRequest) ProtoMessage 

func (*KubeconfigRequest) ProtoMessage()

func (*KubeconfigRequest) ProtoReflect 

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

func (*KubeconfigRequest) Reset 

func (x *KubeconfigRequest) Reset()

func (*KubeconfigRequest) SizeVT 

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

func (*KubeconfigRequest) String 

func (x *KubeconfigRequest) String() string

func (*KubeconfigRequest) UnmarshalVT 

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

type KubeconfigResponse 

type KubeconfigResponse struct {

	// Kubeconfig is the kubeconfig for the cluster.
	Kubeconfig []byte `protobuf:"bytes,1,opt,name=kubeconfig,proto3" json:"kubeconfig,omitempty"`
	// contains filtered or unexported fields
}

func (*KubeconfigResponse) Descriptor deprecated 

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

Deprecated: Use KubeconfigResponse.ProtoReflect.Descriptor instead.

func (*KubeconfigResponse) EqualMessageVT 

func (this *KubeconfigResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*KubeconfigResponse) EqualVT 

func (this *KubeconfigResponse) EqualVT(that *KubeconfigResponse) bool

func (*KubeconfigResponse) GetKubeconfig 

func (x *KubeconfigResponse) GetKubeconfig() []byte

func (*KubeconfigResponse) MarshalToSizedBufferVT 

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

func (*KubeconfigResponse) MarshalToVT 

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

func (*KubeconfigResponse) MarshalVT 

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

func (*KubeconfigResponse) ProtoMessage 

func (*KubeconfigResponse) ProtoMessage()

func (*KubeconfigResponse) ProtoReflect 

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

func (*KubeconfigResponse) Reset 

func (x *KubeconfigResponse) Reset()

func (*KubeconfigResponse) SizeVT 

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

func (*KubeconfigResponse) String 

func (x *KubeconfigResponse) String() string

func (*KubeconfigResponse) UnmarshalVT 

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

type KubernetesSyncManifestRequest 

type KubernetesSyncManifestRequest struct {
	DryRun bool `protobuf:"varint,1,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// contains filtered or unexported fields
}

func (*KubernetesSyncManifestRequest) Descriptor deprecated 

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

Deprecated: Use KubernetesSyncManifestRequest.ProtoReflect.Descriptor instead.

func (*KubernetesSyncManifestRequest) EqualMessageVT 

func (this *KubernetesSyncManifestRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*KubernetesSyncManifestRequest) EqualVT 

func (this *KubernetesSyncManifestRequest) EqualVT(that *KubernetesSyncManifestRequest) bool

func (*KubernetesSyncManifestRequest) GetDryRun 

func (x *KubernetesSyncManifestRequest) GetDryRun() bool

func (*KubernetesSyncManifestRequest) MarshalToSizedBufferVT 

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

func (*KubernetesSyncManifestRequest) MarshalToVT 

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

func (*KubernetesSyncManifestRequest) MarshalVT 

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

func (*KubernetesSyncManifestRequest) ProtoMessage 

func (*KubernetesSyncManifestRequest) ProtoMessage()

func (*KubernetesSyncManifestRequest) ProtoReflect 

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

func (*KubernetesSyncManifestRequest) Reset 

func (x *KubernetesSyncManifestRequest) Reset()

func (*KubernetesSyncManifestRequest) SizeVT 

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

func (*KubernetesSyncManifestRequest) String 

func (x *KubernetesSyncManifestRequest) String() string

func (*KubernetesSyncManifestRequest) UnmarshalVT 

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

type KubernetesSyncManifestResponse 

type KubernetesSyncManifestResponse struct {
	ResponseType KubernetesSyncManifestResponse_ResponseType `` /* 158-byte string literal not displayed */
	Path         string                                      `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Object       []byte                                      `protobuf:"bytes,3,opt,name=object,proto3" json:"object,omitempty"`
	Diff         string                                      `protobuf:"bytes,4,opt,name=diff,proto3" json:"diff,omitempty"`
	Skipped      bool                                        `protobuf:"varint,5,opt,name=skipped,proto3" json:"skipped,omitempty"`
	// contains filtered or unexported fields
}

func (*KubernetesSyncManifestResponse) Descriptor deprecated 

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

Deprecated: Use KubernetesSyncManifestResponse.ProtoReflect.Descriptor instead.

func (*KubernetesSyncManifestResponse) EqualMessageVT 

func (this *KubernetesSyncManifestResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*KubernetesSyncManifestResponse) EqualVT 

func (this *KubernetesSyncManifestResponse) EqualVT(that *KubernetesSyncManifestResponse) bool

func (*KubernetesSyncManifestResponse) GetDiff 

func (x *KubernetesSyncManifestResponse) GetDiff() string

func (*KubernetesSyncManifestResponse) GetObject 

func (x *KubernetesSyncManifestResponse) GetObject() []byte

func (*KubernetesSyncManifestResponse) GetPath 

func (x *KubernetesSyncManifestResponse) GetPath() string

func (*KubernetesSyncManifestResponse) GetResponseType 

func (x *KubernetesSyncManifestResponse) GetResponseType() KubernetesSyncManifestResponse_ResponseType

func (*KubernetesSyncManifestResponse) GetSkipped 

func (x *KubernetesSyncManifestResponse) GetSkipped() bool

func (*KubernetesSyncManifestResponse) MarshalToSizedBufferVT 

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

func (*KubernetesSyncManifestResponse) MarshalToVT 

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

func (*KubernetesSyncManifestResponse) MarshalVT 

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

func (*KubernetesSyncManifestResponse) ProtoMessage 

func (*KubernetesSyncManifestResponse) ProtoMessage()

func (*KubernetesSyncManifestResponse) ProtoReflect 

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

func (*KubernetesSyncManifestResponse) Reset 

func (x *KubernetesSyncManifestResponse) Reset()

func (*KubernetesSyncManifestResponse) SizeVT 

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

func (*KubernetesSyncManifestResponse) String 

func (x *KubernetesSyncManifestResponse) String() string

func (*KubernetesSyncManifestResponse) UnmarshalVT 

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

type KubernetesSyncManifestResponse_ResponseType 

type KubernetesSyncManifestResponse_ResponseType int32
const (
	KubernetesSyncManifestResponse_UNKNOWN  KubernetesSyncManifestResponse_ResponseType = 0
	KubernetesSyncManifestResponse_MANIFEST KubernetesSyncManifestResponse_ResponseType = 1
	KubernetesSyncManifestResponse_ROLLOUT  KubernetesSyncManifestResponse_ResponseType = 2
)

func (KubernetesSyncManifestResponse_ResponseType) Descriptor 

func (KubernetesSyncManifestResponse_ResponseType) Descriptor() protoreflect.EnumDescriptor

func (KubernetesSyncManifestResponse_ResponseType) Enum 

func (x KubernetesSyncManifestResponse_ResponseType) Enum() *KubernetesSyncManifestResponse_ResponseType

func (KubernetesSyncManifestResponse_ResponseType) EnumDescriptor deprecated 

func (KubernetesSyncManifestResponse_ResponseType) EnumDescriptor() ([]byte, []int)

Deprecated: Use KubernetesSyncManifestResponse_ResponseType.Descriptor instead.

func (KubernetesSyncManifestResponse_ResponseType) Number 

func (x KubernetesSyncManifestResponse_ResponseType) Number() protoreflect.EnumNumber

func (KubernetesSyncManifestResponse_ResponseType) String 

func (x KubernetesSyncManifestResponse_ResponseType) String() string

func (KubernetesSyncManifestResponse_ResponseType) Type 

func (KubernetesSyncManifestResponse_ResponseType) Type() protoreflect.EnumType

type KubernetesUpgradePreChecksRequest 

type KubernetesUpgradePreChecksRequest struct {
	NewVersion string `protobuf:"bytes,1,opt,name=new_version,json=newVersion,proto3" json:"new_version,omitempty"`
	// contains filtered or unexported fields
}

func (*KubernetesUpgradePreChecksRequest) Descriptor deprecated 

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

Deprecated: Use KubernetesUpgradePreChecksRequest.ProtoReflect.Descriptor instead.

func (*KubernetesUpgradePreChecksRequest) EqualMessageVT 

func (this *KubernetesUpgradePreChecksRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*KubernetesUpgradePreChecksRequest) EqualVT 

func (this *KubernetesUpgradePreChecksRequest) EqualVT(that *KubernetesUpgradePreChecksRequest) bool

func (*KubernetesUpgradePreChecksRequest) GetNewVersion 

func (x *KubernetesUpgradePreChecksRequest) GetNewVersion() string

func (*KubernetesUpgradePreChecksRequest) MarshalToSizedBufferVT 

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

func (*KubernetesUpgradePreChecksRequest) MarshalToVT 

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

func (*KubernetesUpgradePreChecksRequest) MarshalVT 

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

func (*KubernetesUpgradePreChecksRequest) ProtoMessage 

func (*KubernetesUpgradePreChecksRequest) ProtoMessage()

func (*KubernetesUpgradePreChecksRequest) ProtoReflect 

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

func (*KubernetesUpgradePreChecksRequest) Reset 

func (x *KubernetesUpgradePreChecksRequest) Reset()

func (*KubernetesUpgradePreChecksRequest) SizeVT 

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

func (*KubernetesUpgradePreChecksRequest) String 

func (x *KubernetesUpgradePreChecksRequest) String() string

func (*KubernetesUpgradePreChecksRequest) UnmarshalVT 

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

type KubernetesUpgradePreChecksResponse 

type KubernetesUpgradePreChecksResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*KubernetesUpgradePreChecksResponse) Descriptor deprecated 

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

Deprecated: Use KubernetesUpgradePreChecksResponse.ProtoReflect.Descriptor instead.

func (*KubernetesUpgradePreChecksResponse) EqualMessageVT 

func (this *KubernetesUpgradePreChecksResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*KubernetesUpgradePreChecksResponse) EqualVT 

func (this *KubernetesUpgradePreChecksResponse) EqualVT(that *KubernetesUpgradePreChecksResponse) bool

func (*KubernetesUpgradePreChecksResponse) GetOk 

func (x *KubernetesUpgradePreChecksResponse) GetOk() bool

func (*KubernetesUpgradePreChecksResponse) GetReason 

func (x *KubernetesUpgradePreChecksResponse) GetReason() string

func (*KubernetesUpgradePreChecksResponse) MarshalToSizedBufferVT 

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

func (*KubernetesUpgradePreChecksResponse) MarshalToVT 

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

func (*KubernetesUpgradePreChecksResponse) MarshalVT 

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

func (*KubernetesUpgradePreChecksResponse) ProtoMessage 

func (*KubernetesUpgradePreChecksResponse) ProtoMessage()

func (*KubernetesUpgradePreChecksResponse) ProtoReflect 

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

func (*KubernetesUpgradePreChecksResponse) Reset 

func (x *KubernetesUpgradePreChecksResponse) Reset()

func (*KubernetesUpgradePreChecksResponse) SizeVT 

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

func (*KubernetesUpgradePreChecksResponse) String 

func (x *KubernetesUpgradePreChecksResponse) String() string

func (*KubernetesUpgradePreChecksResponse) UnmarshalVT 

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

type ListServiceAccountsResponse 

type ListServiceAccountsResponse struct {
	ServiceAccounts []*ListServiceAccountsResponse_ServiceAccount `protobuf:"bytes,1,rep,name=service_accounts,json=serviceAccounts,proto3" json:"service_accounts,omitempty"`
	// contains filtered or unexported fields
}

func (*ListServiceAccountsResponse) Descriptor deprecated 

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

Deprecated: Use ListServiceAccountsResponse.ProtoReflect.Descriptor instead.

func (*ListServiceAccountsResponse) EqualMessageVT 

func (this *ListServiceAccountsResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*ListServiceAccountsResponse) EqualVT 

func (this *ListServiceAccountsResponse) EqualVT(that *ListServiceAccountsResponse) bool

func (*ListServiceAccountsResponse) GetServiceAccounts 

func (x *ListServiceAccountsResponse) GetServiceAccounts() []*ListServiceAccountsResponse_ServiceAccount

func (*ListServiceAccountsResponse) MarshalToSizedBufferVT 

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

func (*ListServiceAccountsResponse) MarshalToVT 

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

func (*ListServiceAccountsResponse) MarshalVT 

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

func (*ListServiceAccountsResponse) ProtoMessage 

func (*ListServiceAccountsResponse) ProtoMessage()

func (*ListServiceAccountsResponse) ProtoReflect 

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

func (*ListServiceAccountsResponse) Reset 

func (x *ListServiceAccountsResponse) Reset()

func (*ListServiceAccountsResponse) SizeVT 

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

func (*ListServiceAccountsResponse) String 

func (x *ListServiceAccountsResponse) String() string

func (*ListServiceAccountsResponse) UnmarshalVT 

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

type ListServiceAccountsResponse_ServiceAccount 

type ListServiceAccountsResponse_ServiceAccount struct {
	Name          string                                                     `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PgpPublicKeys []*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey `protobuf:"bytes,2,rep,name=pgp_public_keys,json=pgpPublicKeys,proto3" json:"pgp_public_keys,omitempty"`
	Scopes        []string                                                   `protobuf:"bytes,3,rep,name=scopes,proto3" json:"scopes,omitempty"`
	// contains filtered or unexported fields
}

func (*ListServiceAccountsResponse_ServiceAccount) Descriptor deprecated 

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

Deprecated: Use ListServiceAccountsResponse_ServiceAccount.ProtoReflect.Descriptor instead.

func (*ListServiceAccountsResponse_ServiceAccount) EqualMessageVT 

func (this *ListServiceAccountsResponse_ServiceAccount) EqualMessageVT(thatMsg proto.Message) bool

func (*ListServiceAccountsResponse_ServiceAccount) EqualVT 

func (this *ListServiceAccountsResponse_ServiceAccount) EqualVT(that *ListServiceAccountsResponse_ServiceAccount) bool

func (*ListServiceAccountsResponse_ServiceAccount) GetName 

func (x *ListServiceAccountsResponse_ServiceAccount) GetName() string

func (*ListServiceAccountsResponse_ServiceAccount) GetPgpPublicKeys 

func (x *ListServiceAccountsResponse_ServiceAccount) GetPgpPublicKeys() []*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey

func (*ListServiceAccountsResponse_ServiceAccount) GetScopes 

func (x *ListServiceAccountsResponse_ServiceAccount) GetScopes() []string

func (*ListServiceAccountsResponse_ServiceAccount) MarshalToSizedBufferVT 

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

func (*ListServiceAccountsResponse_ServiceAccount) MarshalToVT 

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

func (*ListServiceAccountsResponse_ServiceAccount) MarshalVT 

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

func (*ListServiceAccountsResponse_ServiceAccount) ProtoMessage 

func (*ListServiceAccountsResponse_ServiceAccount) ProtoMessage()

func (*ListServiceAccountsResponse_ServiceAccount) ProtoReflect 

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

func (*ListServiceAccountsResponse_ServiceAccount) Reset 

func (x *ListServiceAccountsResponse_ServiceAccount) Reset()

func (*ListServiceAccountsResponse_ServiceAccount) SizeVT 

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

func (*ListServiceAccountsResponse_ServiceAccount) String 

func (x *ListServiceAccountsResponse_ServiceAccount) String() string

func (*ListServiceAccountsResponse_ServiceAccount) UnmarshalVT 

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

type ListServiceAccountsResponse_ServiceAccount_PgpPublicKey 

type ListServiceAccountsResponse_ServiceAccount_PgpPublicKey struct {
	Id         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Armored    string                 `protobuf:"bytes,2,opt,name=armored,proto3" json:"armored,omitempty"`
	Expiration *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expiration,proto3" json:"expiration,omitempty"`
	// contains filtered or unexported fields
}

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) Descriptor deprecated 

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

Deprecated: Use ListServiceAccountsResponse_ServiceAccount_PgpPublicKey.ProtoReflect.Descriptor instead.

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) EqualMessageVT 

func (this *ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) EqualMessageVT(thatMsg proto.Message) bool

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) EqualVT 

func (this *ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) EqualVT(that *ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) bool

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) GetArmored 

func (x *ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) GetArmored() string

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) GetExpiration 

func (x *ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) GetExpiration() *timestamppb.Timestamp

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) GetId 

func (x *ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) GetId() string

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) MarshalToSizedBufferVT 

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

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) MarshalToVT 

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

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) MarshalVT 

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

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) ProtoMessage 

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) ProtoMessage()

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) ProtoReflect 

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

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) Reset 

func (x *ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) Reset()

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) SizeVT 

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

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) String 

func (x *ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) String() string

func (*ListServiceAccountsResponse_ServiceAccount_PgpPublicKey) UnmarshalVT 

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

type MachineLogsRequest 

type MachineLogsRequest struct {

	// MachineId is the ID of the machine.
	MachineId string `protobuf:"bytes,1,opt,name=machine_id,json=machineId,proto3" json:"machine_id,omitempty"`
	// Follow is whether to follow the logs.
	Follow bool `protobuf:"varint,2,opt,name=follow,proto3" json:"follow,omitempty"`
	// TailLines is the number of lines to tail.
	TailLines int32 `protobuf:"varint,3,opt,name=tail_lines,json=tailLines,proto3" json:"tail_lines,omitempty"`
	// contains filtered or unexported fields
}

func (*MachineLogsRequest) Descriptor deprecated 

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

Deprecated: Use MachineLogsRequest.ProtoReflect.Descriptor instead.

func (*MachineLogsRequest) EqualMessageVT 

func (this *MachineLogsRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*MachineLogsRequest) EqualVT 

func (this *MachineLogsRequest) EqualVT(that *MachineLogsRequest) bool

func (*MachineLogsRequest) GetFollow 

func (x *MachineLogsRequest) GetFollow() bool

func (*MachineLogsRequest) GetMachineId 

func (x *MachineLogsRequest) GetMachineId() string

func (*MachineLogsRequest) GetTailLines 

func (x *MachineLogsRequest) GetTailLines() int32

func (*MachineLogsRequest) MarshalToSizedBufferVT 

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

func (*MachineLogsRequest) MarshalToVT 

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

func (*MachineLogsRequest) MarshalVT 

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

func (*MachineLogsRequest) ProtoMessage 

func (*MachineLogsRequest) ProtoMessage()

func (*MachineLogsRequest) ProtoReflect 

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

func (*MachineLogsRequest) Reset 

func (x *MachineLogsRequest) Reset()

func (*MachineLogsRequest) SizeVT 

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

func (*MachineLogsRequest) String 

func (x *MachineLogsRequest) String() string

func (*MachineLogsRequest) UnmarshalVT 

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

type ManagementServiceClient 

type ManagementServiceClient interface {
	Kubeconfig(ctx context.Context, in *KubeconfigRequest, opts ...grpc.CallOption) (*KubeconfigResponse, error)
	Talosconfig(ctx context.Context, in *TalosconfigRequest, opts ...grpc.CallOption) (*TalosconfigResponse, error)
	Omniconfig(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*OmniconfigResponse, error)
	MachineLogs(ctx context.Context, in *MachineLogsRequest, opts ...grpc.CallOption) (ManagementService_MachineLogsClient, error)
	ValidateConfig(ctx context.Context, in *ValidateConfigRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CreateServiceAccount(ctx context.Context, in *CreateServiceAccountRequest, opts ...grpc.CallOption) (*CreateServiceAccountResponse, error)
	RenewServiceAccount(ctx context.Context, in *RenewServiceAccountRequest, opts ...grpc.CallOption) (*RenewServiceAccountResponse, error)
	ListServiceAccounts(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListServiceAccountsResponse, error)
	DestroyServiceAccount(ctx context.Context, in *DestroyServiceAccountRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	KubernetesUpgradePreChecks(ctx context.Context, in *KubernetesUpgradePreChecksRequest, opts ...grpc.CallOption) (*KubernetesUpgradePreChecksResponse, error)
	KubernetesSyncManifests(ctx context.Context, in *KubernetesSyncManifestRequest, opts ...grpc.CallOption) (ManagementService_KubernetesSyncManifestsClient, error)
}

ManagementServiceClient is the client API for ManagementService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewManagementServiceClient 

func NewManagementServiceClient(cc grpc.ClientConnInterface) ManagementServiceClient

type ManagementServiceServer 

type ManagementServiceServer interface {
	Kubeconfig(context.Context, *KubeconfigRequest) (*KubeconfigResponse, error)
	Talosconfig(context.Context, *TalosconfigRequest) (*TalosconfigResponse, error)
	Omniconfig(context.Context, *emptypb.Empty) (*OmniconfigResponse, error)
	MachineLogs(*MachineLogsRequest, ManagementService_MachineLogsServer) error
	ValidateConfig(context.Context, *ValidateConfigRequest) (*emptypb.Empty, error)
	CreateServiceAccount(context.Context, *CreateServiceAccountRequest) (*CreateServiceAccountResponse, error)
	RenewServiceAccount(context.Context, *RenewServiceAccountRequest) (*RenewServiceAccountResponse, error)
	ListServiceAccounts(context.Context, *emptypb.Empty) (*ListServiceAccountsResponse, error)
	DestroyServiceAccount(context.Context, *DestroyServiceAccountRequest) (*emptypb.Empty, error)
	KubernetesUpgradePreChecks(context.Context, *KubernetesUpgradePreChecksRequest) (*KubernetesUpgradePreChecksResponse, error)
	KubernetesSyncManifests(*KubernetesSyncManifestRequest, ManagementService_KubernetesSyncManifestsServer) error
	// contains filtered or unexported methods
}

ManagementServiceServer is the server API for ManagementService service. All implementations must embed UnimplementedManagementServiceServer for forward compatibility

type ManagementService_KubernetesSyncManifestsClient 

type ManagementService_KubernetesSyncManifestsClient interface {
	Recv() (*KubernetesSyncManifestResponse, error)
	grpc.ClientStream
}

type ManagementService_KubernetesSyncManifestsServer 

type ManagementService_KubernetesSyncManifestsServer interface {
	Send(*KubernetesSyncManifestResponse) error
	grpc.ServerStream
}

type ManagementService_MachineLogsClient 

type ManagementService_MachineLogsClient interface {
	Recv() (*common.Data, error)
	grpc.ClientStream
}

type ManagementService_MachineLogsServer 

type ManagementService_MachineLogsServer interface {
	Send(*common.Data) error
	grpc.ServerStream
}

type OmniconfigResponse 

type OmniconfigResponse struct {

	// omniconfig is the omnictl client configuration to access the omni instance.
	Omniconfig []byte `protobuf:"bytes,1,opt,name=omniconfig,proto3" json:"omniconfig,omitempty"`
	// contains filtered or unexported fields
}

func (*OmniconfigResponse) Descriptor deprecated 

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

Deprecated: Use OmniconfigResponse.ProtoReflect.Descriptor instead.

func (*OmniconfigResponse) EqualMessageVT 

func (this *OmniconfigResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*OmniconfigResponse) EqualVT 

func (this *OmniconfigResponse) EqualVT(that *OmniconfigResponse) bool

func (*OmniconfigResponse) GetOmniconfig 

func (x *OmniconfigResponse) GetOmniconfig() []byte

func (*OmniconfigResponse) MarshalToSizedBufferVT 

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

func (*OmniconfigResponse) MarshalToVT 

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

func (*OmniconfigResponse) MarshalVT 

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

func (*OmniconfigResponse) ProtoMessage 

func (*OmniconfigResponse) ProtoMessage()

func (*OmniconfigResponse) ProtoReflect 

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

func (*OmniconfigResponse) Reset 

func (x *OmniconfigResponse) Reset()

func (*OmniconfigResponse) SizeVT 

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

func (*OmniconfigResponse) String 

func (x *OmniconfigResponse) String() string

func (*OmniconfigResponse) UnmarshalVT 

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

type RenewServiceAccountRequest 

type RenewServiceAccountRequest struct {
	Name                string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ArmoredPgpPublicKey string `protobuf:"bytes,2,opt,name=armored_pgp_public_key,json=armoredPgpPublicKey,proto3" json:"armored_pgp_public_key,omitempty"`
	// contains filtered or unexported fields
}

func (*RenewServiceAccountRequest) Descriptor deprecated 

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

Deprecated: Use RenewServiceAccountRequest.ProtoReflect.Descriptor instead.

func (*RenewServiceAccountRequest) EqualMessageVT 

func (this *RenewServiceAccountRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*RenewServiceAccountRequest) EqualVT 

func (this *RenewServiceAccountRequest) EqualVT(that *RenewServiceAccountRequest) bool

func (*RenewServiceAccountRequest) GetArmoredPgpPublicKey 

func (x *RenewServiceAccountRequest) GetArmoredPgpPublicKey() string

func (*RenewServiceAccountRequest) GetName 

func (x *RenewServiceAccountRequest) GetName() string

func (*RenewServiceAccountRequest) MarshalToSizedBufferVT 

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

func (*RenewServiceAccountRequest) MarshalToVT 

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

func (*RenewServiceAccountRequest) MarshalVT 

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

func (*RenewServiceAccountRequest) ProtoMessage 

func (*RenewServiceAccountRequest) ProtoMessage()

func (*RenewServiceAccountRequest) ProtoReflect 

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

func (*RenewServiceAccountRequest) Reset 

func (x *RenewServiceAccountRequest) Reset()

func (*RenewServiceAccountRequest) SizeVT 

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

func (*RenewServiceAccountRequest) String 

func (x *RenewServiceAccountRequest) String() string

func (*RenewServiceAccountRequest) UnmarshalVT 

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

type RenewServiceAccountResponse 

type RenewServiceAccountResponse struct {
	PublicKeyId string `protobuf:"bytes,1,opt,name=public_key_id,json=publicKeyId,proto3" json:"public_key_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RenewServiceAccountResponse) Descriptor deprecated 

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

Deprecated: Use RenewServiceAccountResponse.ProtoReflect.Descriptor instead.

func (*RenewServiceAccountResponse) EqualMessageVT 

func (this *RenewServiceAccountResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*RenewServiceAccountResponse) EqualVT 

func (this *RenewServiceAccountResponse) EqualVT(that *RenewServiceAccountResponse) bool

func (*RenewServiceAccountResponse) GetPublicKeyId 

func (x *RenewServiceAccountResponse) GetPublicKeyId() string

func (*RenewServiceAccountResponse) MarshalToSizedBufferVT 

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

func (*RenewServiceAccountResponse) MarshalToVT 

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

func (*RenewServiceAccountResponse) MarshalVT 

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

func (*RenewServiceAccountResponse) ProtoMessage 

func (*RenewServiceAccountResponse) ProtoMessage()

func (*RenewServiceAccountResponse) ProtoReflect 

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

func (*RenewServiceAccountResponse) Reset 

func (x *RenewServiceAccountResponse) Reset()

func (*RenewServiceAccountResponse) SizeVT 

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

func (*RenewServiceAccountResponse) String 

func (x *RenewServiceAccountResponse) String() string

func (*RenewServiceAccountResponse) UnmarshalVT 

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

type TalosconfigRequest 

type TalosconfigRequest struct {

	// Admin indicates whether to generate an admin talosconfig or a regular one.
	Admin bool `protobuf:"varint,1,opt,name=admin,proto3" json:"admin,omitempty"`
	// contains filtered or unexported fields
}

func (*TalosconfigRequest) Descriptor deprecated 

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

Deprecated: Use TalosconfigRequest.ProtoReflect.Descriptor instead.

func (*TalosconfigRequest) EqualMessageVT 

func (this *TalosconfigRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*TalosconfigRequest) EqualVT 

func (this *TalosconfigRequest) EqualVT(that *TalosconfigRequest) bool

func (*TalosconfigRequest) GetAdmin 

func (x *TalosconfigRequest) GetAdmin() bool

func (*TalosconfigRequest) MarshalToSizedBufferVT 

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

func (*TalosconfigRequest) MarshalToVT 

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

func (*TalosconfigRequest) MarshalVT 

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

func (*TalosconfigRequest) ProtoMessage 

func (*TalosconfigRequest) ProtoMessage()

func (*TalosconfigRequest) ProtoReflect 

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

func (*TalosconfigRequest) Reset 

func (x *TalosconfigRequest) Reset()

func (*TalosconfigRequest) SizeVT 

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

func (*TalosconfigRequest) String 

func (x *TalosconfigRequest) String() string

func (*TalosconfigRequest) UnmarshalVT 

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

type TalosconfigResponse 

type TalosconfigResponse struct {

	// talosconfig is the talos client configuration to access the cluster via the proxy.
	Talosconfig []byte `protobuf:"bytes,1,opt,name=talosconfig,proto3" json:"talosconfig,omitempty"`
	// contains filtered or unexported fields
}

func (*TalosconfigResponse) Descriptor deprecated 

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

Deprecated: Use TalosconfigResponse.ProtoReflect.Descriptor instead.

func (*TalosconfigResponse) EqualMessageVT 

func (this *TalosconfigResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*TalosconfigResponse) EqualVT 

func (this *TalosconfigResponse) EqualVT(that *TalosconfigResponse) bool

func (*TalosconfigResponse) GetTalosconfig 

func (x *TalosconfigResponse) GetTalosconfig() []byte

func (*TalosconfigResponse) MarshalToSizedBufferVT 

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

func (*TalosconfigResponse) MarshalToVT 

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

func (*TalosconfigResponse) MarshalVT 

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

func (*TalosconfigResponse) ProtoMessage 

func (*TalosconfigResponse) ProtoMessage()

func (*TalosconfigResponse) ProtoReflect 

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

func (*TalosconfigResponse) Reset 

func (x *TalosconfigResponse) Reset()

func (*TalosconfigResponse) SizeVT 

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

func (*TalosconfigResponse) String 

func (x *TalosconfigResponse) String() string

func (*TalosconfigResponse) UnmarshalVT 

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

type UnimplementedManagementServiceServer 

type UnimplementedManagementServiceServer struct {
}

UnimplementedManagementServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedManagementServiceServer) CreateServiceAccount 

func (UnimplementedManagementServiceServer) CreateServiceAccount(context.Context, *CreateServiceAccountRequest) (*CreateServiceAccountResponse, error)

func (UnimplementedManagementServiceServer) DestroyServiceAccount 

func (UnimplementedManagementServiceServer) DestroyServiceAccount(context.Context, *DestroyServiceAccountRequest) (*emptypb.Empty, error)

func (UnimplementedManagementServiceServer) Kubeconfig 

func (UnimplementedManagementServiceServer) Kubeconfig(context.Context, *KubeconfigRequest) (*KubeconfigResponse, error)

func (UnimplementedManagementServiceServer) KubernetesSyncManifests 

func (UnimplementedManagementServiceServer) KubernetesSyncManifests(*KubernetesSyncManifestRequest, ManagementService_KubernetesSyncManifestsServer) error

func (UnimplementedManagementServiceServer) KubernetesUpgradePreChecks 

func (UnimplementedManagementServiceServer) KubernetesUpgradePreChecks(context.Context, *KubernetesUpgradePreChecksRequest) (*KubernetesUpgradePreChecksResponse, error)

func (UnimplementedManagementServiceServer) ListServiceAccounts 

func (UnimplementedManagementServiceServer) ListServiceAccounts(context.Context, *emptypb.Empty) (*ListServiceAccountsResponse, error)

func (UnimplementedManagementServiceServer) MachineLogs 

func (UnimplementedManagementServiceServer) MachineLogs(*MachineLogsRequest, ManagementService_MachineLogsServer) error

func (UnimplementedManagementServiceServer) Omniconfig 

func (UnimplementedManagementServiceServer) Omniconfig(context.Context, *emptypb.Empty) (*OmniconfigResponse, error)

func (UnimplementedManagementServiceServer) RenewServiceAccount 

func (UnimplementedManagementServiceServer) RenewServiceAccount(context.Context, *RenewServiceAccountRequest) (*RenewServiceAccountResponse, error)

func (UnimplementedManagementServiceServer) Talosconfig 

func (UnimplementedManagementServiceServer) Talosconfig(context.Context, *TalosconfigRequest) (*TalosconfigResponse, error)

func (UnimplementedManagementServiceServer) ValidateConfig 

func (UnimplementedManagementServiceServer) ValidateConfig(context.Context, *ValidateConfigRequest) (*emptypb.Empty, error)

type UnsafeManagementServiceServer 

type UnsafeManagementServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeManagementServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ManagementServiceServer will result in compilation errors.

type ValidateConfigRequest 

type ValidateConfigRequest struct {

	// Config represents raw configuration string to validate.
	Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateConfigRequest) Descriptor deprecated 

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

Deprecated: Use ValidateConfigRequest.ProtoReflect.Descriptor instead.

func (*ValidateConfigRequest) EqualMessageVT 

func (this *ValidateConfigRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*ValidateConfigRequest) EqualVT 

func (this *ValidateConfigRequest) EqualVT(that *ValidateConfigRequest) bool

func (*ValidateConfigRequest) GetConfig 

func (x *ValidateConfigRequest) GetConfig() string

func (*ValidateConfigRequest) MarshalToSizedBufferVT 

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

func (*ValidateConfigRequest) MarshalToVT 

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

func (*ValidateConfigRequest) MarshalVT 

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

func (*ValidateConfigRequest) ProtoMessage 

func (*ValidateConfigRequest) ProtoMessage()

func (*ValidateConfigRequest) ProtoReflect 

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

func (*ValidateConfigRequest) Reset 

func (x *ValidateConfigRequest) Reset()

func (*ValidateConfigRequest) SizeVT 

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

func (*ValidateConfigRequest) String 

func (x *ValidateConfigRequest) String() string

func (*ValidateConfigRequest) UnmarshalVT 

func (m *ValidateConfigRequest) 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.