Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

rpc

package

Go to main page

Versions in this module

v0

v0.2.1

Apr 8, 2022

v0.2.0

Mar 30, 2022

Changes in this version

+ var ContextService_ServiceDesc = grpc.ServiceDesc

+ var File_rpc_context_proto protoreflect.FileDescriptor

+ var File_rpc_management_proto protoreflect.FileDescriptor

+ var File_rpc_resource_proto protoreflect.FileDescriptor

+ var ManagementService_ServiceDesc = grpc.ServiceDesc

+ var ResourceService_ServiceDesc = grpc.ServiceDesc

+ var TaskStatusSpec_Phase_name = map[int32]string

+ var TaskStatusSpec_Phase_value = map[string]int32

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

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

+ func RegisterContextServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterContextServiceServer(s grpc.ServiceRegistrar, srv ContextServiceServer)

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

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

+ func RegisterManagementServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterManagementServiceServer(s grpc.ServiceRegistrar, srv ManagementServiceServer)

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

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

+ func RegisterResourceServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterResourceServiceServer(s grpc.ServiceRegistrar, srv ResourceServiceServer)

+ type ConfigResponse struct

+ Data string

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

+ func (*ConfigResponse) ProtoMessage()

+ func (x *ConfigResponse) GetData() string

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

+ func (x *ConfigResponse) Reset()

+ func (x *ConfigResponse) String() string

+ type Context struct

+ Cluster string

+ Name string

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

+ func (*Context) ProtoMessage()

+ func (x *Context) GetCluster() string

+ func (x *Context) GetName() string

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

+ func (x *Context) Reset()

+ func (x *Context) String() string

+ type ContextServiceClient interface

+ List func(ctx context.Context, in *ListContextsRequest, opts ...grpc.CallOption) (*ListContextsResponse, error)

+ func NewContextServiceClient(cc grpc.ClientConnInterface) ContextServiceClient

+ type ContextServiceServer interface

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

+ type CreateRequest struct

+ Resource *v1alpha1.Resource

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

+ func (*CreateRequest) ProtoMessage()

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

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

+ func (x *CreateRequest) Reset()

+ func (x *CreateRequest) String() string

+ type CreateResponse struct

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

+ func (*CreateResponse) ProtoMessage()

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

+ func (x *CreateResponse) Reset()

+ func (x *CreateResponse) String() string

+ type DeleteRequest struct

+ Id string

+ Namespace string

+ Type string

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

+ func (*DeleteRequest) ProtoMessage()

+ func (x *DeleteRequest) GetId() string

+ func (x *DeleteRequest) GetNamespace() string

+ func (x *DeleteRequest) GetType() string

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

+ func (x *DeleteRequest) Reset()

+ func (x *DeleteRequest) String() string

+ type DeleteResponse struct

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

+ func (*DeleteResponse) ProtoMessage()

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

+ func (x *DeleteResponse) Reset()

+ func (x *DeleteResponse) String() string

+ type GetResponse struct

+ Body string

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

+ func (*GetResponse) ProtoMessage()

+ func (x *GetResponse) GetBody() string

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

+ func (x *GetResponse) Reset()

+ func (x *GetResponse) String() string

+ type KubernetesResourceSpec struct

+ Spec string

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

+ func (*KubernetesResourceSpec) ProtoMessage()

+ func (x *KubernetesResourceSpec) GetSpec() string

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

+ func (x *KubernetesResourceSpec) Reset()

+ func (x *KubernetesResourceSpec) String() string

+ type KubernetesVersionSpec struct

+ Version string

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

+ func (*KubernetesVersionSpec) ProtoMessage()

+ func (x *KubernetesVersionSpec) GetVersion() string

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

+ func (x *KubernetesVersionSpec) Reset()

+ func (x *KubernetesVersionSpec) String() string

+ type ListContextsRequest struct

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

+ func (*ListContextsRequest) ProtoMessage()

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

+ func (x *ListContextsRequest) Reset()

+ func (x *ListContextsRequest) String() string

+ type ListContextsResponse struct

+ Contexts []*Context

+ Current string

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

+ func (*ListContextsResponse) ProtoMessage()

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

+ func (x *ListContextsResponse) GetCurrent() string

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

+ func (x *ListContextsResponse) Reset()

+ func (x *ListContextsResponse) String() string

+ type ListResponse struct

+ Messages []string

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

+ func (*ListResponse) ProtoMessage()

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

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

+ func (x *ListResponse) Reset()

+ func (x *ListResponse) String() string

