rpc

package
v0.2.1 Latest Latest
Warning

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

 Go to latest Published: Apr 8, 2022 License: MPL-2.0 Imports: 20 Imported by: 0

Documentation

Overview

Package rpc is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package rpc is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package rpc is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	TaskStatusSpec_Phase_name = map[int32]string{
		0: "FAILED",
		1: "RUNNING",
		2: "COMPLETE",
	}
	TaskStatusSpec_Phase_value = map[string]int32{
		"FAILED":   0,
		"RUNNING":  1,
		"COMPLETE": 2,
	}
)

Enum value maps for TaskStatusSpec_Phase.

View Source 
var ContextService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cluster.ContextService",
	HandlerType: (*ContextServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "List",
			Handler:    _ContextService_List_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpc/context.proto",
}

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

View Source 
var File_rpc_context_proto protoreflect.FileDescriptor
View Source 
var File_rpc_management_proto protoreflect.FileDescriptor
View Source 
var File_rpc_resource_proto protoreflect.FileDescriptor
View Source 
var ManagementService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "management.ManagementService",
	HandlerType: (*ManagementServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpgradeInfo",
			Handler:    _ManagementService_UpgradeInfo_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpc/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)

View Source 
var ResourceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "theila.resource.ResourceService",
	HandlerType: (*ResourceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _ResourceService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _ResourceService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _ResourceService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _ResourceService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ResourceService_Delete_Handler,
		},
		{
			MethodName: "GetConfig",
			Handler:    _ResourceService_GetConfig_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpc/resource.proto",
}

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

Functions

func RegisterContextServiceHandler 

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

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

func RegisterContextServiceHandlerClient 

func RegisterContextServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ContextServiceClient) error

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

func RegisterContextServiceHandlerFromEndpoint 

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

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

func RegisterContextServiceHandlerServer 

func RegisterContextServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ContextServiceServer) error

RegisterContextServiceHandlerServer registers the http handlers for service ContextService to "mux". UnaryRPC :call ContextServiceServer 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 RegisterContextServiceHandlerFromEndpoint instead.

func RegisterContextServiceServer 

func RegisterContextServiceServer(s grpc.ServiceRegistrar, srv ContextServiceServer)

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)

func RegisterResourceServiceHandler 

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

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

func RegisterResourceServiceHandlerClient 

func RegisterResourceServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ResourceServiceClient) error

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

func RegisterResourceServiceHandlerFromEndpoint 

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

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

func RegisterResourceServiceHandlerServer 

func RegisterResourceServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ResourceServiceServer) error

RegisterResourceServiceHandlerServer registers the http handlers for service ResourceService to "mux". UnaryRPC :call ResourceServiceServer 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 RegisterResourceServiceHandlerFromEndpoint instead.

func RegisterResourceServiceServer 

func RegisterResourceServiceServer(s grpc.ServiceRegistrar, srv ResourceServiceServer)

Types

type ConfigResponse 

type ConfigResponse struct {

	// Data raw config data.
	Data string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigResponse) Descriptor deprecated 

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

Deprecated: Use ConfigResponse.ProtoReflect.Descriptor instead.

func (*ConfigResponse) GetData 

func (x *ConfigResponse) GetData() string

func (*ConfigResponse) ProtoMessage 

func (*ConfigResponse) ProtoMessage()

func (*ConfigResponse) ProtoReflect 

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

func (*ConfigResponse) Reset 

func (x *ConfigResponse) Reset()

func (*ConfigResponse) String 

func (x *ConfigResponse) String() string

type Context 

type Context struct {

	// Name is the name of the Context.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Cluster is the name of the cluster.
	Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*Context) Descriptor deprecated 

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

Deprecated: Use Context.ProtoReflect.Descriptor instead.

func (*Context) GetCluster 

func (x *Context) GetCluster() string

func (*Context) GetName 

func (x *Context) GetName() string

func (*Context) ProtoMessage 

func (*Context) ProtoMessage()

func (*Context) ProtoReflect 

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

func (*Context) Reset 

func (x *Context) Reset()

func (*Context) String 

func (x *Context) String() string

