enterprise

package
v2.7.2 Latest Latest
Warning

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

 Go to latest Published: Aug 30, 2023 License: Apache-2.0 Imports: 11 Imported by: 1

Documentation

Index

Constants

View Source 
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

View Source 
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.

View Source 
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.

View Source 
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)

View Source 
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
const (
	State_NONE             State = 0
	State_ACTIVE           State = 1
	State_EXPIRED          State = 2
	State_HEARTBEAT_FAILED State = 3
)

func (State) Descriptor added in v2.7.0 

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum added in v2.7.0 

func (x State) Enum() *State

func (State) EnumDescriptor deprecated 

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

Deprecated: Use State.Descriptor instead.

func (State) Number added in v2.7.0 

func (x State) Number() protoreflect.EnumNumber

func (State) String 

func (x State) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use TokenInfo.ProtoReflect.Descriptor instead.

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

func (*TokenInfo) Reset 

func (x *TokenInfo) Reset()

func (*TokenInfo) String 

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

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.