enterprise

package
v2.6.10 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthEnterprise        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEnterprise          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEnterprise = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var PauseStatusResponse_PauseStatus_name = map[int32]string{
	0: "UNPAUSED",
	1: "PARTIALLY_PAUSED",
	2: "PAUSED",
}
View Source 
var PauseStatusResponse_PauseStatus_value = map[string]int32{
	"UNPAUSED":         0,
	"PARTIALLY_PAUSED": 1,
	"PAUSED":           2,
}
View Source 
var State_name = map[int32]string{
	0: "NONE",
	1: "ACTIVE",
	2: "EXPIRED",
	3: "HEARTBEAT_FAILED",
}
View Source 
var State_value = map[string]int32{
	"NONE":             0,
	"ACTIVE":           1,
	"EXPIRED":          2,
	"HEARTBEAT_FAILED": 3,
}

Functions

func RegisterAPIServer 

func RegisterAPIServer(s *grpc.Server, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAPIClient 

func NewAPIClient(cc *grpc.ClientConn) 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)
}

APIServer is the server API for API service.

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActivateRequest) Descriptor 

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

func (*ActivateRequest) GetId 

func (m *ActivateRequest) GetId() string

func (*ActivateRequest) GetLicenseServer 

func (m *ActivateRequest) GetLicenseServer() string

func (*ActivateRequest) GetSecret 

func (m *ActivateRequest) GetSecret() string

func (*ActivateRequest) Marshal 

func (m *ActivateRequest) Marshal() (dAtA []byte, err error)

func (*ActivateRequest) MarshalLogObject 

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

func (*ActivateRequest) MarshalTo 

func (m *ActivateRequest) MarshalTo(dAtA []byte) (int, error)

func (*ActivateRequest) MarshalToSizedBuffer 

func (m *ActivateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivateRequest) ProtoMessage 

func (*ActivateRequest) ProtoMessage()

func (*ActivateRequest) Reset 

func (m *ActivateRequest) Reset()

func (*ActivateRequest) Size 

func (m *ActivateRequest) Size() (n int)

func (*ActivateRequest) String 

func (m *ActivateRequest) String() string

func (*ActivateRequest) Unmarshal 

func (m *ActivateRequest) Unmarshal(dAtA []byte) error

func (*ActivateRequest) XXX_DiscardUnknown 

func (m *ActivateRequest) XXX_DiscardUnknown()

func (*ActivateRequest) XXX_Marshal 

func (m *ActivateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivateRequest) XXX_Merge 

func (m *ActivateRequest) XXX_Merge(src proto.Message)

func (*ActivateRequest) XXX_Size 

func (m *ActivateRequest) XXX_Size() int

func (*ActivateRequest) XXX_Unmarshal 

func (m *ActivateRequest) XXX_Unmarshal(b []byte) error

type ActivateResponse 

type ActivateResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ActivateResponse) Descriptor 

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

func (*ActivateResponse) Marshal 

func (m *ActivateResponse) Marshal() (dAtA []byte, err error)

func (*ActivateResponse) MarshalLogObject 

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

func (*ActivateResponse) MarshalTo 

func (m *ActivateResponse) MarshalTo(dAtA []byte) (int, error)

func (*ActivateResponse) MarshalToSizedBuffer 

func (m *ActivateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ActivateResponse) ProtoMessage 

func (*ActivateResponse) ProtoMessage()

func (*ActivateResponse) Reset 

func (m *ActivateResponse) Reset()

func (*ActivateResponse) Size 

func (m *ActivateResponse) Size() (n int)

func (*ActivateResponse) String 

func (m *ActivateResponse) String() string

func (*ActivateResponse) Unmarshal 

func (m *ActivateResponse) Unmarshal(dAtA []byte) error

func (*ActivateResponse) XXX_DiscardUnknown 

func (m *ActivateResponse) XXX_DiscardUnknown()

func (*ActivateResponse) XXX_Marshal 

func (m *ActivateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ActivateResponse) XXX_Merge 

func (m *ActivateResponse) XXX_Merge(src proto.Message)

func (*ActivateResponse) XXX_Size 

func (m *ActivateResponse) XXX_Size() int

func (*ActivateResponse) XXX_Unmarshal 

func (m *ActivateResponse) XXX_Unmarshal(b []byte) error

type DeactivateRequest 

type DeactivateRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeactivateRequest) Descriptor 

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

func (*DeactivateRequest) Marshal 