type ContextServiceClient 

type ContextServiceClient interface {
	List(ctx context.Context, in *ListContextsRequest, opts ...grpc.CallOption) (*ListContextsResponse, error)
}

ContextServiceClient is the client API for ContextService 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 NewContextServiceClient 

func NewContextServiceClient(cc grpc.ClientConnInterface) ContextServiceClient

type ContextServiceServer 

type ContextServiceServer interface {
	List(context.Context, *ListContextsRequest) (*ListContextsResponse, error)
	// contains filtered or unexported methods
}

ContextServiceServer is the server API for ContextService service. All implementations must embed UnimplementedContextServiceServer for forward compatibility

type CreateRequest 

type CreateRequest struct {
	Resource *v1alpha1.Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRequest) Descriptor deprecated 

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetResource 

func (x *CreateRequest) GetResource() *v1alpha1.Resource

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

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

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateResponse 

type CreateResponse struct {
	// contains filtered or unexported fields
}

func (*CreateResponse) Descriptor deprecated 

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect 

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

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type DeleteRequest 

type DeleteRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type      string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Id        string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetId 

func (x *DeleteRequest) GetId() string

func (*DeleteRequest) GetNamespace 

func (x *DeleteRequest) GetNamespace() string

func (*DeleteRequest) GetType 

func (x *DeleteRequest) GetType() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	// contains filtered or unexported fields
}

func (*DeleteResponse) Descriptor deprecated 

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

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect 

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

func (*DeleteResponse) Reset 

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (x *DeleteResponse) String() string

type GetResponse 