+ type ManagementServiceClient interface

+ UpgradeInfo func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*UpgradeInfoResponse, error)

+ func NewManagementServiceClient(cc grpc.ClientConnInterface) ManagementServiceClient

+ type ManagementServiceServer interface

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

+ type ResourceServiceClient interface

+ Create func(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)

+ Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)

+ Get func(ctx context.Context, in *resource.GetRequest, opts ...grpc.CallOption) (*GetResponse, error)

+ GetConfig func(ctx context.Context, in *common.Cluster, opts ...grpc.CallOption) (*ConfigResponse, error)

+ List func(ctx context.Context, in *resource.ListRequest, opts ...grpc.CallOption) (*ListResponse, error)

+ Update func(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error)

+ func NewResourceServiceClient(cc grpc.ClientConnInterface) ResourceServiceClient

+ type ResourceServiceServer interface

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

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

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

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

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

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

+ type TaskLogSpec struct

+ Line string

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

+ func (*TaskLogSpec) ProtoMessage()

+ func (x *TaskLogSpec) GetLine() string

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

+ func (x *TaskLogSpec) Reset()

+ func (x *TaskLogSpec) String() string

+ type TaskStateSpec struct

+ StatusId string

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

+ func (*TaskStateSpec) ProtoMessage()

+ func (x *TaskStateSpec) GetStatusId() string

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

+ func (x *TaskStateSpec) Reset()

+ func (x *TaskStateSpec) String() string

+ type TaskStatusSpec struct

+ Error string

+ FinishedAt *timestamppb.Timestamp

+ FromVersion string

+ Phase TaskStatusSpec_Phase

+ Progress float32

+ ToVersion string

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

+ func (*TaskStatusSpec) ProtoMessage()

+ func (x *TaskStatusSpec) GetError() string

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

+ func (x *TaskStatusSpec) GetFromVersion() string

+ func (x *TaskStatusSpec) GetPhase() TaskStatusSpec_Phase

+ func (x *TaskStatusSpec) GetProgress() float32

+ func (x *TaskStatusSpec) GetToVersion() string

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

+ func (x *TaskStatusSpec) Reset()

+ func (x *TaskStatusSpec) String() string

+ type TaskStatusSpec_Phase int32

+ const TaskStatusSpec_COMPLETE

+ const TaskStatusSpec_FAILED

+ const TaskStatusSpec_RUNNING

+ func (TaskStatusSpec_Phase) Descriptor() protoreflect.EnumDescriptor

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

+ func (TaskStatusSpec_Phase) Type() protoreflect.EnumType

+ func (x TaskStatusSpec_Phase) Enum() *TaskStatusSpec_Phase

+ func (x TaskStatusSpec_Phase) Number() protoreflect.EnumNumber

+ func (x TaskStatusSpec_Phase) String() string

+ type UnimplementedContextServiceServer struct

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

+ type UnimplementedManagementServiceServer struct

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

+ type UnimplementedResourceServiceServer struct

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

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

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

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

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

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

+ type UnsafeContextServiceServer interface

+ type UnsafeManagementServiceServer interface

+ type UnsafeResourceServiceServer interface

+ type UpdateRequest struct

+ CurrentVersion string

+ Resource *v1alpha1.Resource

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

+ func (*UpdateRequest) ProtoMessage()

+ func (x *UpdateRequest) GetCurrentVersion() string

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

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

+ func (x *UpdateRequest) Reset()

+ func (x *UpdateRequest) String() string

+ type UpdateResponse struct

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

+ func (*UpdateResponse) ProtoMessage()

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

+ func (x *UpdateResponse) Reset()

+ func (x *UpdateResponse) String() string

+ type UpgradeInfoResponse struct

+ FromVersion string

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

+ func (*UpgradeInfoResponse) ProtoMessage()

+ func (x *UpgradeInfoResponse) GetFromVersion() string

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

+ func (x *UpgradeInfoResponse) Reset()

+ func (x *UpgradeInfoResponse) String() string

+ type UpgradeK8SSpec struct

+ Context *common.Context

+ FromVersion string

+ ToVersion string

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

+ func (*UpgradeK8SSpec) ProtoMessage()

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

+ func (x *UpgradeK8SSpec) GetFromVersion() string

+ func (x *UpgradeK8SSpec) GetToVersion() string

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

+ func (x *UpgradeK8SSpec) Reset()

+ func (x *UpgradeK8SSpec) String() string

v0.2.0-alpha.0

Mar 24, 2022