func (m *DeactivateRequest) Marshal() (dAtA []byte, err error)

func (*DeactivateRequest) MarshalLogObject 

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

func (*DeactivateRequest) MarshalTo 

func (m *DeactivateRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeactivateRequest) MarshalToSizedBuffer 

func (m *DeactivateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeactivateRequest) ProtoMessage 

func (*DeactivateRequest) ProtoMessage()

func (*DeactivateRequest) Reset 

func (m *DeactivateRequest) Reset()

func (*DeactivateRequest) Size 

func (m *DeactivateRequest) Size() (n int)

func (*DeactivateRequest) String 

func (m *DeactivateRequest) String() string

func (*DeactivateRequest) Unmarshal 

func (m *DeactivateRequest) Unmarshal(dAtA []byte) error

func (*DeactivateRequest) XXX_DiscardUnknown 

func (m *DeactivateRequest) XXX_DiscardUnknown()

func (*DeactivateRequest) XXX_Marshal 

func (m *DeactivateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeactivateRequest) XXX_Merge 

func (m *DeactivateRequest) XXX_Merge(src proto.Message)

func (*DeactivateRequest) XXX_Size 

func (m *DeactivateRequest) XXX_Size() int

func (*DeactivateRequest) XXX_Unmarshal 

func (m *DeactivateRequest) XXX_Unmarshal(b []byte) error

type DeactivateResponse 

type DeactivateResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeactivateResponse) Descriptor 

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

func (*DeactivateResponse) Marshal 

func (m *DeactivateResponse) Marshal() (dAtA []byte, err error)

func (*DeactivateResponse) MarshalLogObject 

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

func (*DeactivateResponse) MarshalTo 

func (m *DeactivateResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeactivateResponse) MarshalToSizedBuffer 

func (m *DeactivateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeactivateResponse) ProtoMessage 

func (*DeactivateResponse) ProtoMessage()

func (*DeactivateResponse) Reset 

func (m *DeactivateResponse) Reset()

func (*DeactivateResponse) Size 

func (m *DeactivateResponse) Size() (n int)

func (*DeactivateResponse) String 

func (m *DeactivateResponse) String() string

func (*DeactivateResponse) Unmarshal 

func (m *DeactivateResponse) Unmarshal(dAtA []byte) error

func (*DeactivateResponse) XXX_DiscardUnknown 

func (m *DeactivateResponse) XXX_DiscardUnknown()

func (*DeactivateResponse) XXX_Marshal 

func (m *DeactivateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeactivateResponse) XXX_Merge 

func (m *DeactivateResponse) XXX_Merge(src proto.Message)

func (*DeactivateResponse) XXX_Size 

func (m *DeactivateResponse) XXX_Size() int

func (*DeactivateResponse) XXX_Unmarshal 

