Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)
- type APIClient
- type APIServer
- type ActivateRequest
- func (*ActivateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ActivateRequest) GetId() string
- func (x *ActivateRequest) GetLicenseServer() string
- func (x *ActivateRequest) GetSecret() string
- func (x *ActivateRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ActivateRequest) ProtoMessage()
- func (x *ActivateRequest) ProtoReflect() protoreflect.Message
- func (x *ActivateRequest) Reset()
- func (x *ActivateRequest) String() string
- type ActivateResponse
- func (*ActivateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ActivateResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ActivateResponse) ProtoMessage()
- func (x *ActivateResponse) ProtoReflect() protoreflect.Message
- func (x *ActivateResponse) Reset()
- func (x *ActivateResponse) String() string
- type DeactivateRequest
- func (*DeactivateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeactivateRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*DeactivateRequest) ProtoMessage()
- func (x *DeactivateRequest) ProtoReflect() protoreflect.Message
- func (x *DeactivateRequest) Reset()
- func (x *DeactivateRequest) String() string
- type DeactivateResponse
- func (*DeactivateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeactivateResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*DeactivateResponse) ProtoMessage()
- func (x *DeactivateResponse) ProtoReflect() protoreflect.Message
- func (x *DeactivateResponse) Reset()
- func (x *DeactivateResponse) String() string
- type EnterpriseConfig
- func (*EnterpriseConfig) Descriptor() ([]byte, []int)deprecated
- func (x *EnterpriseConfig) GetId() string
- func (x *EnterpriseConfig) GetLicenseServer() string
- func (x *EnterpriseConfig) GetSecret() string
- func (x *EnterpriseConfig) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*EnterpriseConfig) ProtoMessage()
- func (x *EnterpriseConfig) ProtoReflect() protoreflect.Message
- func (x *EnterpriseConfig) Reset()
- func (x *EnterpriseConfig) String() string
- type EnterpriseRecord
- func (*EnterpriseRecord) Descriptor() ([]byte, []int)deprecated
- func (x *EnterpriseRecord) GetHeartbeatFailed() bool
- func (x *EnterpriseRecord) GetLastHeartbeat() *timestamppb.Timestamp
- func (x *EnterpriseRecord) GetLicense() *LicenseRecord
- func (x *EnterpriseRecord) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*EnterpriseRecord) ProtoMessage()
- func (x *EnterpriseRecord) ProtoReflect() protoreflect.Message
- func (x *EnterpriseRecord) Reset()
- func (x *EnterpriseRecord) String() string
- type GetActivationCodeRequest
- func (*GetActivationCodeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetActivationCodeRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*GetActivationCodeRequest) ProtoMessage()
- func (x *GetActivationCodeRequest) ProtoReflect() protoreflect.Message
- func (x *GetActivationCodeRequest) Reset()
- func (x *GetActivationCodeRequest) String() string
- type GetActivationCodeResponse
- func (*GetActivationCodeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetActivationCodeResponse) GetActivationCode() string
- func (x *GetActivationCodeResponse) GetInfo() *TokenInfo
- func (x *GetActivationCodeResponse) GetState() State
- func (x *GetActivationCodeResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*GetActivationCodeResponse) ProtoMessage()
- func (x *GetActivationCodeResponse) ProtoReflect() protoreflect.Message
- func (x *GetActivationCodeResponse) Reset()
- func (x *GetActivationCodeResponse) String() string
- type GetStateRequest
- func (*GetStateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetStateRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*GetStateRequest) ProtoMessage()
- func (x *GetStateRequest) ProtoReflect() protoreflect.Message
- func (x *GetStateRequest) Reset()
- func (x *GetStateRequest) String() string
- type GetStateResponse
- func (*GetStateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStateResponse) GetActivationCode() string
- func (x *GetStateResponse) GetInfo() *TokenInfo
- func (x *GetStateResponse) GetState() State
- func (x *GetStateResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*GetStateResponse) ProtoMessage()
- func (x *GetStateResponse) ProtoReflect() protoreflect.Message
- func (x *GetStateResponse) Reset()
- func (x *GetStateResponse) String() string
- type HeartbeatRequest
- func (*HeartbeatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HeartbeatRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*HeartbeatRequest) ProtoMessage()
- func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
- func (x *HeartbeatRequest) Reset()
- func (x *HeartbeatRequest) String() string
- type HeartbeatResponse
- func (*HeartbeatResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HeartbeatResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*HeartbeatResponse) ProtoMessage()
- func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message
- func (x *HeartbeatResponse) Reset()
- func (x *HeartbeatResponse) String() string
- type LicenseRecord
- func (*LicenseRecord) Descriptor() ([]byte, []int)deprecated
- func (x *LicenseRecord) GetActivationCode() string
- func (x *LicenseRecord) GetExpires() *timestamppb.Timestamp
- func (x *LicenseRecord) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*LicenseRecord) ProtoMessage()
- func (x *LicenseRecord) ProtoReflect() protoreflect.Message
- func (x *LicenseRecord) Reset()
- func (x *LicenseRecord) String() string
- type PauseRequest
- type PauseResponse
- func (*PauseResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PauseResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*PauseResponse) ProtoMessage()
- func (x *PauseResponse) ProtoReflect() protoreflect.Message
- func (x *PauseResponse) Reset()
- func (x *PauseResponse) String() string
- type PauseStatusRequest
- func (*PauseStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PauseStatusRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*PauseStatusRequest) ProtoMessage()
- func (x *PauseStatusRequest) ProtoReflect() protoreflect.Message
- func (x *PauseStatusRequest) Reset()
- func (x *PauseStatusRequest) String() string
- type PauseStatusResponse
- func (*PauseStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PauseStatusResponse) GetStatus() PauseStatusResponse_PauseStatus
- func (x *PauseStatusResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*PauseStatusResponse) ProtoMessage()
- func (x *PauseStatusResponse) ProtoReflect() protoreflect.Message
- func (x *PauseStatusResponse) Reset()
- func (x *PauseStatusResponse) String() string
- type PauseStatusResponse_PauseStatus
- func (PauseStatusResponse_PauseStatus) Descriptor() protoreflect.EnumDescriptor
- func (x PauseStatusResponse_PauseStatus) Enum() *PauseStatusResponse_PauseStatus
- func (PauseStatusResponse_PauseStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x PauseStatusResponse_PauseStatus) Number() protoreflect.EnumNumber
- func (x PauseStatusResponse_PauseStatus) String() string
- func (PauseStatusResponse_PauseStatus) Type() protoreflect.EnumType
- type State
- type TokenInfo
- func (*TokenInfo) Descriptor() ([]byte, []int)deprecated
- func (x *TokenInfo) GetExpires() *timestamppb.Timestamp
- func (x *TokenInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*TokenInfo) ProtoMessage()
- func (x *TokenInfo) ProtoReflect() protoreflect.Message
- func (x *TokenInfo) Reset()
- func (x *TokenInfo) String() string
- type UnimplementedAPIServer
- func (UnimplementedAPIServer) Activate(context.Context, *ActivateRequest) (*ActivateResponse, error)
- func (UnimplementedAPIServer) Deactivate(context.Context, *DeactivateRequest) (*DeactivateResponse, error)
- func (UnimplementedAPIServer) GetActivationCode(context.Context, *GetActivationCodeRequest) (*GetActivationCodeResponse, error)
- func (UnimplementedAPIServer) GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)
- func (UnimplementedAPIServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
- func (UnimplementedAPIServer) Pause(context.Context, *PauseRequest) (*PauseResponse, error)
- func (UnimplementedAPIServer) PauseStatus(context.Context, *PauseStatusRequest) (*PauseStatusResponse, error)
- func (UnimplementedAPIServer) Unpause(context.Context, *UnpauseRequest) (*UnpauseResponse, error)
- type UnpauseRequest
- func (*UnpauseRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnpauseRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*UnpauseRequest) ProtoMessage()
- func (x *UnpauseRequest) ProtoReflect() protoreflect.Message
- func (x *UnpauseRequest) Reset()
- func (x *UnpauseRequest) String() string
- type UnpauseResponse
- func (*UnpauseResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UnpauseResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*UnpauseResponse) ProtoMessage()
- func (x *UnpauseResponse) ProtoReflect() protoreflect.Message
- func (x *UnpauseResponse) Reset()
- func (x *UnpauseResponse) String() string
- type UnsafeAPIServer
Constants ¶
const ( API_Activate_FullMethodName = "/enterprise_v2.API/Activate" API_GetState_FullMethodName = "/enterprise_v2.API/GetState" API_GetActivationCode_FullMethodName = "/enterprise_v2.API/GetActivationCode" API_Heartbeat_FullMethodName = "/enterprise_v2.API/Heartbeat" API_Deactivate_FullMethodName = "/enterprise_v2.API/Deactivate" API_Pause_FullMethodName = "/enterprise_v2.API/Pause" API_Unpause_FullMethodName = "/enterprise_v2.API/Unpause" API_PauseStatus_FullMethodName = "/enterprise_v2.API/PauseStatus" )
Variables ¶
var ( State_name = map[int32]string{ 0: "NONE", 1: "ACTIVE", 2: "EXPIRED", 3: "HEARTBEAT_FAILED", } State_value = map[string]int32{ "NONE": 0, "ACTIVE": 1, "EXPIRED": 2, "HEARTBEAT_FAILED": 3, } )
Enum value maps for State.
var ( PauseStatusResponse_PauseStatus_name = map[int32]string{ 0: "UNPAUSED", 1: "PARTIALLY_PAUSED", 2: "PAUSED", } PauseStatusResponse_PauseStatus_value = map[string]int32{ "UNPAUSED": 0, "PARTIALLY_PAUSED": 1, "PAUSED": 2, } )
Enum value maps for PauseStatusResponse_PauseStatus.
var API_ServiceDesc = grpc.ServiceDesc{ ServiceName: "enterprise_v2.API", HandlerType: (*APIServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Activate", Handler: _API_Activate_Handler, }, { MethodName: "GetState", Handler: _API_GetState_Handler, }, { MethodName: "GetActivationCode", Handler: _API_GetActivationCode_Handler, }, { MethodName: "Heartbeat", Handler: _API_Heartbeat_Handler, }, { MethodName: "Deactivate", Handler: _API_Deactivate_Handler, }, { MethodName: "Pause", Handler: _API_Pause_Handler, }, { MethodName: "Unpause", Handler: _API_Unpause_Handler, }, { MethodName: "PauseStatus", Handler: _API_PauseStatus_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "enterprise/enterprise.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)
var File_enterprise_enterprise_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAPIServer ¶
func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)
Types ¶
type APIClient ¶
type APIClient interface { // Provide a Pachyderm enterprise token, enabling Pachyderm enterprise // features, such as the Pachyderm Dashboard and Auth system Activate(ctx context.Context, in *ActivateRequest, opts ...grpc.CallOption) (*ActivateResponse, error) GetState(ctx context.Context, in *GetStateRequest, opts ...grpc.CallOption) (*GetStateResponse, error) GetActivationCode(ctx context.Context, in *GetActivationCodeRequest, opts ...grpc.CallOption) (*GetActivationCodeResponse, error) // Heartbeat is used in testing to trigger a heartbeat on demand. Normally this happens // on a timer. Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error) // Deactivate removes a cluster's enterprise activation // token and sets its enterprise state to NONE. Deactivate(ctx context.Context, in *DeactivateRequest, opts ...grpc.CallOption) (*DeactivateResponse, error) // Pause pauses the cluster. Pause(ctx context.Context, in *PauseRequest, opts ...grpc.CallOption) (*PauseResponse, error) // Unpause unpauses the cluser. Unpause(ctx context.Context, in *UnpauseRequest, opts ...grpc.CallOption) (*UnpauseResponse, error) PauseStatus(ctx context.Context, in *PauseStatusRequest, opts ...grpc.CallOption) (*PauseStatusResponse, 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 { // Provide a Pachyderm enterprise token, enabling Pachyderm enterprise // features, such as the Pachyderm Dashboard and Auth system Activate(context.Context, *ActivateRequest) (*ActivateResponse, error) GetState(context.Context, *GetStateRequest) (*GetStateResponse, error) GetActivationCode(context.Context, *GetActivationCodeRequest) (*GetActivationCodeResponse, error) // Heartbeat is used in testing to trigger a heartbeat on demand. Normally this happens // on a timer. Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error) // Deactivate removes a cluster's enterprise activation // token and sets its enterprise state to NONE. Deactivate(context.Context, *DeactivateRequest) (*DeactivateResponse, error) // Pause pauses the cluster. Pause(context.Context, *PauseRequest) (*PauseResponse, error) // Unpause unpauses the cluser. Unpause(context.Context, *UnpauseRequest) (*UnpauseResponse, error) PauseStatus(context.Context, *PauseStatusRequest) (*PauseStatusResponse, 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 { LicenseServer string `protobuf:"bytes,1,opt,name=license_server,json=licenseServer,proto3" json:"license_server,omitempty"` Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` Secret string `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"` // contains filtered or unexported fields }
func (*ActivateRequest) Descriptor
deprecated
func (*ActivateRequest) Descriptor() ([]byte, []int)
Deprecated: Use ActivateRequest.ProtoReflect.Descriptor instead.
func (*ActivateRequest) GetId ¶
func (x *ActivateRequest) GetId() string
func (*ActivateRequest) GetLicenseServer ¶
func (x *ActivateRequest) GetLicenseServer() string
func (*ActivateRequest) GetSecret ¶
func (x *ActivateRequest) GetSecret() string
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 {
// contains filtered or unexported fields
}
func (*ActivateResponse) Descriptor
deprecated
func (*ActivateResponse) Descriptor() ([]byte, []int)
Deprecated: Use ActivateResponse.ProtoReflect.Descriptor instead.
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 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 EnterpriseConfig ¶
type EnterpriseConfig struct { // license_server is the address of the grpc license service LicenseServer string `protobuf:"bytes,1,opt,name=license_server,json=licenseServer,proto3" json:"license_server,omitempty"` // id is the unique identifier for this pachd, which is registered // with the license service Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"` // secret is a shared secret between this pachd and the license service Secret string `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"` // contains filtered or unexported fields }
EnterpriseConfig is the configuration we store for heartbeating to the license server.
func (*EnterpriseConfig) Descriptor
deprecated
func (*EnterpriseConfig) Descriptor() ([]byte, []int)
Deprecated: Use EnterpriseConfig.ProtoReflect.Descriptor instead.
func (*EnterpriseConfig) GetId ¶
func (x *EnterpriseConfig) GetId() string
func (*EnterpriseConfig) GetLicenseServer ¶
func (x *EnterpriseConfig) GetLicenseServer() string
func (*EnterpriseConfig) GetSecret ¶
func (x *EnterpriseConfig) GetSecret() string
func (*EnterpriseConfig) MarshalLogObject ¶
func (x *EnterpriseConfig) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*EnterpriseConfig) ProtoMessage ¶
func (*EnterpriseConfig) ProtoMessage()
func (*EnterpriseConfig) ProtoReflect ¶ added in v2.7.0
func (x *EnterpriseConfig) ProtoReflect() protoreflect.Message
func (*EnterpriseConfig) Reset ¶
func (x *EnterpriseConfig) Reset()
func (*EnterpriseConfig) String ¶
func (x *EnterpriseConfig) String() string
type EnterpriseRecord ¶
type EnterpriseRecord struct { // license is the cached LicenseRecord retrieved from the most recent // heartbeat to the license server. License *LicenseRecord `protobuf:"bytes,1,opt,name=license,proto3" json:"license,omitempty"` // last_heartbeat is the timestamp of the last successful heartbeat // to the license server LastHeartbeat *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_heartbeat,json=lastHeartbeat,proto3" json:"last_heartbeat,omitempty"` // heartbeat_failed is set if the license is still valid, but // the pachd is no longer registered with an enterprise server. // This is the same as the expired state, where auth is locked // but not disabled. HeartbeatFailed bool `protobuf:"varint,3,opt,name=heartbeat_failed,json=heartbeatFailed,proto3" json:"heartbeat_failed,omitempty"` // contains filtered or unexported fields }
EnterpriseRecord is a protobuf we cache in etcd to store the enterprise status.
func (*EnterpriseRecord) Descriptor
deprecated
func (*EnterpriseRecord) Descriptor() ([]byte, []int)
Deprecated: Use EnterpriseRecord.ProtoReflect.Descriptor instead.
func (*EnterpriseRecord) GetHeartbeatFailed ¶
func (x *EnterpriseRecord) GetHeartbeatFailed() bool
func (*EnterpriseRecord) GetLastHeartbeat ¶
func (x *EnterpriseRecord) GetLastHeartbeat() *timestamppb.Timestamp
func (*EnterpriseRecord) GetLicense ¶
func (x *EnterpriseRecord) GetLicense() *LicenseRecord
func (*EnterpriseRecord) MarshalLogObject ¶
func (x *EnterpriseRecord) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*EnterpriseRecord) ProtoMessage ¶
func (*EnterpriseRecord) ProtoMessage()
func (*EnterpriseRecord) ProtoReflect ¶ added in v2.7.0
func (x *EnterpriseRecord) ProtoReflect() protoreflect.Message
func (*EnterpriseRecord) Reset ¶
func (x *EnterpriseRecord) Reset()
func (*EnterpriseRecord) String ¶
func (x *EnterpriseRecord) 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 State `protobuf:"varint,1,opt,name=state,proto3,enum=enterprise_v2.State" json:"state,omitempty"` Info *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() *TokenInfo
func (*GetActivationCodeResponse) GetState ¶
func (x *GetActivationCodeResponse) GetState() 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 GetStateRequest ¶
type GetStateRequest struct {
// contains filtered or unexported fields
}
func (*GetStateRequest) Descriptor
deprecated
func (*GetStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStateRequest.ProtoReflect.Descriptor instead.
func (*GetStateRequest) MarshalLogObject ¶
func (x *GetStateRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*GetStateRequest) ProtoMessage ¶
func (*GetStateRequest) ProtoMessage()
func (*GetStateRequest) ProtoReflect ¶ added in v2.7.0
func (x *GetStateRequest) ProtoReflect() protoreflect.Message
func (*GetStateRequest) Reset ¶
func (x *GetStateRequest) Reset()
func (*GetStateRequest) String ¶
func (x *GetStateRequest) String() string
type GetStateResponse ¶
type GetStateResponse struct { State State `protobuf:"varint,1,opt,name=state,proto3,enum=enterprise_v2.State" json:"state,omitempty"` Info *TokenInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"` // activation_code will always be an empty string, // call GetEnterpriseCode to get the activation code ActivationCode string `protobuf:"bytes,3,opt,name=activation_code,json=activationCode,proto3" json:"activation_code,omitempty"` // contains filtered or unexported fields }
func (*GetStateResponse) Descriptor
deprecated
func (*GetStateResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStateResponse.ProtoReflect.Descriptor instead.
func (*GetStateResponse) GetActivationCode ¶
func (x *GetStateResponse) GetActivationCode() string
func (*GetStateResponse) GetInfo ¶
func (x *GetStateResponse) GetInfo() *TokenInfo
func (*GetStateResponse) GetState ¶
func (x *GetStateResponse) GetState() State
func (*GetStateResponse) MarshalLogObject ¶
func (x *GetStateResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*GetStateResponse) ProtoMessage ¶
func (*GetStateResponse) ProtoMessage()
func (*GetStateResponse) ProtoReflect ¶ added in v2.7.0
func (x *GetStateResponse) ProtoReflect() protoreflect.Message
func (*GetStateResponse) Reset ¶
func (x *GetStateResponse) Reset()
func (*GetStateResponse) String ¶
func (x *GetStateResponse) String() string
type HeartbeatRequest ¶
type HeartbeatRequest struct {
// contains filtered or unexported fields
}
Heartbeat in the enterprise service just triggers a heartbeat for testing purposes. The RPC used to communicate with the license service is defined in the license service.
func (*HeartbeatRequest) Descriptor
deprecated
func (*HeartbeatRequest) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.
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 {
// contains filtered or unexported fields
}
func (*HeartbeatResponse) Descriptor
deprecated
func (*HeartbeatResponse) Descriptor() ([]byte, []int)
Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.
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 LicenseRecord ¶
type LicenseRecord struct { ActivationCode string `protobuf:"bytes,1,opt,name=activation_code,json=activationCode,proto3" json:"activation_code,omitempty"` Expires *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires,proto3" json:"expires,omitempty"` // contains filtered or unexported fields }
LicenseRecord is the record we store in etcd for a Pachyderm enterprise token that has been provided to a Pachyderm license server
func (*LicenseRecord) Descriptor
deprecated
func (*LicenseRecord) Descriptor() ([]byte, []int)
Deprecated: Use LicenseRecord.ProtoReflect.Descriptor instead.
func (*LicenseRecord) GetActivationCode ¶
func (x *LicenseRecord) GetActivationCode() string
func (*LicenseRecord) GetExpires ¶
func (x *LicenseRecord) GetExpires() *timestamppb.Timestamp
func (*LicenseRecord) MarshalLogObject ¶
func (x *LicenseRecord) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*LicenseRecord) ProtoMessage ¶
func (*LicenseRecord) ProtoMessage()
func (*LicenseRecord) ProtoReflect ¶ added in v2.7.0
func (x *LicenseRecord) ProtoReflect() protoreflect.Message
func (*LicenseRecord) Reset ¶
func (x *LicenseRecord) Reset()
func (*LicenseRecord) String ¶
func (x *LicenseRecord) String() string
type PauseRequest ¶
type PauseRequest struct {
// contains filtered or unexported fields
}
func (*PauseRequest) Descriptor
deprecated
func (*PauseRequest) Descriptor() ([]byte, []int)
Deprecated: Use PauseRequest.ProtoReflect.Descriptor instead.
func (*PauseRequest) MarshalLogObject ¶
func (x *PauseRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*PauseRequest) ProtoMessage ¶
func (*PauseRequest) ProtoMessage()
func (*PauseRequest) ProtoReflect ¶ added in v2.7.0
func (x *PauseRequest) ProtoReflect() protoreflect.Message
func (*PauseRequest) Reset ¶
func (x *PauseRequest) Reset()
func (*PauseRequest) String ¶
func (x *PauseRequest) String() string
type PauseResponse ¶
type PauseResponse struct {
// contains filtered or unexported fields
}
func (*PauseResponse) Descriptor
deprecated
func (*PauseResponse) Descriptor() ([]byte, []int)
Deprecated: Use PauseResponse.ProtoReflect.Descriptor instead.
func (*PauseResponse) MarshalLogObject ¶
func (x *PauseResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*PauseResponse) ProtoMessage ¶
func (*PauseResponse) ProtoMessage()
func (*PauseResponse) ProtoReflect ¶ added in v2.7.0
func (x *PauseResponse) ProtoReflect() protoreflect.Message
func (*PauseResponse) Reset ¶
func (x *PauseResponse) Reset()
func (*PauseResponse) String ¶
func (x *PauseResponse) String() string
type PauseStatusRequest ¶
type PauseStatusRequest struct {
// contains filtered or unexported fields
}
func (*PauseStatusRequest) Descriptor
deprecated
func (*PauseStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use PauseStatusRequest.ProtoReflect.Descriptor instead.
func (*PauseStatusRequest) MarshalLogObject ¶
func (x *PauseStatusRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*PauseStatusRequest) ProtoMessage ¶
func (*PauseStatusRequest) ProtoMessage()
func (*PauseStatusRequest) ProtoReflect ¶ added in v2.7.0
func (x *PauseStatusRequest) ProtoReflect() protoreflect.Message
func (*PauseStatusRequest) Reset ¶
func (x *PauseStatusRequest) Reset()
func (*PauseStatusRequest) String ¶
func (x *PauseStatusRequest) String() string
type PauseStatusResponse ¶
type PauseStatusResponse struct { Status PauseStatusResponse_PauseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=enterprise_v2.PauseStatusResponse_PauseStatus" json:"status,omitempty"` // contains filtered or unexported fields }
func (*PauseStatusResponse) Descriptor
deprecated
func (*PauseStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use PauseStatusResponse.ProtoReflect.Descriptor instead.
func (*PauseStatusResponse) GetStatus ¶
func (x *PauseStatusResponse) GetStatus() PauseStatusResponse_PauseStatus
func (*PauseStatusResponse) MarshalLogObject ¶
func (x *PauseStatusResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*PauseStatusResponse) ProtoMessage ¶
func (*PauseStatusResponse) ProtoMessage()
func (*PauseStatusResponse) ProtoReflect ¶ added in v2.7.0
func (x *PauseStatusResponse) ProtoReflect() protoreflect.Message
func (*PauseStatusResponse) Reset ¶
func (x *PauseStatusResponse) Reset()
func (*PauseStatusResponse) String ¶
func (x *PauseStatusResponse) String() string
type PauseStatusResponse_PauseStatus ¶
type PauseStatusResponse_PauseStatus int32
const ( PauseStatusResponse_UNPAUSED PauseStatusResponse_PauseStatus = 0 PauseStatusResponse_PARTIALLY_PAUSED PauseStatusResponse_PauseStatus = 1 PauseStatusResponse_PAUSED PauseStatusResponse_PauseStatus = 2 )
func (PauseStatusResponse_PauseStatus) Descriptor ¶ added in v2.7.0
func (PauseStatusResponse_PauseStatus) Descriptor() protoreflect.EnumDescriptor
func (PauseStatusResponse_PauseStatus) Enum ¶ added in v2.7.0
func (x PauseStatusResponse_PauseStatus) Enum() *PauseStatusResponse_PauseStatus
func (PauseStatusResponse_PauseStatus) EnumDescriptor
deprecated
func (PauseStatusResponse_PauseStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use PauseStatusResponse_PauseStatus.Descriptor instead.
func (PauseStatusResponse_PauseStatus) Number ¶ added in v2.7.0
func (x PauseStatusResponse_PauseStatus) Number() protoreflect.EnumNumber
func (PauseStatusResponse_PauseStatus) String ¶
func (x PauseStatusResponse_PauseStatus) String() string
func (PauseStatusResponse_PauseStatus) Type ¶ added in v2.7.0
func (PauseStatusResponse_PauseStatus) Type() protoreflect.EnumType
type State ¶
type State int32
func (State) Descriptor ¶ added in v2.7.0
func (State) Descriptor() protoreflect.EnumDescriptor
func (State) EnumDescriptor
deprecated
func (State) Number ¶ added in v2.7.0
func (x State) Number() protoreflect.EnumNumber
func (State) Type ¶ added in v2.7.0
func (State) Type() protoreflect.EnumType
type TokenInfo ¶
type TokenInfo struct { // expires indicates when the current token expires (unset if there is no // current token) Expires *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=expires,proto3" json:"expires,omitempty"` // contains filtered or unexported fields }
TokenInfo contains information about the currently active enterprise token
func (*TokenInfo) Descriptor
deprecated
func (*TokenInfo) GetExpires ¶
func (x *TokenInfo) GetExpires() *timestamppb.Timestamp
func (*TokenInfo) MarshalLogObject ¶
func (x *TokenInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*TokenInfo) ProtoMessage ¶
func (*TokenInfo) ProtoMessage()
func (*TokenInfo) ProtoReflect ¶ added in v2.7.0
func (x *TokenInfo) ProtoReflect() protoreflect.Message
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) Deactivate ¶
func (UnimplementedAPIServer) Deactivate(context.Context, *DeactivateRequest) (*DeactivateResponse, error)
func (UnimplementedAPIServer) GetActivationCode ¶
func (UnimplementedAPIServer) GetActivationCode(context.Context, *GetActivationCodeRequest) (*GetActivationCodeResponse, error)
func (UnimplementedAPIServer) GetState ¶
func (UnimplementedAPIServer) GetState(context.Context, *GetStateRequest) (*GetStateResponse, error)
func (UnimplementedAPIServer) Heartbeat ¶
func (UnimplementedAPIServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
func (UnimplementedAPIServer) Pause ¶
func (UnimplementedAPIServer) Pause(context.Context, *PauseRequest) (*PauseResponse, error)
func (UnimplementedAPIServer) PauseStatus ¶
func (UnimplementedAPIServer) PauseStatus(context.Context, *PauseStatusRequest) (*PauseStatusResponse, error)
func (UnimplementedAPIServer) Unpause ¶
func (UnimplementedAPIServer) Unpause(context.Context, *UnpauseRequest) (*UnpauseResponse, error)
type UnpauseRequest ¶
type UnpauseRequest struct {
// contains filtered or unexported fields
}
func (*UnpauseRequest) Descriptor
deprecated
func (*UnpauseRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnpauseRequest.ProtoReflect.Descriptor instead.
func (*UnpauseRequest) MarshalLogObject ¶
func (x *UnpauseRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*UnpauseRequest) ProtoMessage ¶
func (*UnpauseRequest) ProtoMessage()
func (*UnpauseRequest) ProtoReflect ¶ added in v2.7.0
func (x *UnpauseRequest) ProtoReflect() protoreflect.Message
func (*UnpauseRequest) Reset ¶
func (x *UnpauseRequest) Reset()
func (*UnpauseRequest) String ¶
func (x *UnpauseRequest) String() string
type UnpauseResponse ¶
type UnpauseResponse struct {
// contains filtered or unexported fields
}
func (*UnpauseResponse) Descriptor
deprecated
func (*UnpauseResponse) Descriptor() ([]byte, []int)
Deprecated: Use UnpauseResponse.ProtoReflect.Descriptor instead.
func (*UnpauseResponse) MarshalLogObject ¶
func (x *UnpauseResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*UnpauseResponse) ProtoMessage ¶
func (*UnpauseResponse) ProtoMessage()
func (*UnpauseResponse) ProtoReflect ¶ added in v2.7.0
func (x *UnpauseResponse) ProtoReflect() protoreflect.Message
func (*UnpauseResponse) Reset ¶
func (x *UnpauseResponse) Reset()
func (*UnpauseResponse) String ¶
func (x *UnpauseResponse) String() string
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.