license

package
v2.7.7 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2024 License: Apache-2.0 Imports: 13 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	API_Activate_FullMethodName          = "/license_v2.API/Activate"
	API_GetActivationCode_FullMethodName = "/license_v2.API/GetActivationCode"
	API_DeleteAll_FullMethodName         = "/license_v2.API/DeleteAll"
	API_AddCluster_FullMethodName        = "/license_v2.API/AddCluster"
	API_DeleteCluster_FullMethodName     = "/license_v2.API/DeleteCluster"
	API_ListClusters_FullMethodName      = "/license_v2.API/ListClusters"
	API_UpdateCluster_FullMethodName     = "/license_v2.API/UpdateCluster"
	API_Heartbeat_FullMethodName         = "/license_v2.API/Heartbeat"
	API_ListUserClusters_FullMethodName  = "/license_v2.API/ListUserClusters"
)

Variables

View Source 
var (
	// ErrDuplicateClusterID is thrown when a cluster is registered but the ID already exists
	ErrDuplicateClusterID = status.Error(codes.Unimplemented, "cluster ID is not unique")

	// ErrInvalidIDOrSecret is thrown when the provided cluster ID or secret is not valid
	ErrInvalidIDOrSecret = status.Error(codes.Unimplemented, "cluster ID or secret is not valid")

	// ErrNotActivated is thrown when a cluster does not have an enterprise key activated
	ErrNotActivated = status.Error(codes.Unimplemented, "cluster does not have enterprise features enabled")
)
View Source 
var API_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "license_v2.API",
	HandlerType: (*APIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Activate",
			Handler:    _API_Activate_Handler,
		},
		{
			MethodName: "GetActivationCode",
			Handler:    _API_GetActivationCode_Handler,
		},
		{
			MethodName: "DeleteAll",
			Handler:    _API_DeleteAll_Handler,
		},
		{
			MethodName: "AddCluster",
			Handler:    _API_AddCluster_Handler,
		},
		{
			MethodName: "DeleteCluster",
			Handler:    _API_DeleteCluster_Handler,
		},
		{
			MethodName: "ListClusters",
			Handler:    _API_ListClusters_Handler,
		},
		{
			MethodName: "UpdateCluster",
			Handler:    _API_UpdateCluster_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _API_Heartbeat_Handler,
		},
		{
			MethodName: "ListUserClusters",
			Handler:    _API_ListUserClusters_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "license/license.proto",
}

API_ServiceDesc is the grpc.ServiceDesc for API 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_license_license_proto protoreflect.FileDescriptor

Functions

func IsErrDuplicateClusterID 

func IsErrDuplicateClusterID(err error) bool

IsErrDuplicateClusterID checks if an error is an ErrDuplicateClusterID

func IsErrInvalidIDOrSecret 

func IsErrInvalidIDOrSecret(err error) bool

IsErrInvalidIDOrSecret checks if an error is an ErrInvalidIDOrSecret

func IsErrNotActivated 

func IsErrNotActivated(err error) bool

IsErrNotActivated checks if an error is an ErrNotActivated

func RegisterAPIServer 

func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)

Types

type APIClient 

type APIClient interface {
	// Activate enables the license service by setting the enterprise activation
	// code to serve.
	Activate(ctx context.Context, in *ActivateRequest, opts ...grpc.CallOption) (*ActivateResponse, error)
	GetActivationCode(ctx context.Context, in *GetActivationCodeRequest, opts ...grpc.CallOption) (*GetActivationCodeResponse, error)
	// DeleteAll deactivates the server and removes all data.
	DeleteAll(ctx context.Context, in *DeleteAllRequest, opts ...grpc.CallOption) (*DeleteAllResponse, error)
	// CRUD operations for the pachds registered with this server.
	AddCluster(ctx context.Context, in *AddClusterRequest, opts ...grpc.CallOption) (*AddClusterResponse, error)
	DeleteCluster(ctx context.Context, in *DeleteClusterRequest, opts ...grpc.CallOption) (*DeleteClusterResponse, error)
	ListClusters(ctx context.Context, in *ListClustersRequest, opts ...grpc.CallOption) (*ListClustersResponse, error)
	UpdateCluster(ctx context.Context, in *UpdateClusterRequest, opts ...grpc.CallOption) (*UpdateClusterResponse, error)
	// Heartbeat is the RPC registered pachds make to the license server
	// to communicate their status and fetch updates.
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	// Lists all clusters available to user
	ListUserClusters(ctx context.Context, in *ListUserClustersRequest, opts ...grpc.CallOption) (*ListUserClustersResponse, error)
}