func (m *DeactivateResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

EnterpriseConfig is the configuration we store for heartbeating to the license server.

func (*EnterpriseConfig) Descriptor 

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

func (*EnterpriseConfig) GetId 

func (m *EnterpriseConfig) GetId() string

func (*EnterpriseConfig) GetLicenseServer 

func (m *EnterpriseConfig) GetLicenseServer() string

func (*EnterpriseConfig) GetSecret 

func (m *EnterpriseConfig) GetSecret() string

func (*EnterpriseConfig) Marshal 

func (m *EnterpriseConfig) Marshal() (dAtA []byte, err error)

func (*EnterpriseConfig) MarshalLogObject 

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

func (*EnterpriseConfig) MarshalTo 

func (m *EnterpriseConfig) MarshalTo(dAtA []byte) (int, error)

func (*EnterpriseConfig) MarshalToSizedBuffer 

func (m *EnterpriseConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EnterpriseConfig) ProtoMessage 

func (*EnterpriseConfig) ProtoMessage()

func (*EnterpriseConfig) Reset 

func (m *EnterpriseConfig) Reset()

func (*EnterpriseConfig) Size 

func (m *EnterpriseConfig) Size() (n int)

func (*EnterpriseConfig) String 

func (m *EnterpriseConfig) String() string

func (*EnterpriseConfig) Unmarshal 

func (m *EnterpriseConfig) Unmarshal(dAtA []byte) error

func (*EnterpriseConfig) XXX_DiscardUnknown 

func (m *EnterpriseConfig) XXX_DiscardUnknown()

func (*EnterpriseConfig) XXX_Marshal 

func (m *EnterpriseConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EnterpriseConfig) XXX_Merge 

func (m *EnterpriseConfig) XXX_Merge(src proto.Message)

func (*EnterpriseConfig) XXX_Size 

func (m *EnterpriseConfig) XXX_Size() int

func (*EnterpriseConfig) XXX_Unmarshal 

func (m *EnterpriseConfig) XXX_Unmarshal(b []byte) error

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 *types.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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

EnterpriseRecord is a protobuf we cache in etcd to store the enterprise status.

func (*EnterpriseRecord) Descriptor 

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

func (*EnterpriseRecord) GetHeartbeatFailed 

func (m *EnterpriseRecord) GetHeartbeatFailed() bool

func (*EnterpriseRecord) GetLastHeartbeat 

func (m *EnterpriseRecord) GetLastHeartbeat() *types.Timestamp

func (*EnterpriseRecord) GetLicense 

func (m *EnterpriseRecord) GetLicense() *LicenseRecord

func (*EnterpriseRecord) Marshal 

func (m *EnterpriseRecord) Marshal() (dAtA []byte, err error)

func (*EnterpriseRecord) MarshalLogObject 

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

func (*EnterpriseRecord) MarshalTo 

func (m *EnterpriseRecord) MarshalTo(dAtA []byte) (int, error)

func (*EnterpriseRecord) MarshalToSizedBuffer 

func (m *EnterpriseRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EnterpriseRecord) ProtoMessage 

func (*EnterpriseRecord) ProtoMessage()

func (*EnterpriseRecord) Reset 

func (m *EnterpriseRecord) Reset()

func (*EnterpriseRecord) Size 

func (m *EnterpriseRecord) Size() (n int)

func (*EnterpriseRecord) String 

func (m *EnterpriseRecord) String() string

func (*EnterpriseRecord) Unmarshal 

func (m *EnterpriseRecord) Unmarshal(dAtA []byte) error

func (*EnterpriseRecord) XXX_DiscardUnknown 

func (m *EnterpriseRecord) XXX_DiscardUnknown()

func (*EnterpriseRecord) XXX_Marshal 

func (m *EnterpriseRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EnterpriseRecord) XXX_Merge 

func (m *EnterpriseRecord) XXX_Merge(src proto.Message)

func (*EnterpriseRecord) XXX_Size 

func (m *EnterpriseRecord) XXX_Size() int

func (*EnterpriseRecord) XXX_Unmarshal 

func (m *EnterpriseRecord) XXX_Unmarshal(b []byte) error

type GetActivationCodeRequest 

type GetActivationCodeRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetActivationCodeRequest) Descriptor 

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

func (*GetActivationCodeRequest) Marshal 

func (m *GetActivationCodeRequest) Marshal() (dAtA []byte, err error)

func (*GetActivationCodeRequest) MarshalLogObject 

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

func (*GetActivationCodeRequest) MarshalTo 

func (m *GetActivationCodeRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetActivationCodeRequest) MarshalToSizedBuffer 

func (m *GetActivationCodeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetActivationCodeRequest) ProtoMessage 

func (*GetActivationCodeRequest) ProtoMessage()

func (*GetActivationCodeRequest) Reset 

func (m *GetActivationCodeRequest) Reset()

func (*GetActivationCodeRequest) Size 

func (m *GetActivationCodeRequest) Size() (n int)

func (*GetActivationCodeRequest) String 

func (m *GetActivationCodeRequest) String() string

func (*GetActivationCodeRequest) Unmarshal 

func (m *GetActivationCodeRequest) Unmarshal(dAtA []byte) error

func (*GetActivationCodeRequest) XXX_DiscardUnknown 

func (m *GetActivationCodeRequest) XXX_DiscardUnknown()

func (*GetActivationCodeRequest) XXX_Marshal 

func (m *GetActivationCodeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetActivationCodeRequest) XXX_Merge 

func (m *GetActivationCodeRequest) XXX_Merge(src proto.Message)

func (*GetActivationCodeRequest) XXX_Size 

func (m *GetActivationCodeRequest) XXX_Size() int

func (*GetActivationCodeRequest) XXX_Unmarshal 

func (m *GetActivationCodeRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetActivationCodeResponse) Descriptor 

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

func (*GetActivationCodeResponse) GetActivationCode 

func (m *GetActivationCodeResponse) GetActivationCode() string

func (*GetActivationCodeResponse) GetInfo 

func (m *GetActivationCodeResponse) GetInfo() *TokenInfo