type GetResponse struct {

	// Body should contain JSON encoded spec.
	Body string `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetBody 

func (x *GetResponse) GetBody() string

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type KubernetesResourceSpec 

type KubernetesResourceSpec struct {

	// Spec contains JSON encoded Kubernetes runtime object.
	Spec string `protobuf:"bytes,1,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*KubernetesResourceSpec) Descriptor deprecated 

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

Deprecated: Use KubernetesResourceSpec.ProtoReflect.Descriptor instead.

func (*KubernetesResourceSpec) GetSpec 

func (x *KubernetesResourceSpec) GetSpec() string

func (*KubernetesResourceSpec) ProtoMessage 

func (*KubernetesResourceSpec) ProtoMessage()

func (*KubernetesResourceSpec) ProtoReflect 

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

func (*KubernetesResourceSpec) Reset 

func (x *KubernetesResourceSpec) Reset()

func (*KubernetesResourceSpec) String 

func (x *KubernetesResourceSpec) String() string

type KubernetesVersionSpec 

type KubernetesVersionSpec struct {

	// Version kubernetes version.
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*KubernetesVersionSpec) Descriptor deprecated 

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

Deprecated: Use KubernetesVersionSpec.ProtoReflect.Descriptor instead.

func (*KubernetesVersionSpec) GetVersion 

func (x *KubernetesVersionSpec) GetVersion() string

func (*KubernetesVersionSpec) ProtoMessage 

func (*KubernetesVersionSpec) ProtoMessage()

func (*KubernetesVersionSpec) ProtoReflect 

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

func (*KubernetesVersionSpec) Reset 

func (x *KubernetesVersionSpec) Reset()

func (*KubernetesVersionSpec) String 

func (x *KubernetesVersionSpec) String() string

type ListContextsRequest 

type ListContextsRequest struct {
	// contains filtered or unexported fields
}

func (*ListContextsRequest) Descriptor deprecated 

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

Deprecated: Use ListContextsRequest.ProtoReflect.Descriptor instead.

func (*ListContextsRequest) ProtoMessage 

func (*ListContextsRequest) ProtoMessage()

func (*ListContextsRequest) ProtoReflect 

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

func (*ListContextsRequest) Reset 

func (x *ListContextsRequest) Reset()

func (*ListContextsRequest) String 

func (x *ListContextsRequest) String() string

type ListContextsResponse 

type ListContextsResponse struct {

	// Current is the default context.
	Current string `protobuf:"bytes,1,opt,name=current,proto3" json:"current,omitempty"`
	// Contexts is the list of available local contexts.
	Contexts []*Context `protobuf:"bytes,2,rep,name=contexts,proto3" json:"contexts,omitempty"`
	// contains filtered or unexported fields
}

func (*ListContextsResponse) Descriptor deprecated 

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

Deprecated: Use ListContextsResponse.ProtoReflect.Descriptor instead.

func (*ListContextsResponse) GetContexts 

func (x *ListContextsResponse) GetContexts() []*Context

func (*ListContextsResponse) GetCurrent 

func (x *ListContextsResponse) GetCurrent() string

func (*ListContextsResponse) ProtoMessage 

func (*ListContextsResponse) ProtoMessage()

func (*ListContextsResponse) ProtoReflect 

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

func (*ListContextsResponse) Reset 

func (x *ListContextsResponse) Reset()

func (*ListContextsResponse) String 

func (x *ListContextsResponse) String() string

type ListResponse 

type ListResponse struct {

	// Messages should contain JSON encoded list spec.
	Messages []string `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetMessages 

func (x *ListResponse) GetMessages() []string

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type ManagementServiceClient 

type ManagementServiceClient interface {
	UpgradeInfo(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*UpgradeInfoResponse, 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 {
	UpgradeInfo(context.Context, *emptypb.Empty) (*UpgradeInfoResponse, error)
	// contains filtered or unexported methods
}

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

type ResourceServiceClient 

type ResourceServiceClient interface {
	Get(ctx context.Context, in *resource.GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	List(ctx context.Context, in *resource.ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	GetConfig(ctx context.Context, in *common.Cluster, opts ...grpc.CallOption) (*ConfigResponse, error)
}

ResourceServiceClient is the client API for ResourceService 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 NewResourceServiceClient 

func NewResourceServiceClient(cc grpc.ClientConnInterface) ResourceServiceClient

type ResourceServiceServer 

type ResourceServiceServer interface {
	Get(context.Context, *resource.GetRequest) (*GetResponse, error)
	List(context.Context, *resource.ListRequest) (*ListResponse, error)
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	GetConfig(context.Context, *common.Cluster) (*ConfigResponse, error)
	// contains filtered or unexported methods
}

ResourceServiceServer is the server API for ResourceService service. All implementations must embed UnimplementedResourceServiceServer for forward compatibility

type TaskLogSpec 

type TaskLogSpec struct {

	// Line represents a single log line.
	Line string `protobuf:"bytes,1,opt,name=line,proto3" json:"line,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskLogSpec) Descriptor deprecated 

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

Deprecated: Use TaskLogSpec.ProtoReflect.Descriptor instead.

func (*TaskLogSpec) GetLine 

func (x *TaskLogSpec) GetLine() string

func (*TaskLogSpec) ProtoMessage 

func (*TaskLogSpec) ProtoMessage()

func (*TaskLogSpec) ProtoReflect 

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

func (*TaskLogSpec) Reset 

func (x *TaskLogSpec) Reset()

func (*TaskLogSpec) String 

func (x *TaskLogSpec) String() string

type TaskStateSpec 

type TaskStateSpec struct {

	// StatusID keeps the id for the current task status.
	StatusId string `protobuf:"bytes,4,opt,name=status_id,json=statusId,proto3" json:"status_id,omitempty"`
	// contains filtered or unexported fields
}

Maps the task spec into task status spec.

func (*TaskStateSpec) Descriptor deprecated 

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

Deprecated: Use TaskStateSpec.ProtoReflect.Descriptor instead.

func (*TaskStateSpec) GetStatusId 

func (x *TaskStateSpec) GetStatusId() string

func (*TaskStateSpec) ProtoMessage 

func (*TaskStateSpec) ProtoMessage()

func (*TaskStateSpec) ProtoReflect 

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

func (*TaskStateSpec) Reset 

func (x *TaskStateSpec) Reset()

func (*TaskStateSpec) String 

func (x *TaskStateSpec) String() string

type TaskStatusSpec 

type TaskStatusSpec struct {

	// Upgrade task state.
	Phase TaskStatusSpec_Phase `protobuf:"varint,1,opt,name=phase,proto3,enum=management.TaskStatusSpec_Phase" json:"phase,omitempty"`
	// Progress represents the task progress [0,1].
	Progress float32 `protobuf:"fixed32,2,opt,name=progress,proto3" json:"progress,omitempty"`
	// Failure reason.
	Error string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// K8s version to upgrade from.
	FromVersion string `protobuf:"bytes,4,opt,name=from_version,json=fromVersion,proto3" json:"from_version,omitempty"`
	// K8s version to upgrade to.
	ToVersion string `protobuf:"bytes,5,opt,name=to_version,json=toVersion,proto3" json:"to_version,omitempty"`
	// FinishedAt is when the task either failed or completed.
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskStatusSpec) Descriptor deprecated 

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

Deprecated: Use TaskStatusSpec.ProtoReflect.Descriptor instead.

func (*TaskStatusSpec) GetError 

func (x *TaskStatusSpec) GetError() string

func (*TaskStatusSpec) GetFinishedAt 

func (x *TaskStatusSpec) GetFinishedAt() *timestamppb.Timestamp

func (*TaskStatusSpec) GetFromVersion 

func (x *TaskStatusSpec) GetFromVersion() string

func (*TaskStatusSpec) GetPhase 

func (x *TaskStatusSpec) GetPhase() TaskStatusSpec_Phase

func (*TaskStatusSpec) GetProgress 

func (x *TaskStatusSpec) GetProgress() float32

func (*TaskStatusSpec) GetToVersion 

func (x *TaskStatusSpec) GetToVersion() string

func (*TaskStatusSpec) ProtoMessage 

func (*TaskStatusSpec) ProtoMessage()

func (*TaskStatusSpec) ProtoReflect 

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

func (*TaskStatusSpec) Reset 

func (x *TaskStatusSpec) Reset()

func (*TaskStatusSpec) String 

func (x *TaskStatusSpec) String() string

type TaskStatusSpec_Phase 

type TaskStatusSpec_Phase int32
const (
	TaskStatusSpec_FAILED   TaskStatusSpec_Phase = 0
	TaskStatusSpec_RUNNING  TaskStatusSpec_Phase = 1
	TaskStatusSpec_COMPLETE TaskStatusSpec_Phase = 2
)

func (TaskStatusSpec_Phase) Descriptor 

func (TaskStatusSpec_Phase) Descriptor() protoreflect.EnumDescriptor

func (TaskStatusSpec_Phase) Enum 

func (x TaskStatusSpec_Phase) Enum() *TaskStatusSpec_Phase

func (TaskStatusSpec_Phase) EnumDescriptor deprecated 

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

Deprecated: Use TaskStatusSpec_Phase.Descriptor instead.

func (TaskStatusSpec_Phase) Number 

func (x TaskStatusSpec_Phase) Number() protoreflect.EnumNumber

func (TaskStatusSpec_Phase) String 

func (x TaskStatusSpec_Phase) String() string

func (TaskStatusSpec_Phase) Type 

func (TaskStatusSpec_Phase) Type() protoreflect.EnumType

type UnimplementedContextServiceServer 

type UnimplementedContextServiceServer struct {
}

UnimplementedContextServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedContextServiceServer) List 

func (UnimplementedContextServiceServer) List(context.Context, *ListContextsRequest) (*ListContextsResponse, error)

type UnimplementedManagementServiceServer 

type UnimplementedManagementServiceServer struct {
}

UnimplementedManagementServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedManagementServiceServer) UpgradeInfo 