APIClient is the client API for API 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 NewAPIClient 

func NewAPIClient(cc grpc.ClientConnInterface) APIClient

type APIServer 

type APIServer interface {
	// Activate enables the license service by setting the enterprise activation
	// code to serve.
	Activate(context.Context, *ActivateRequest) (*ActivateResponse, error)
	GetActivationCode(context.Context, *GetActivationCodeRequest) (*GetActivationCodeResponse, error)
	// DeleteAll deactivates the server and removes all data.
	DeleteAll(context.Context, *DeleteAllRequest) (*DeleteAllResponse, error)
	// CRUD operations for the pachds registered with this server.
	AddCluster(context.Context, *AddClusterRequest) (*AddClusterResponse, error)
	DeleteCluster(context.Context, *DeleteClusterRequest) (*DeleteClusterResponse, error)
	ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)
	UpdateCluster(context.Context, *UpdateClusterRequest) (*UpdateClusterResponse, error)
	// Heartbeat is the RPC registered pachds make to the license server
	// to communicate their status and fetch updates.
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	// Lists all clusters available to user
	ListUserClusters(context.Context, *ListUserClustersRequest) (*ListUserClustersResponse, error)
	// contains filtered or unexported methods
}

APIServer is the server API for API service. All implementations must embed UnimplementedAPIServer for forward compatibility

type ActivateRequest 

type ActivateRequest struct {

	// activation_code is a Pachyderm enterprise activation code. New users can
	// obtain trial activation codes
	ActivationCode string `protobuf:"bytes,1,opt,name=activation_code,json=activationCode,proto3" json:"activation_code,omitempty"`
	// expires is a timestamp indicating when this activation code will expire.
	// This should not generally be set (it's primarily used for testing), and is
	// only applied if it's earlier than the signed expiration time in
	// 'activation_code'.
	Expires *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires,proto3" json:"expires,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivateRequest) Descriptor deprecated 

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

Deprecated: Use ActivateRequest.ProtoReflect.Descriptor instead.

func (*ActivateRequest) GetActivationCode 

func (x *ActivateRequest) GetActivationCode() string

func (*ActivateRequest) GetExpires 

func (x *ActivateRequest) GetExpires() *timestamppb.Timestamp

func (*ActivateRequest) MarshalLogObject 

func (x *ActivateRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ActivateRequest) ProtoMessage 

func (*ActivateRequest) ProtoMessage()

func (*ActivateRequest) ProtoReflect added in v2.7.0 

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

func (*ActivateRequest) Reset 

func (x *ActivateRequest) Reset()

func (*ActivateRequest) String 

func (x *ActivateRequest) String() string

type ActivateResponse 

type ActivateResponse struct {
	Info *enterprise.TokenInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*ActivateResponse) Descriptor deprecated 

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

Deprecated: Use ActivateResponse.ProtoReflect.Descriptor instead.

func (*ActivateResponse) GetInfo 

func (x *ActivateResponse) GetInfo() *enterprise.TokenInfo

func (*ActivateResponse) MarshalLogObject 

func (x *ActivateResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ActivateResponse) ProtoMessage 

func (*ActivateResponse) ProtoMessage()

func (*ActivateResponse) ProtoReflect added in v2.7.0 

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

func (*ActivateResponse) Reset 

func (x *ActivateResponse) Reset()

func (*ActivateResponse) String 

func (x *ActivateResponse) String() string

type AddClusterRequest 