func (*GetActivationCodeResponse) GetState 

func (m *GetActivationCodeResponse) GetState() State

func (*GetActivationCodeResponse) Marshal 

func (m *GetActivationCodeResponse) Marshal() (dAtA []byte, err error)

func (*GetActivationCodeResponse) MarshalLogObject 

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

func (*GetActivationCodeResponse) MarshalTo 

func (m *GetActivationCodeResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetActivationCodeResponse) MarshalToSizedBuffer 

func (m *GetActivationCodeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetActivationCodeResponse) ProtoMessage 

func (*GetActivationCodeResponse) ProtoMessage()

func (*GetActivationCodeResponse) Reset 

func (m *GetActivationCodeResponse) Reset()

func (*GetActivationCodeResponse) Size 

func (m *GetActivationCodeResponse) Size() (n int)

func (*GetActivationCodeResponse) String 

func (m *GetActivationCodeResponse) String() string

func (*GetActivationCodeResponse) Unmarshal 

func (m *GetActivationCodeResponse) Unmarshal(dAtA []byte) error

func (*GetActivationCodeResponse) XXX_DiscardUnknown 

func (m *GetActivationCodeResponse) XXX_DiscardUnknown()

func (*GetActivationCodeResponse) XXX_Marshal 

func (m *GetActivationCodeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetActivationCodeResponse) XXX_Merge 

func (m *GetActivationCodeResponse) XXX_Merge(src proto.Message)

func (*GetActivationCodeResponse) XXX_Size 

func (m *GetActivationCodeResponse) XXX_Size() int

func (*GetActivationCodeResponse) XXX_Unmarshal 

func (m *GetActivationCodeResponse) XXX_Unmarshal(b []byte) error

type GetStateRequest 

type GetStateRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStateRequest) Descriptor 

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

func (*GetStateRequest) Marshal 

func (m *GetStateRequest) Marshal() (dAtA []byte, err error)

func (*GetStateRequest) MarshalLogObject 

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

func (*GetStateRequest) MarshalTo 

func (m *GetStateRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetStateRequest) MarshalToSizedBuffer 

func (m *GetStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) Reset 

func (m *GetStateRequest) Reset()

func (*GetStateRequest) Size 

func (m *GetStateRequest) Size() (n int)

func (*GetStateRequest) String 

func (m *GetStateRequest) String() string

func (*GetStateRequest) Unmarshal 

func (m *GetStateRequest) Unmarshal(dAtA []byte) error

func (*GetStateRequest) XXX_DiscardUnknown 

func (m *GetStateRequest) XXX_DiscardUnknown()

func (*GetStateRequest) XXX_Marshal 

func (m *GetStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStateRequest) XXX_Merge 

func (m *GetStateRequest) XXX_Merge(src proto.Message)

func (*GetStateRequest) XXX_Size 

func (m *GetStateRequest) XXX_Size() int

func (*GetStateRequest) XXX_Unmarshal 

func (m *GetStateRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStateResponse) Descriptor 

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

func (*GetStateResponse) GetActivationCode 

func (m *GetStateResponse) GetActivationCode() string

func (*GetStateResponse) GetInfo 

func (m *GetStateResponse) GetInfo() *TokenInfo

func (*GetStateResponse) GetState 

func (m *GetStateResponse) GetState() State

func (*GetStateResponse) Marshal 

func (m *GetStateResponse) Marshal() (dAtA []byte, err error)

func (*GetStateResponse) MarshalLogObject 

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

func (*GetStateResponse) MarshalTo 

func (m *GetStateResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetStateResponse) MarshalToSizedBuffer 

func (m *GetStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetStateResponse) ProtoMessage 

func (*GetStateResponse) ProtoMessage()

func (*GetStateResponse) Reset 

func (m *GetStateResponse) Reset()

func (*GetStateResponse) Size 

func (m *GetStateResponse) Size() (n int)

func (*GetStateResponse) String 

func (m *GetStateResponse) String() string

func (*GetStateResponse) Unmarshal 

func (m *GetStateResponse) Unmarshal(dAtA []byte) error

func (*GetStateResponse) XXX_DiscardUnknown 

func (m *GetStateResponse) XXX_DiscardUnknown()

func (*GetStateResponse) XXX_Marshal 

func (m *GetStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetStateResponse) XXX_Merge 

func (m *GetStateResponse) XXX_Merge(src proto.Message)