func (UnimplementedManagementServiceServer) UpgradeInfo(context.Context, *emptypb.Empty) (*UpgradeInfoResponse, error)

type UnimplementedResourceServiceServer 

type UnimplementedResourceServiceServer struct {
}

UnimplementedResourceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedResourceServiceServer) Create 

func (UnimplementedResourceServiceServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

func (UnimplementedResourceServiceServer) Delete 

func (UnimplementedResourceServiceServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)

func (UnimplementedResourceServiceServer) Get 

func (UnimplementedResourceServiceServer) Get(context.Context, *resource.GetRequest) (*GetResponse, error)

func (UnimplementedResourceServiceServer) GetConfig 

func (UnimplementedResourceServiceServer) GetConfig(context.Context, *common.Cluster) (*ConfigResponse, error)

func (UnimplementedResourceServiceServer) List 

func (UnimplementedResourceServiceServer) List(context.Context, *resource.ListRequest) (*ListResponse, error)

func (UnimplementedResourceServiceServer) Update 

func (UnimplementedResourceServiceServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)

type UnsafeContextServiceServer 

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

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

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 UnsafeResourceServiceServer 

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

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

type UpdateRequest 

type UpdateRequest struct {
	CurrentVersion string             `protobuf:"bytes,1,opt,name=currentVersion,proto3" json:"currentVersion,omitempty"`
	Resource       *v1alpha1.Resource `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetCurrentVersion 

func (x *UpdateRequest) GetCurrentVersion() string

func (*UpdateRequest) GetResource 

func (x *UpdateRequest) GetResource() *v1alpha1.Resource

func (*UpdateRequest) ProtoMessage 

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect 

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

func (*UpdateRequest) Reset 

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String 

func (x *UpdateRequest) String() string

type UpdateResponse 

type UpdateResponse struct {
	// contains filtered or unexported fields
}

func (*UpdateResponse) Descriptor deprecated 

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

Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.

func (*UpdateResponse) ProtoMessage 

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) ProtoReflect 

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

func (*UpdateResponse) Reset 

func (x *UpdateResponse) Reset()

func (*UpdateResponse) String 

func (x *UpdateResponse) String() string

type UpgradeInfoResponse 

type UpgradeInfoResponse struct {

	// FromVersion is the lowest detected Kubernetes version.
	FromVersion string `protobuf:"bytes,1,opt,name=from_version,json=fromVersion,proto3" json:"from_version,omitempty"`
	// contains filtered or unexported fields
}

func (*UpgradeInfoResponse) Descriptor deprecated 

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

Deprecated: Use UpgradeInfoResponse.ProtoReflect.Descriptor instead.

func (*UpgradeInfoResponse) GetFromVersion 

func (x *UpgradeInfoResponse) GetFromVersion() string

func (*UpgradeInfoResponse) ProtoMessage 

func (*UpgradeInfoResponse) ProtoMessage()

func (*UpgradeInfoResponse) ProtoReflect 

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

func (*UpgradeInfoResponse) Reset 

func (x *UpgradeInfoResponse) Reset()

func (*UpgradeInfoResponse) String 

func (x *UpgradeInfoResponse) String() string

type UpgradeK8SSpec 

type UpgradeK8SSpec struct {

	// K8s version to upgrade from.
	FromVersion string `protobuf:"bytes,1,opt,name=from_version,json=fromVersion,proto3" json:"from_version,omitempty"`
	// K8s version to upgrade to.
	ToVersion string `protobuf:"bytes,2,opt,name=to_version,json=toVersion,proto3" json:"to_version,omitempty"`
	// Context to use.
	Context *common.Context `protobuf:"bytes,3,opt,name=context,proto3" json:"context,omitempty"`
	// contains filtered or unexported fields
}

func (*UpgradeK8SSpec) Descriptor deprecated 

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

Deprecated: Use UpgradeK8SSpec.ProtoReflect.Descriptor instead.

func (*UpgradeK8SSpec) GetContext 

func (x *UpgradeK8SSpec) GetContext() *common.Context

func (*UpgradeK8SSpec) GetFromVersion 

func (x *UpgradeK8SSpec) GetFromVersion() string

func (*UpgradeK8SSpec) GetToVersion 

func (x *UpgradeK8SSpec) GetToVersion() string

func (*UpgradeK8SSpec) ProtoMessage 

func (*UpgradeK8SSpec) ProtoMessage()

func (*UpgradeK8SSpec) ProtoReflect 

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

func (*UpgradeK8SSpec) Reset 

func (x *UpgradeK8SSpec) Reset()

func (*UpgradeK8SSpec) String 

func (x *UpgradeK8SSpec) String() string

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.