type AddClusterRequest struct {

	// id is the unique, immutable identifier for this cluster
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// address is the public GPRC address where the cluster can be reached
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// If set, secret specifies the shared secret this cluster will use
	// to authenticate to the license server. Otherwise a secret will be
	// generated and returned in the response.
	Secret string `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
	// The pachd address for users to connect to.
	UserAddress string `protobuf:"bytes,4,opt,name=user_address,json=userAddress,proto3" json:"user_address,omitempty"`
	// The deployment ID value generated by each Cluster
	ClusterDeploymentId string `protobuf:"bytes,5,opt,name=cluster_deployment_id,json=clusterDeploymentId,proto3" json:"cluster_deployment_id,omitempty"`
	// This field indicates whether the address points to an enterprise server
	EnterpriseServer bool `protobuf:"varint,6,opt,name=enterprise_server,json=enterpriseServer,proto3" json:"enterprise_server,omitempty"`
	// contains filtered or unexported fields
}

func (*AddClusterRequest) Descriptor deprecated 

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

Deprecated: Use AddClusterRequest.ProtoReflect.Descriptor instead.

func (*AddClusterRequest) GetAddress 

func (x *AddClusterRequest) GetAddress() string

func (*AddClusterRequest) GetClusterDeploymentId 

func (x *AddClusterRequest) GetClusterDeploymentId() string

func (*AddClusterRequest) GetEnterpriseServer 

func (x *AddClusterRequest) GetEnterpriseServer() bool

func (*AddClusterRequest) GetId 

func (x *AddClusterRequest) GetId() string

func (*AddClusterRequest) GetSecret 

func (x *AddClusterRequest) GetSecret() string

func (*AddClusterRequest) GetUserAddress 

func (x *AddClusterRequest) GetUserAddress() string

func (*AddClusterRequest) MarshalLogObject 

func (x *AddClusterRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*AddClusterRequest) ProtoMessage 

func (*AddClusterRequest) ProtoMessage()

func (*AddClusterRequest) ProtoReflect added in v2.7.0 

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

func (*AddClusterRequest) Reset 

func (x *AddClusterRequest) Reset()

func (*AddClusterRequest) String 

func (x *AddClusterRequest) String() string

type AddClusterResponse 

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

func (*AddClusterResponse) Descriptor deprecated 

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

Deprecated: Use AddClusterResponse.ProtoReflect.Descriptor instead.

func (*AddClusterResponse) GetSecret 

func (x *AddClusterResponse) GetSecret() string

func (*AddClusterResponse) MarshalLogObject 

func (x *AddClusterResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*AddClusterResponse) ProtoMessage 

func (*AddClusterResponse) ProtoMessage()

func (*AddClusterResponse) ProtoReflect added in v2.7.0 

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

func (*AddClusterResponse) Reset 

func (x *AddClusterResponse) Reset()

func (*AddClusterResponse) String 

func (x *AddClusterResponse) String() string

type ClusterStatus 

type ClusterStatus struct {
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address       string                 `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Version       string                 `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	AuthEnabled   bool                   `protobuf:"varint,4,opt,name=auth_enabled,json=authEnabled,proto3" json:"auth_enabled,omitempty"`
	ClientId      string                 `protobuf:"bytes,7,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	LastHeartbeat *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_heartbeat,json=lastHeartbeat,proto3" json:"last_heartbeat,omitempty"`
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*ClusterStatus) Descriptor deprecated 

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

Deprecated: Use ClusterStatus.ProtoReflect.Descriptor instead.

func (*ClusterStatus) GetAddress 

func (x *ClusterStatus) GetAddress() string

func (*ClusterStatus) GetAuthEnabled 

func (x *ClusterStatus) GetAuthEnabled() bool

func (*ClusterStatus) GetClientId 

func (x *ClusterStatus) GetClientId() string

func (*ClusterStatus) GetCreatedAt 

func (x *ClusterStatus) GetCreatedAt() *timestamppb.Timestamp

func (*ClusterStatus) GetId 

func (x *ClusterStatus) GetId() string

func (*ClusterStatus) GetLastHeartbeat 

func (x *ClusterStatus) GetLastHeartbeat() *timestamppb.Timestamp

func (*ClusterStatus) GetVersion 

func (x *ClusterStatus) GetVersion() string

func (*ClusterStatus) MarshalLogObject 

func (x *ClusterStatus) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ClusterStatus) ProtoMessage 

func (*ClusterStatus) ProtoMessage()

func (*ClusterStatus) ProtoReflect added in v2.7.0 

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

func (*ClusterStatus) Reset 

func (x *ClusterStatus) Reset()

func (*ClusterStatus) String 

func (x *ClusterStatus) String() string

type DeactivateRequest 

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

func (*DeactivateRequest) Descriptor deprecated 

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

Deprecated: Use DeactivateRequest.ProtoReflect.Descriptor instead.

func (*DeactivateRequest) MarshalLogObject 

func (x *DeactivateRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeactivateRequest) ProtoMessage 

func (*DeactivateRequest) ProtoMessage()

func (*DeactivateRequest) ProtoReflect added in v2.7.0 

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

func (*DeactivateRequest) Reset 

func (x *DeactivateRequest) Reset()

func (*DeactivateRequest) String 

func (x *DeactivateRequest) String() string

type DeactivateResponse 

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

func (*DeactivateResponse) Descriptor deprecated 

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

Deprecated: Use DeactivateResponse.ProtoReflect.Descriptor instead.

func (*DeactivateResponse) MarshalLogObject 

func (x *DeactivateResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeactivateResponse) ProtoMessage 

func (*DeactivateResponse) ProtoMessage()

func (*DeactivateResponse) ProtoReflect added in v2.7.0 

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

func (*DeactivateResponse) Reset 

func (x *DeactivateResponse) Reset()

func (*DeactivateResponse) String 

func (x *DeactivateResponse) String() string

type DeleteAllRequest 

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

func (*DeleteAllRequest) Descriptor deprecated 

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

Deprecated: Use DeleteAllRequest.ProtoReflect.Descriptor instead.

func (*DeleteAllRequest) MarshalLogObject 

func (x *DeleteAllRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeleteAllRequest) ProtoMessage 

func (*DeleteAllRequest) ProtoMessage()

func (*DeleteAllRequest) ProtoReflect added in v2.7.0 

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

func (*DeleteAllRequest) Reset 

func (x *DeleteAllRequest) Reset()

func (*DeleteAllRequest) String 

func (x *DeleteAllRequest) String() string

type DeleteAllResponse 

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

func (*DeleteAllResponse) Descriptor deprecated 

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

Deprecated: Use DeleteAllResponse.ProtoReflect.Descriptor instead.

func (*DeleteAllResponse) MarshalLogObject 

func (x *DeleteAllResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeleteAllResponse) ProtoMessage 

func (*DeleteAllResponse) ProtoMessage()

func (*DeleteAllResponse) ProtoReflect added in v2.7.0 

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

func (*DeleteAllResponse) Reset 

func (x *DeleteAllResponse) Reset()

func (*DeleteAllResponse) String 

func (x *DeleteAllResponse) String() string

type DeleteClusterRequest 

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

func (*DeleteClusterRequest) Descriptor deprecated 

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

Deprecated: Use DeleteClusterRequest.ProtoReflect.Descriptor instead.

func (*DeleteClusterRequest) GetId 

func (x *DeleteClusterRequest) GetId() string

func (*DeleteClusterRequest) MarshalLogObject 

func (x *DeleteClusterRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeleteClusterRequest) ProtoMessage 

func (*DeleteClusterRequest) ProtoMessage()

func (*DeleteClusterRequest) ProtoReflect added in v2.7.0 

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

func (*DeleteClusterRequest) Reset 

func (x *DeleteClusterRequest) Reset()

func (*DeleteClusterRequest) String 

func (x *DeleteClusterRequest) String() string

type DeleteClusterResponse 

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

func (*DeleteClusterResponse) Descriptor deprecated 

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

Deprecated: Use DeleteClusterResponse.ProtoReflect.Descriptor instead.

func (*DeleteClusterResponse) MarshalLogObject 

func (x *DeleteClusterResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*DeleteClusterResponse) ProtoMessage 

func (*DeleteClusterResponse) ProtoMessage()

func (*DeleteClusterResponse) ProtoReflect added in v2.7.0 

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

func (*DeleteClusterResponse) Reset 

func (x *DeleteClusterResponse) Reset()

func (*DeleteClusterResponse) String 

func (x *DeleteClusterResponse) String() string

type GetActivationCodeRequest 

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

func (*GetActivationCodeRequest) Descriptor deprecated 

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

Deprecated: Use GetActivationCodeRequest.ProtoReflect.Descriptor instead.

func (*GetActivationCodeRequest) MarshalLogObject 

func (x *GetActivationCodeRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*GetActivationCodeRequest) ProtoMessage 

func (*GetActivationCodeRequest) ProtoMessage()

func (*GetActivationCodeRequest) ProtoReflect added in v2.7.0 

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

func (*GetActivationCodeRequest) Reset 

func (x *GetActivationCodeRequest) Reset()

func (*GetActivationCodeRequest) String 

func (x *GetActivationCodeRequest) String() string

type GetActivationCodeResponse 

type GetActivationCodeResponse struct {
	State          enterprise.State      `protobuf:"varint,1,opt,name=state,proto3,enum=enterprise_v2.State" json:"state,omitempty"`
	Info           *enterprise.TokenInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	ActivationCode string                `protobuf:"bytes,3,opt,name=activation_code,json=activationCode,proto3" json:"activation_code,omitempty"`
	// contains filtered or unexported fields
}

func (*GetActivationCodeResponse) Descriptor deprecated 

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

Deprecated: Use GetActivationCodeResponse.ProtoReflect.Descriptor instead.

func (*GetActivationCodeResponse) GetActivationCode 

func (x *GetActivationCodeResponse) GetActivationCode() string

func (*GetActivationCodeResponse) GetInfo 

func (x *GetActivationCodeResponse) GetInfo() *enterprise.TokenInfo

func (*GetActivationCodeResponse) GetState 

func (x *GetActivationCodeResponse) GetState() enterprise.State

func (*GetActivationCodeResponse) MarshalLogObject 

func (x *GetActivationCodeResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*GetActivationCodeResponse) ProtoMessage 

func (*GetActivationCodeResponse) ProtoMessage()

func (*GetActivationCodeResponse) ProtoReflect added in v2.7.0 

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

func (*GetActivationCodeResponse) Reset 

func (x *GetActivationCodeResponse) Reset()

func (*GetActivationCodeResponse) String 

func (x *GetActivationCodeResponse) String() string

type HeartbeatRequest 

type HeartbeatRequest struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Secret      string `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	Version     string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	AuthEnabled bool   `protobuf:"varint,4,opt,name=auth_enabled,json=authEnabled,proto3" json:"auth_enabled,omitempty"`
	ClientId    string `protobuf:"bytes,5,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetAuthEnabled 

func (x *HeartbeatRequest) GetAuthEnabled() bool

func (*HeartbeatRequest) GetClientId 

func (x *HeartbeatRequest) GetClientId() string

func (*HeartbeatRequest) GetId 

func (x *HeartbeatRequest) GetId() string

func (*HeartbeatRequest) GetSecret 

func (x *HeartbeatRequest) GetSecret() string

func (*HeartbeatRequest) GetVersion 

func (x *HeartbeatRequest) GetVersion() string

func (*HeartbeatRequest) MarshalLogObject 

func (x *HeartbeatRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect added in v2.7.0 

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

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type HeartbeatResponse 

type HeartbeatResponse struct {
	License *enterprise.LicenseRecord `protobuf:"bytes,1,opt,name=license,proto3" json:"license,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) GetLicense 

func (x *HeartbeatResponse) GetLicense() *enterprise.LicenseRecord

func (*HeartbeatResponse) MarshalLogObject 

func (x *HeartbeatResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect added in v2.7.0 

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

func (*HeartbeatResponse) Reset 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (x *HeartbeatResponse) String() string

type ListClustersRequest 

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

func (*ListClustersRequest) Descriptor deprecated 

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

Deprecated: Use ListClustersRequest.ProtoReflect.Descriptor instead.

func (*ListClustersRequest) MarshalLogObject 

func (x *ListClustersRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListClustersRequest) ProtoMessage 

func (*ListClustersRequest) ProtoMessage()

func (*ListClustersRequest) ProtoReflect added in v2.7.0 

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

func (*ListClustersRequest) Reset 

func (x *ListClustersRequest) Reset()

func (*ListClustersRequest) String 

func (x *ListClustersRequest) String() string

type ListClustersResponse 

type ListClustersResponse struct {
	Clusters []*ClusterStatus `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClustersResponse) Descriptor deprecated 

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

Deprecated: Use ListClustersResponse.ProtoReflect.Descriptor instead.

func (*ListClustersResponse) GetClusters 

func (x *ListClustersResponse) GetClusters() []*ClusterStatus

func (*ListClustersResponse) MarshalLogObject 

func (x *ListClustersResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListClustersResponse) ProtoMessage 

func (*ListClustersResponse) ProtoMessage()

func (*ListClustersResponse) ProtoReflect added in v2.7.0 

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

func (*ListClustersResponse) Reset 

func (x *ListClustersResponse) Reset()

func (*ListClustersResponse) String 

func (x *ListClustersResponse) String() string

type ListUserClustersRequest 

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

func (*ListUserClustersRequest) Descriptor deprecated 

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

Deprecated: Use ListUserClustersRequest.ProtoReflect.Descriptor instead.

func (*ListUserClustersRequest) MarshalLogObject 

func (x *ListUserClustersRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListUserClustersRequest) ProtoMessage 

func (*ListUserClustersRequest) ProtoMessage()

func (*ListUserClustersRequest) ProtoReflect added in v2.7.0 

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

func (*ListUserClustersRequest) Reset 

func (x *ListUserClustersRequest) Reset()

func (*ListUserClustersRequest) String 

func (x *ListUserClustersRequest) String() string

type ListUserClustersResponse 

type ListUserClustersResponse struct {
	Clusters []*UserClusterInfo `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// contains filtered or unexported fields
}

func (*ListUserClustersResponse) Descriptor deprecated 

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

Deprecated: Use ListUserClustersResponse.ProtoReflect.Descriptor instead.

func (*ListUserClustersResponse) GetClusters 

func (x *ListUserClustersResponse) GetClusters() []*UserClusterInfo

func (*ListUserClustersResponse) MarshalLogObject 

func (x *ListUserClustersResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListUserClustersResponse) ProtoMessage 

func (*ListUserClustersResponse) ProtoMessage()

func (*ListUserClustersResponse) ProtoReflect added in v2.7.0 

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

func (*ListUserClustersResponse) Reset 

func (x *ListUserClustersResponse) Reset()

func (*ListUserClustersResponse) String 

func (x *ListUserClustersResponse) String() string

type UnimplementedAPIServer 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer must be embedded to have forward compatible implementations.

func (UnimplementedAPIServer) Activate 

func (UnimplementedAPIServer) Activate(context.Context, *ActivateRequest) (*ActivateResponse, error)

func (UnimplementedAPIServer) AddCluster 

func (UnimplementedAPIServer) AddCluster(context.Context, *AddClusterRequest) (*AddClusterResponse, error)

func (UnimplementedAPIServer) DeleteAll 

func (UnimplementedAPIServer) DeleteAll(context.Context, *DeleteAllRequest) (*DeleteAllResponse, error)

func (UnimplementedAPIServer) DeleteCluster 

func (UnimplementedAPIServer) DeleteCluster(context.Context, *DeleteClusterRequest) (*DeleteClusterResponse, error)

func (UnimplementedAPIServer) GetActivationCode 

func (UnimplementedAPIServer) GetActivationCode(context.Context, *GetActivationCodeRequest) (*GetActivationCodeResponse, error)

func (UnimplementedAPIServer) Heartbeat 

func (UnimplementedAPIServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)

func (UnimplementedAPIServer) ListClusters 

func (UnimplementedAPIServer) ListClusters(context.Context, *ListClustersRequest) (*ListClustersResponse, error)

func (UnimplementedAPIServer) ListUserClusters 

func (UnimplementedAPIServer) ListUserClusters(context.Context, *ListUserClustersRequest) (*ListUserClustersResponse, error)

func (UnimplementedAPIServer) UpdateCluster 

func (UnimplementedAPIServer) UpdateCluster(context.Context, *UpdateClusterRequest) (*UpdateClusterResponse, error)

type UnsafeAPIServer added in v2.7.0 

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

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

type UpdateClusterRequest 

type UpdateClusterRequest struct {
	Id                  string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address             string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	UserAddress         string `protobuf:"bytes,3,opt,name=user_address,json=userAddress,proto3" json:"user_address,omitempty"`
	ClusterDeploymentId string `protobuf:"bytes,4,opt,name=cluster_deployment_id,json=clusterDeploymentId,proto3" json:"cluster_deployment_id,omitempty"`
	Secret              string `protobuf:"bytes,5,opt,name=secret,proto3" json:"secret,omitempty"`
	// contains filtered or unexported fields
}

Note: Updates of the enterprise-server field are not allowed. In the worst case, a user can recreate their cluster if they need the field updated.

func (*UpdateClusterRequest) Descriptor deprecated 

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

Deprecated: Use UpdateClusterRequest.ProtoReflect.Descriptor instead.

func (*UpdateClusterRequest) GetAddress 

func (x *UpdateClusterRequest) GetAddress() string

func (*UpdateClusterRequest) GetClusterDeploymentId 

func (x *UpdateClusterRequest) GetClusterDeploymentId() string

func (*UpdateClusterRequest) GetId 

func (x *UpdateClusterRequest) GetId() string

func (*UpdateClusterRequest) GetSecret 

func (x *UpdateClusterRequest) GetSecret() string

func (*UpdateClusterRequest) GetUserAddress 

func (x *UpdateClusterRequest) GetUserAddress() string

func (*UpdateClusterRequest) MarshalLogObject 

func (x *UpdateClusterRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*UpdateClusterRequest) ProtoMessage 

func (*UpdateClusterRequest) ProtoMessage()

func (*UpdateClusterRequest) ProtoReflect added in v2.7.0 

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

func (*UpdateClusterRequest) Reset 

func (x *UpdateClusterRequest) Reset()

func (*UpdateClusterRequest) String 

func (x *UpdateClusterRequest) String() string

type UpdateClusterResponse 

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

func (*UpdateClusterResponse) Descriptor deprecated 

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

Deprecated: Use UpdateClusterResponse.ProtoReflect.Descriptor instead.

func (*UpdateClusterResponse) MarshalLogObject 

func (x *UpdateClusterResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*UpdateClusterResponse) ProtoMessage 

func (*UpdateClusterResponse) ProtoMessage()

func (*UpdateClusterResponse) ProtoReflect added in v2.7.0 

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

func (*UpdateClusterResponse) Reset 

func (x *UpdateClusterResponse) Reset()

func (*UpdateClusterResponse) String 

func (x *UpdateClusterResponse) String() string

type UserClusterInfo 

type UserClusterInfo struct {
	Id                  string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ClusterDeploymentId string `protobuf:"bytes,2,opt,name=cluster_deployment_id,json=clusterDeploymentId,proto3" json:"cluster_deployment_id,omitempty"`
	Address             string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	EnterpriseServer    bool   `protobuf:"varint,4,opt,name=enterprise_server,json=enterpriseServer,proto3" json:"enterprise_server,omitempty"`
	// contains filtered or unexported fields
}

func (*UserClusterInfo) Descriptor deprecated 

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

Deprecated: Use UserClusterInfo.ProtoReflect.Descriptor instead.

func (*UserClusterInfo) GetAddress 

func (x *UserClusterInfo) GetAddress() string

func (*UserClusterInfo) GetClusterDeploymentId 

func (x *UserClusterInfo) GetClusterDeploymentId() string

func (*UserClusterInfo) GetEnterpriseServer 

func (x *UserClusterInfo) GetEnterpriseServer() bool

func (*UserClusterInfo) GetId 

func (x *UserClusterInfo) GetId() string

func (*UserClusterInfo) MarshalLogObject 

func (x *UserClusterInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*UserClusterInfo) ProtoMessage 

func (*UserClusterInfo) ProtoMessage()

func (*UserClusterInfo) ProtoReflect added in v2.7.0 

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

func (*UserClusterInfo) Reset 

func (x *UserClusterInfo) Reset()

func (*UserClusterInfo) String 

func (x *UserClusterInfo) 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.