func (*GetStateResponse) XXX_Size 

func (m *GetStateResponse) XXX_Size() int

func (*GetStateResponse) XXX_Unmarshal 

func (m *GetStateResponse) XXX_Unmarshal(b []byte) error

type HeartbeatRequest 

type HeartbeatRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*HeartbeatRequest) Marshal 

func (m *HeartbeatRequest) Marshal() (dAtA []byte, err error)

func (*HeartbeatRequest) MarshalLogObject 

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

func (*HeartbeatRequest) MarshalTo 

func (m *HeartbeatRequest) MarshalTo(dAtA []byte) (int, error)

func (*HeartbeatRequest) MarshalToSizedBuffer 

func (m *HeartbeatRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) Reset 

func (m *HeartbeatRequest) Reset()

func (*HeartbeatRequest) Size 

func (m *HeartbeatRequest) Size() (n int)

func (*HeartbeatRequest) String 

func (m *HeartbeatRequest) String() string

func (*HeartbeatRequest) Unmarshal 

func (m *HeartbeatRequest) Unmarshal(dAtA []byte) error

func (*HeartbeatRequest) XXX_DiscardUnknown 

func (m *HeartbeatRequest) XXX_DiscardUnknown()

func (*HeartbeatRequest) XXX_Marshal 

func (m *HeartbeatRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeartbeatRequest) XXX_Merge 

func (m *HeartbeatRequest) XXX_Merge(src proto.Message)

func (*HeartbeatRequest) XXX_Size 

func (m *HeartbeatRequest) XXX_Size() int

func (*HeartbeatRequest) XXX_Unmarshal 

func (m *HeartbeatRequest) XXX_Unmarshal(b []byte) error

type HeartbeatResponse 

type HeartbeatResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HeartbeatResponse) Descriptor 

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

func (*HeartbeatResponse) Marshal 

func (m *HeartbeatResponse) Marshal() (dAtA []byte, err error)

func (*HeartbeatResponse) MarshalLogObject 

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

func (*HeartbeatResponse) MarshalTo 

func (m *HeartbeatResponse) MarshalTo(dAtA []byte) (int, error)

func (*HeartbeatResponse) MarshalToSizedBuffer 

func (m *HeartbeatResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) Reset 

func (m *HeartbeatResponse) Reset()

func (*HeartbeatResponse) Size 

func (m *HeartbeatResponse) Size() (n int)

func (*HeartbeatResponse) String 

func (m *HeartbeatResponse) String() string

func (*HeartbeatResponse) Unmarshal 

func (m *HeartbeatResponse) Unmarshal(dAtA []byte) error

func (*HeartbeatResponse) XXX_DiscardUnknown 

func (m *HeartbeatResponse) XXX_DiscardUnknown()

func (*HeartbeatResponse) XXX_Marshal 

func (m *HeartbeatResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HeartbeatResponse) XXX_Merge 

func (m *HeartbeatResponse) XXX_Merge(src proto.Message)

func (*HeartbeatResponse) XXX_Size 

func (m *HeartbeatResponse) XXX_Size() int

func (*HeartbeatResponse) XXX_Unmarshal 

func (m *HeartbeatResponse) XXX_Unmarshal(b []byte) error

type LicenseRecord 

type LicenseRecord struct {
	ActivationCode       string           `protobuf:"bytes,1,opt,name=activation_code,json=activationCode,proto3" json:"activation_code,omitempty"`
	Expires              *types.Timestamp `protobuf:"bytes,2,opt,name=expires,proto3" json:"expires,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

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 

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

func (*LicenseRecord) GetActivationCode 

func (m *LicenseRecord) GetActivationCode() string

func (*LicenseRecord) GetExpires 

func (m *LicenseRecord) GetExpires() *types.Timestamp

func (*LicenseRecord) Marshal 

func (m *LicenseRecord) Marshal() (dAtA []byte, err error)

func (*LicenseRecord) MarshalLogObject 

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

func (*LicenseRecord) MarshalTo 

func (m *LicenseRecord) MarshalTo(dAtA []byte) (int, error)

func (*LicenseRecord) MarshalToSizedBuffer 

func (m *LicenseRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LicenseRecord) ProtoMessage 

func (*LicenseRecord) ProtoMessage()

func (*LicenseRecord) Reset 

func (m *LicenseRecord) Reset()

func (*LicenseRecord) Size 

func (m *LicenseRecord) Size() (n int)

func (*LicenseRecord) String 

func (m *LicenseRecord) String() string

func (*LicenseRecord) Unmarshal 

func (m *LicenseRecord) Unmarshal(dAtA []byte) error

func (*LicenseRecord) XXX_DiscardUnknown 

func (m *LicenseRecord) XXX_DiscardUnknown()

func (*LicenseRecord) XXX_Marshal 

func (m *LicenseRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LicenseRecord) XXX_Merge 

func (m *LicenseRecord) XXX_Merge(src proto.Message)

func (*LicenseRecord) XXX_Size 

func (m *LicenseRecord) XXX_Size() int

func (*LicenseRecord) XXX_Unmarshal 

func (m *LicenseRecord) XXX_Unmarshal(b []byte) error

type PauseRequest 

type PauseRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PauseRequest) Descriptor 

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

func (*PauseRequest) Marshal 

func (m *PauseRequest) Marshal() (dAtA []byte, err error)

func (*PauseRequest) MarshalLogObject 

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

func (*PauseRequest) MarshalTo 

func (m *PauseRequest) MarshalTo(dAtA []byte) (int, error)

func (*PauseRequest) MarshalToSizedBuffer 

func (m *PauseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PauseRequest) ProtoMessage 

func (*PauseRequest) ProtoMessage()

func (*PauseRequest) Reset 

func (m *PauseRequest) Reset()

func (*PauseRequest) Size 

func (m *PauseRequest) Size() (n int)

func (*PauseRequest) String 

func (m *PauseRequest) String() string

func (*PauseRequest) Unmarshal 

func (m *PauseRequest) Unmarshal(dAtA []byte) error

func (*PauseRequest) XXX_DiscardUnknown 

func (m *PauseRequest) XXX_DiscardUnknown()

func (*PauseRequest) XXX_Marshal 

func (m *PauseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PauseRequest) XXX_Merge 

func (m *PauseRequest) XXX_Merge(src proto.Message)

func (*PauseRequest) XXX_Size 

func (m *PauseRequest) XXX_Size() int

func (*PauseRequest) XXX_Unmarshal 

func (m *PauseRequest) XXX_Unmarshal(b []byte) error

type PauseResponse 

type PauseResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PauseResponse) Descriptor 

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

func (*PauseResponse) Marshal 

func (m *PauseResponse) Marshal() (dAtA []byte, err error)

func (*PauseResponse) MarshalLogObject 

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

func (*PauseResponse) MarshalTo 

func (m *PauseResponse) MarshalTo(dAtA []byte) (int, error)

func (*PauseResponse) MarshalToSizedBuffer 

func (m *PauseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PauseResponse) ProtoMessage 

func (*PauseResponse) ProtoMessage()

func (*PauseResponse) Reset 

func (m *PauseResponse) Reset()

func (*PauseResponse) Size 

func (m *PauseResponse) Size() (n int)

func (*PauseResponse) String 

func (m *PauseResponse) String() string

func (*PauseResponse) Unmarshal 

func (m *PauseResponse) Unmarshal(dAtA []byte) error

func (*PauseResponse) XXX_DiscardUnknown 

func (m *PauseResponse) XXX_DiscardUnknown()

func (*PauseResponse) XXX_Marshal 

func (m *PauseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PauseResponse) XXX_Merge 

func (m *PauseResponse) XXX_Merge(src proto.Message)

func (*PauseResponse) XXX_Size 

func (m *PauseResponse) XXX_Size() int

func (*PauseResponse) XXX_Unmarshal 

func (m *PauseResponse) XXX_Unmarshal(b []byte) error

type PauseStatusRequest 

type PauseStatusRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PauseStatusRequest) Descriptor 

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

func (*PauseStatusRequest) Marshal 

func (m *PauseStatusRequest) Marshal() (dAtA []byte, err error)

func (*PauseStatusRequest) MarshalLogObject 

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

func (*PauseStatusRequest) MarshalTo 

func (m *PauseStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*PauseStatusRequest) MarshalToSizedBuffer 

func (m *PauseStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PauseStatusRequest) ProtoMessage 

func (*PauseStatusRequest) ProtoMessage()

func (*PauseStatusRequest) Reset 

func (m *PauseStatusRequest) Reset()

func (*PauseStatusRequest) Size 

func (m *PauseStatusRequest) Size() (n int)

func (*PauseStatusRequest) String 

func (m *PauseStatusRequest) String() string

func (*PauseStatusRequest) Unmarshal 

func (m *PauseStatusRequest) Unmarshal(dAtA []byte) error

func (*PauseStatusRequest) XXX_DiscardUnknown 

func (m *PauseStatusRequest) XXX_DiscardUnknown()

func (*PauseStatusRequest) XXX_Marshal 

func (m *PauseStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PauseStatusRequest) XXX_Merge 

func (m *PauseStatusRequest) XXX_Merge(src proto.Message)

func (*PauseStatusRequest) XXX_Size 

func (m *PauseStatusRequest) XXX_Size() int

func (*PauseStatusRequest) XXX_Unmarshal 

func (m *PauseStatusRequest) XXX_Unmarshal(b []byte) error

type PauseStatusResponse 

type PauseStatusResponse struct {
	Status               PauseStatusResponse_PauseStatus `protobuf:"varint,1,opt,name=status,proto3,enum=enterprise_v2.PauseStatusResponse_PauseStatus" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*PauseStatusResponse) Descriptor 

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

func (*PauseStatusResponse) GetStatus 

func (m *PauseStatusResponse) GetStatus() PauseStatusResponse_PauseStatus

func (*PauseStatusResponse) Marshal 

func (m *PauseStatusResponse) Marshal() (dAtA []byte, err error)

func (*PauseStatusResponse) MarshalLogObject 

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

func (*PauseStatusResponse) MarshalTo 

func (m *PauseStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*PauseStatusResponse) MarshalToSizedBuffer 

func (m *PauseStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PauseStatusResponse) ProtoMessage 

func (*PauseStatusResponse) ProtoMessage()

func (*PauseStatusResponse) Reset 

func (m *PauseStatusResponse) Reset()

func (*PauseStatusResponse) Size 

func (m *PauseStatusResponse) Size() (n int)

func (*PauseStatusResponse) String 

func (m *PauseStatusResponse) String() string

func (*PauseStatusResponse) Unmarshal 

func (m *PauseStatusResponse) Unmarshal(dAtA []byte) error

func (*PauseStatusResponse) XXX_DiscardUnknown 

func (m *PauseStatusResponse) XXX_DiscardUnknown()

func (*PauseStatusResponse) XXX_Marshal 

func (m *PauseStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PauseStatusResponse) XXX_Merge 

func (m *PauseStatusResponse) XXX_Merge(src proto.Message)

func (*PauseStatusResponse) XXX_Size 

func (m *PauseStatusResponse) XXX_Size() int

func (*PauseStatusResponse) XXX_Unmarshal 

func (m *PauseStatusResponse) XXX_Unmarshal(b []byte) error

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) EnumDescriptor 

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

func (PauseStatusResponse_PauseStatus) String 

func (x PauseStatusResponse_PauseStatus) String() string

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) EnumDescriptor 

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

func (State) String 

func (x State) String() string

type TokenInfo 

type TokenInfo struct {
	// expires indicates when the current token expires (unset if there is no
	// current token)
	Expires              *types.Timestamp `protobuf:"bytes,1,opt,name=expires,proto3" json:"expires,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

TokenInfo contains information about the currently active enterprise token

func (*TokenInfo) Descriptor 

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

func (*TokenInfo) GetExpires 

func (m *TokenInfo) GetExpires() *types.Timestamp

func (*TokenInfo) Marshal 

func (m *TokenInfo) Marshal() (dAtA []byte, err error)

func (*TokenInfo) MarshalLogObject 

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

func (*TokenInfo) MarshalTo 

func (m *TokenInfo) MarshalTo(dAtA []byte) (int, error)

func (*TokenInfo) MarshalToSizedBuffer 

func (m *TokenInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TokenInfo) ProtoMessage 

func (*TokenInfo) ProtoMessage()

func (*TokenInfo) Reset 

func (m *TokenInfo) Reset()

func (*TokenInfo) Size 

func (m *TokenInfo) Size() (n int)

func (*TokenInfo) String 

func (m *TokenInfo) String() string

func (*TokenInfo) Unmarshal 

func (m *TokenInfo) Unmarshal(dAtA []byte) error

func (*TokenInfo) XXX_DiscardUnknown 

func (m *TokenInfo) XXX_DiscardUnknown()

func (*TokenInfo) XXX_Marshal 

func (m *TokenInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TokenInfo) XXX_Merge 

func (m *TokenInfo) XXX_Merge(src proto.Message)

func (*TokenInfo) XXX_Size 

func (m *TokenInfo) XXX_Size() int

func (*TokenInfo) XXX_Unmarshal 

func (m *TokenInfo) XXX_Unmarshal(b []byte) error

type UnimplementedAPIServer 

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) Activate 

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

func (*UnimplementedAPIServer) Deactivate 

func (*UnimplementedAPIServer) Deactivate(ctx context.Context, req *DeactivateRequest) (*DeactivateResponse, error)

func (*UnimplementedAPIServer) GetActivationCode 

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

func (*UnimplementedAPIServer) GetState 

func (*UnimplementedAPIServer) GetState(ctx context.Context, req *GetStateRequest) (*GetStateResponse, error)

func (*UnimplementedAPIServer) Heartbeat 

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

func (*UnimplementedAPIServer) Pause 

func (*UnimplementedAPIServer) Pause(ctx context.Context, req *PauseRequest) (*PauseResponse, error)

func (*UnimplementedAPIServer) PauseStatus 

func (*UnimplementedAPIServer) PauseStatus(ctx context.Context, req *PauseStatusRequest) (*PauseStatusResponse, error)

func (*UnimplementedAPIServer) Unpause 

func (*UnimplementedAPIServer) Unpause(ctx context.Context, req *UnpauseRequest) (*UnpauseResponse, error)

type UnpauseRequest 

type UnpauseRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnpauseRequest) Descriptor 

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

func (*UnpauseRequest) Marshal 

func (m *UnpauseRequest) Marshal() (dAtA []byte, err error)

func (*UnpauseRequest) MarshalLogObject 

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

func (*UnpauseRequest) MarshalTo 

func (m *UnpauseRequest) MarshalTo(dAtA []byte) (int, error)

func (*UnpauseRequest) MarshalToSizedBuffer 

func (m *UnpauseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnpauseRequest) ProtoMessage 

func (*UnpauseRequest) ProtoMessage()

func (*UnpauseRequest) Reset 

func (m *UnpauseRequest) Reset()

func (*UnpauseRequest) Size 

func (m *UnpauseRequest) Size() (n int)

func (*UnpauseRequest) String 

func (m *UnpauseRequest) String() string

func (*UnpauseRequest) Unmarshal 

func (m *UnpauseRequest) Unmarshal(dAtA []byte) error

func (*UnpauseRequest) XXX_DiscardUnknown 

func (m *UnpauseRequest) XXX_DiscardUnknown()

func (*UnpauseRequest) XXX_Marshal 

func (m *UnpauseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnpauseRequest) XXX_Merge 

func (m *UnpauseRequest) XXX_Merge(src proto.Message)

func (*UnpauseRequest) XXX_Size 

func (m *UnpauseRequest) XXX_Size() int

func (*UnpauseRequest) XXX_Unmarshal 

func (m *UnpauseRequest) XXX_Unmarshal(b []byte) error

type UnpauseResponse 

type UnpauseResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnpauseResponse) Descriptor 

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

func (*UnpauseResponse) Marshal 

func (m *UnpauseResponse) Marshal() (dAtA []byte, err error)

func (*UnpauseResponse) MarshalLogObject 

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

func (*UnpauseResponse) MarshalTo 

func (m *UnpauseResponse) MarshalTo(dAtA []byte) (int, error)

func (*UnpauseResponse) MarshalToSizedBuffer 

func (m *UnpauseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnpauseResponse) ProtoMessage 

func (*UnpauseResponse) ProtoMessage()

func (*UnpauseResponse) Reset 

func (m *UnpauseResponse) Reset()

func (*UnpauseResponse) Size 

func (m *UnpauseResponse) Size() (n int)

func (*UnpauseResponse) String 

func (m *UnpauseResponse) String() string

func (*UnpauseResponse) Unmarshal 

func (m *UnpauseResponse) Unmarshal(dAtA []byte) error

func (*UnpauseResponse) XXX_DiscardUnknown 

func (m *UnpauseResponse) XXX_DiscardUnknown()

func (*UnpauseResponse) XXX_Marshal 

func (m *UnpauseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnpauseResponse) XXX_Merge 

func (m *UnpauseResponse) XXX_Merge(src proto.Message)

func (*UnpauseResponse) XXX_Size 

func (m *UnpauseResponse) XXX_Size() int

func (*UnpauseResponse) XXX_Unmarshal 

func (m *UnpauseResponse) XXX_Unmarshal(b []byte) error

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.