internalpb

package
v1.126.1-rc Latest Latest
Warning

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

 Go to latest Published: Apr 2, 2025 License: AGPL-3.0 Imports: 12 Imported by: 3

Documentation

Overview

Package internalpb contains proto definitions for satellite internal tools.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DRPCRegisterJobQueue added in v1.124.4 

func DRPCRegisterJobQueue(mux drpc.Mux, impl DRPCJobQueueServer) error

func DRPCRegisterRepairCoordinator 

func DRPCRegisterRepairCoordinator(mux drpc.Mux, impl DRPCRepairCoordinatorServer) error

Types

type DRPCJobQueueClient added in v1.124.4 

type DRPCJobQueueClient interface {
	DRPCConn() drpc.Conn

	Push(ctx context.Context, in *JobQueuePushRequest) (*JobQueuePushResponse, error)
	PushBatch(ctx context.Context, in *JobQueuePushBatchRequest) (*JobQueuePushBatchResponse, error)
	Pop(ctx context.Context, in *JobQueuePopRequest) (*JobQueuePopResponse, error)
	Peek(ctx context.Context, in *JobQueuePeekRequest) (*JobQueuePeekResponse, error)
	Delete(ctx context.Context, in *JobQueueDeleteRequest) (*JobQueueDeleteResponse, error)
	Len(ctx context.Context, in *JobQueueLengthRequest) (*JobQueueLengthResponse, error)
	Inspect(ctx context.Context, in *JobQueueInspectRequest) (*JobQueueInspectResponse, error)
	Stat(ctx context.Context, in *JobQueueStatRequest) (*JobQueueStatResponse, error)
	Truncate(ctx context.Context, in *JobQueueTruncateRequest) (*JobQueueTruncateResponse, error)
	Clean(ctx context.Context, in *JobQueueCleanRequest) (*JobQueueCleanResponse, error)
	Trim(ctx context.Context, in *JobQueueTrimRequest) (*JobQueueTrimResponse, error)
	TestingSetAttemptedTime(ctx context.Context, in *JobQueueTestingSetAttemptedTimeRequest) (*JobQueueTestingSetAttemptedTimeResponse, error)
	TestingSetUpdatedTime(ctx context.Context, in *JobQueueTestingSetUpdatedTimeRequest) (*JobQueueTestingSetUpdatedTimeResponse, error)
}

func NewDRPCJobQueueClient added in v1.124.4 

func NewDRPCJobQueueClient(cc drpc.Conn) DRPCJobQueueClient

type DRPCJobQueueDescription added in v1.124.4 

type DRPCJobQueueDescription struct{}

func (DRPCJobQueueDescription) Method added in v1.124.4 

func (DRPCJobQueueDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCJobQueueDescription) NumMethods added in v1.124.4 

func (DRPCJobQueueDescription) NumMethods() int

type DRPCJobQueueServer added in v1.124.4 

type DRPCJobQueueServer interface {
	Push(context.Context, *JobQueuePushRequest) (*JobQueuePushResponse, error)
	PushBatch(context.Context, *JobQueuePushBatchRequest) (*JobQueuePushBatchResponse, error)
	Pop(context.Context, *JobQueuePopRequest) (*JobQueuePopResponse, error)
	Peek(context.Context, *JobQueuePeekRequest) (*JobQueuePeekResponse, error)
	Delete(context.Context, *JobQueueDeleteRequest) (*JobQueueDeleteResponse, error)
	Len(context.Context, *JobQueueLengthRequest) (*JobQueueLengthResponse, error)
	Inspect(context.Context, *JobQueueInspectRequest) (*JobQueueInspectResponse, error)
	Stat(context.Context, *JobQueueStatRequest) (*JobQueueStatResponse, error)
	Truncate(context.Context, *JobQueueTruncateRequest) (*JobQueueTruncateResponse, error)
	Clean(context.Context, *JobQueueCleanRequest) (*JobQueueCleanResponse, error)
	Trim(context.Context, *JobQueueTrimRequest) (*JobQueueTrimResponse, error)
	TestingSetAttemptedTime(context.Context, *JobQueueTestingSetAttemptedTimeRequest) (*JobQueueTestingSetAttemptedTimeResponse, error)
	TestingSetUpdatedTime(context.Context, *JobQueueTestingSetUpdatedTimeRequest) (*JobQueueTestingSetUpdatedTimeResponse, error)
}

type DRPCJobQueueUnimplementedServer added in v1.124.4 

type DRPCJobQueueUnimplementedServer struct{}

func (*DRPCJobQueueUnimplementedServer) Clean added in v1.124.4 

func (s *DRPCJobQueueUnimplementedServer) Clean(context.Context, *JobQueueCleanRequest) (*JobQueueCleanResponse, error)

func (*DRPCJobQueueUnimplementedServer) Delete added in v1.125.2 

func (s *DRPCJobQueueUnimplementedServer) Delete(context.Context, *JobQueueDeleteRequest) (*JobQueueDeleteResponse, error)

func (*DRPCJobQueueUnimplementedServer) Inspect added in v1.124.4 

func (s *DRPCJobQueueUnimplementedServer) Inspect(context.Context, *JobQueueInspectRequest) (*JobQueueInspectResponse, error)

func (*DRPCJobQueueUnimplementedServer) Len added in v1.124.4 

func (s *DRPCJobQueueUnimplementedServer) Len(context.Context, *JobQueueLengthRequest) (*JobQueueLengthResponse, error)

func (*DRPCJobQueueUnimplementedServer) Peek added in v1.124.4 

func (s *DRPCJobQueueUnimplementedServer) Peek(context.Context, *JobQueuePeekRequest) (*JobQueuePeekResponse, error)

func (*DRPCJobQueueUnimplementedServer) Pop added in v1.124.4 

func (s *DRPCJobQueueUnimplementedServer) Pop(context.Context, *JobQueuePopRequest) (*JobQueuePopResponse, error)

func (*DRPCJobQueueUnimplementedServer) Push added in v1.124.4 

func (s *DRPCJobQueueUnimplementedServer) Push(context.Context, *JobQueuePushRequest) (*JobQueuePushResponse, error)

func (*DRPCJobQueueUnimplementedServer) PushBatch added in v1.124.4 

func (s *DRPCJobQueueUnimplementedServer) PushBatch(context.Context, *JobQueuePushBatchRequest) (*JobQueuePushBatchResponse, error)

func (*DRPCJobQueueUnimplementedServer) Stat added in v1.125.2 

func (s *DRPCJobQueueUnimplementedServer) Stat(context.Context, *JobQueueStatRequest) (*JobQueueStatResponse, error)

func (*DRPCJobQueueUnimplementedServer) TestingSetAttemptedTime added in v1.125.2 

func (s *DRPCJobQueueUnimplementedServer) TestingSetAttemptedTime(context.Context, *JobQueueTestingSetAttemptedTimeRequest) (*JobQueueTestingSetAttemptedTimeResponse, error)

func (*DRPCJobQueueUnimplementedServer) TestingSetUpdatedTime added in v1.126.2 

func (s *DRPCJobQueueUnimplementedServer) TestingSetUpdatedTime(context.Context, *JobQueueTestingSetUpdatedTimeRequest) (*JobQueueTestingSetUpdatedTimeResponse, error)

func (*DRPCJobQueueUnimplementedServer) Trim added in v1.124.4 

func (s *DRPCJobQueueUnimplementedServer) Trim(context.Context, *JobQueueTrimRequest) (*JobQueueTrimResponse, error)

func (*DRPCJobQueueUnimplementedServer) Truncate added in v1.124.4 

func (s *DRPCJobQueueUnimplementedServer) Truncate(context.Context, *JobQueueTruncateRequest) (*JobQueueTruncateResponse, error)

type DRPCJobQueue_CleanStream added in v1.124.4 

type DRPCJobQueue_CleanStream interface {
	drpc.Stream
	SendAndClose(*JobQueueCleanResponse) error
}

type DRPCJobQueue_DeleteStream added in v1.125.2 

type DRPCJobQueue_DeleteStream interface {
	drpc.Stream
	SendAndClose(*JobQueueDeleteResponse) error
}

type DRPCJobQueue_InspectStream added in v1.124.4 

type DRPCJobQueue_InspectStream interface {
	drpc.Stream
	SendAndClose(*JobQueueInspectResponse) error
}

type DRPCJobQueue_LenStream added in v1.124.4 

type DRPCJobQueue_LenStream interface {
	drpc.Stream
	SendAndClose(*JobQueueLengthResponse) error
}

type DRPCJobQueue_PeekStream added in v1.124.4 

type DRPCJobQueue_PeekStream interface {
	drpc.Stream
	SendAndClose(*JobQueuePeekResponse) error
}

type DRPCJobQueue_PopStream added in v1.124.4 

type DRPCJobQueue_PopStream interface {
	drpc.Stream
	SendAndClose(*JobQueuePopResponse) error
}

type DRPCJobQueue_PushBatchStream added in v1.124.4 

type DRPCJobQueue_PushBatchStream interface {
	drpc.Stream
	SendAndClose(*JobQueuePushBatchResponse) error
}

type DRPCJobQueue_PushStream added in v1.124.4 

type DRPCJobQueue_PushStream interface {
	drpc.Stream
	SendAndClose(*JobQueuePushResponse) error
}

type DRPCJobQueue_StatStream added in v1.125.2 

type DRPCJobQueue_StatStream interface {
	drpc.Stream
	SendAndClose(*JobQueueStatResponse) error
}

type DRPCJobQueue_TestingSetAttemptedTimeStream added in v1.125.2 

type DRPCJobQueue_TestingSetAttemptedTimeStream interface {
	drpc.Stream
	SendAndClose(*JobQueueTestingSetAttemptedTimeResponse) error
}

type DRPCJobQueue_TestingSetUpdatedTimeStream added in v1.126.2 

type DRPCJobQueue_TestingSetUpdatedTimeStream interface {
	drpc.Stream
	SendAndClose(*JobQueueTestingSetUpdatedTimeResponse) error
}

type DRPCJobQueue_TrimStream added in v1.124.4 

type DRPCJobQueue_TrimStream interface {
	drpc.Stream
	SendAndClose(*JobQueueTrimResponse) error
}

type DRPCJobQueue_TruncateStream added in v1.124.4 

type DRPCJobQueue_TruncateStream interface {
	drpc.Stream
	SendAndClose(*JobQueueTruncateResponse) error
}

type DRPCRepairCoordinatorClient 

type DRPCRepairCoordinatorClient interface {
	DRPCConn() drpc.Conn

	RepairJob(ctx context.Context, in *RepairJobRequest) (*RepairJobResponse, error)
}

func NewDRPCRepairCoordinatorClient 

func NewDRPCRepairCoordinatorClient(cc drpc.Conn) DRPCRepairCoordinatorClient

type DRPCRepairCoordinatorDescription 

type DRPCRepairCoordinatorDescription struct{}

func (DRPCRepairCoordinatorDescription) Method 

func (DRPCRepairCoordinatorDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCRepairCoordinatorDescription) NumMethods 

func (DRPCRepairCoordinatorDescription) NumMethods() int

type DRPCRepairCoordinatorServer 

type DRPCRepairCoordinatorServer interface {
	RepairJob(context.Context, *RepairJobRequest) (*RepairJobResponse, error)
}

type DRPCRepairCoordinatorUnimplementedServer added in v1.26.2 

type DRPCRepairCoordinatorUnimplementedServer struct{}

func (*DRPCRepairCoordinatorUnimplementedServer) RepairJob added in v1.26.2 

func (s *DRPCRepairCoordinatorUnimplementedServer) RepairJob(context.Context, *RepairJobRequest) (*RepairJobResponse, error)

type DRPCRepairCoordinator_RepairJobStream 

type DRPCRepairCoordinator_RepairJobStream interface {
	drpc.Stream
	SendAndClose(*RepairJobResponse) error
}

type JobQueueAddPlacementQueueRequest added in v1.124.4 

type JobQueueAddPlacementQueueRequest struct {
	Placement            int32    `protobuf:"varint,1,opt,name=placement,proto3" json:"placement,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueAddPlacementQueueRequest) Descriptor added in v1.124.4 

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

func (*JobQueueAddPlacementQueueRequest) GetPlacement added in v1.124.4 

func (m *JobQueueAddPlacementQueueRequest) GetPlacement() int32

func (*JobQueueAddPlacementQueueRequest) ProtoMessage added in v1.124.4 

func (*JobQueueAddPlacementQueueRequest) ProtoMessage()

func (*JobQueueAddPlacementQueueRequest) Reset added in v1.124.4 

func (m *JobQueueAddPlacementQueueRequest) Reset()

func (*JobQueueAddPlacementQueueRequest) String added in v1.124.4 

func (m *JobQueueAddPlacementQueueRequest) String() string

func (*JobQueueAddPlacementQueueRequest) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueAddPlacementQueueRequest) XXX_DiscardUnknown()

func (*JobQueueAddPlacementQueueRequest) XXX_Marshal added in v1.124.4 

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

func (*JobQueueAddPlacementQueueRequest) XXX_Merge added in v1.124.4 

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

func (*JobQueueAddPlacementQueueRequest) XXX_Size added in v1.124.4 

func (m *JobQueueAddPlacementQueueRequest) XXX_Size() int

func (*JobQueueAddPlacementQueueRequest) XXX_Unmarshal added in v1.124.4 

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

type JobQueueAddPlacementQueueResponse added in v1.124.4 

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

func (*JobQueueAddPlacementQueueResponse) Descriptor added in v1.124.4 

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

func (*JobQueueAddPlacementQueueResponse) ProtoMessage added in v1.124.4 

func (*JobQueueAddPlacementQueueResponse) ProtoMessage()

func (*JobQueueAddPlacementQueueResponse) Reset added in v1.124.4 

func (m *JobQueueAddPlacementQueueResponse) Reset()

func (*JobQueueAddPlacementQueueResponse) String added in v1.124.4 

func (m *JobQueueAddPlacementQueueResponse) String() string

func (*JobQueueAddPlacementQueueResponse) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueAddPlacementQueueResponse) XXX_DiscardUnknown()

func (*JobQueueAddPlacementQueueResponse) XXX_Marshal added in v1.124.4 

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

func (*JobQueueAddPlacementQueueResponse) XXX_Merge added in v1.124.4 

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

func (*JobQueueAddPlacementQueueResponse) XXX_Size added in v1.124.4 

func (m *JobQueueAddPlacementQueueResponse) XXX_Size() int

func (*JobQueueAddPlacementQueueResponse) XXX_Unmarshal added in v1.124.4 

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

type JobQueueCleanRequest added in v1.124.4 

type JobQueueCleanRequest struct {
	Placement            int32     `protobuf:"varint,1,opt,name=placement,proto3" json:"placement,omitempty"`
	UpdatedBefore        time.Time `protobuf:"bytes,2,opt,name=updated_before,json=updatedBefore,proto3,stdtime" json:"updated_before"`
	AllPlacements        bool      `protobuf:"varint,3,opt,name=all_placements,json=allPlacements,proto3" json:"all_placements,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*JobQueueCleanRequest) Descriptor added in v1.124.4 

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

func (*JobQueueCleanRequest) GetAllPlacements added in v1.125.2 

func (m *JobQueueCleanRequest) GetAllPlacements() bool

func (*JobQueueCleanRequest) GetPlacement added in v1.124.4 

func (m *JobQueueCleanRequest) GetPlacement() int32

func (*JobQueueCleanRequest) GetUpdatedBefore added in v1.124.4 

func (m *JobQueueCleanRequest) GetUpdatedBefore() time.Time

func (*JobQueueCleanRequest) ProtoMessage added in v1.124.4 

func (*JobQueueCleanRequest) ProtoMessage()

func (*JobQueueCleanRequest) Reset added in v1.124.4 

func (m *JobQueueCleanRequest) Reset()

func (*JobQueueCleanRequest) String added in v1.124.4 

func (m *JobQueueCleanRequest) String() string

func (*JobQueueCleanRequest) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueCleanRequest) XXX_DiscardUnknown()

func (*JobQueueCleanRequest) XXX_Marshal added in v1.124.4 

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

func (*JobQueueCleanRequest) XXX_Merge added in v1.124.4 

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

func (*JobQueueCleanRequest) XXX_Size added in v1.124.4 

func (m *JobQueueCleanRequest) XXX_Size() int

func (*JobQueueCleanRequest) XXX_Unmarshal added in v1.124.4 

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

type JobQueueCleanResponse added in v1.124.4 

type JobQueueCleanResponse struct {
	RemovedSegments      int32    `protobuf:"varint,1,opt,name=removed_segments,json=removedSegments,proto3" json:"removed_segments,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueCleanResponse) Descriptor added in v1.124.4 

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

func (*JobQueueCleanResponse) GetRemovedSegments added in v1.124.4 

func (m *JobQueueCleanResponse) GetRemovedSegments() int32

func (*JobQueueCleanResponse) ProtoMessage added in v1.124.4 

func (*JobQueueCleanResponse) ProtoMessage()

func (*JobQueueCleanResponse) Reset added in v1.124.4 

func (m *JobQueueCleanResponse) Reset()

func (*JobQueueCleanResponse) String added in v1.124.4 

func (m *JobQueueCleanResponse) String() string

func (*JobQueueCleanResponse) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueCleanResponse) XXX_DiscardUnknown()

func (*JobQueueCleanResponse) XXX_Marshal added in v1.124.4 

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

func (*JobQueueCleanResponse) XXX_Merge added in v1.124.4 

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

func (*JobQueueCleanResponse) XXX_Size added in v1.124.4 

func (m *JobQueueCleanResponse) XXX_Size() int

func (*JobQueueCleanResponse) XXX_Unmarshal added in v1.124.4 

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

type JobQueueDeleteRequest added in v1.125.2 

type JobQueueDeleteRequest struct {
	StreamId             []byte   `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Position             uint64   `protobuf:"varint,2,opt,name=position,proto3" json:"position,omitempty"`
	Placement            int32    `protobuf:"varint,3,opt,name=placement,proto3" json:"placement,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueDeleteRequest) Descriptor added in v1.125.2 

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

func (*JobQueueDeleteRequest) GetPlacement added in v1.125.2 

func (m *JobQueueDeleteRequest) GetPlacement() int32

func (*JobQueueDeleteRequest) GetPosition added in v1.125.2 

func (m *JobQueueDeleteRequest) GetPosition() uint64

func (*JobQueueDeleteRequest) GetStreamId added in v1.125.2 

func (m *JobQueueDeleteRequest) GetStreamId() []byte

func (*JobQueueDeleteRequest) ProtoMessage added in v1.125.2 

func (*JobQueueDeleteRequest) ProtoMessage()

func (*JobQueueDeleteRequest) Reset added in v1.125.2 

func (m *JobQueueDeleteRequest) Reset()

func (*JobQueueDeleteRequest) String added in v1.125.2 

func (m *JobQueueDeleteRequest) String() string

func (*JobQueueDeleteRequest) XXX_DiscardUnknown added in v1.125.2 

func (m *JobQueueDeleteRequest) XXX_DiscardUnknown()

func (*JobQueueDeleteRequest) XXX_Marshal added in v1.125.2 

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

func (*JobQueueDeleteRequest) XXX_Merge added in v1.125.2 

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

func (*JobQueueDeleteRequest) XXX_Size added in v1.125.2 

func (m *JobQueueDeleteRequest) XXX_Size() int

func (*JobQueueDeleteRequest) XXX_Unmarshal added in v1.125.2 

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

type JobQueueDeleteResponse added in v1.125.2 

type JobQueueDeleteResponse struct {
	DidDelete            bool     `protobuf:"varint,1,opt,name=did_delete,json=didDelete,proto3" json:"did_delete,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueDeleteResponse) Descriptor added in v1.125.2 

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

func (*JobQueueDeleteResponse) GetDidDelete added in v1.125.2 

func (m *JobQueueDeleteResponse) GetDidDelete() bool

func (*JobQueueDeleteResponse) ProtoMessage added in v1.125.2 

func (*JobQueueDeleteResponse) ProtoMessage()

func (*JobQueueDeleteResponse) Reset added in v1.125.2 

func (m *JobQueueDeleteResponse) Reset()

func (*JobQueueDeleteResponse) String added in v1.125.2 

func (m *JobQueueDeleteResponse) String() string

func (*JobQueueDeleteResponse) XXX_DiscardUnknown added in v1.125.2 

func (m *JobQueueDeleteResponse) XXX_DiscardUnknown()

func (*JobQueueDeleteResponse) XXX_Marshal added in v1.125.2 

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

func (*JobQueueDeleteResponse) XXX_Merge added in v1.125.2 

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

func (*JobQueueDeleteResponse) XXX_Size added in v1.125.2 

func (m *JobQueueDeleteResponse) XXX_Size() int

func (*JobQueueDeleteResponse) XXX_Unmarshal added in v1.125.2 

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

type JobQueueDestroyPlacementQueueRequest added in v1.124.4 

type JobQueueDestroyPlacementQueueRequest struct {
	Placement            int32    `protobuf:"varint,1,opt,name=placement,proto3" json:"placement,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueDestroyPlacementQueueRequest) Descriptor added in v1.124.4 

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

func (*JobQueueDestroyPlacementQueueRequest) GetPlacement added in v1.124.4 

func (m *JobQueueDestroyPlacementQueueRequest) GetPlacement() int32

func (*JobQueueDestroyPlacementQueueRequest) ProtoMessage added in v1.124.4 

func (*JobQueueDestroyPlacementQueueRequest) ProtoMessage()

func (*JobQueueDestroyPlacementQueueRequest) Reset added in v1.124.4 

func (m *JobQueueDestroyPlacementQueueRequest) Reset()

func (*JobQueueDestroyPlacementQueueRequest) String added in v1.124.4 

func (m *JobQueueDestroyPlacementQueueRequest) String() string

func (*JobQueueDestroyPlacementQueueRequest) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueDestroyPlacementQueueRequest) XXX_DiscardUnknown()

func (*JobQueueDestroyPlacementQueueRequest) XXX_Marshal added in v1.124.4 

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

func (*JobQueueDestroyPlacementQueueRequest) XXX_Merge added in v1.124.4 

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

func (*JobQueueDestroyPlacementQueueRequest) XXX_Size added in v1.124.4 

func (m *JobQueueDestroyPlacementQueueRequest) XXX_Size() int

func (*JobQueueDestroyPlacementQueueRequest) XXX_Unmarshal added in v1.124.4 

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

type JobQueueDestroyPlacementQueueResponse added in v1.124.4 

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

func (*JobQueueDestroyPlacementQueueResponse) Descriptor added in v1.124.4 

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

func (*JobQueueDestroyPlacementQueueResponse) ProtoMessage added in v1.124.4 

func (*JobQueueDestroyPlacementQueueResponse) ProtoMessage()

func (*JobQueueDestroyPlacementQueueResponse) Reset added in v1.124.4 

func (m *JobQueueDestroyPlacementQueueResponse) Reset()

func (*JobQueueDestroyPlacementQueueResponse) String added in v1.124.4 

func (m *JobQueueDestroyPlacementQueueResponse) String() string

func (*JobQueueDestroyPlacementQueueResponse) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueDestroyPlacementQueueResponse) XXX_DiscardUnknown()

func (*JobQueueDestroyPlacementQueueResponse) XXX_Marshal added in v1.124.4 

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

func (*JobQueueDestroyPlacementQueueResponse) XXX_Merge added in v1.124.4 

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

func (*JobQueueDestroyPlacementQueueResponse) XXX_Size added in v1.124.4 

func (m *JobQueueDestroyPlacementQueueResponse) XXX_Size() int

func (*JobQueueDestroyPlacementQueueResponse) XXX_Unmarshal added in v1.124.4 

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

type JobQueueInspectRequest added in v1.124.4 

type JobQueueInspectRequest struct {
	StreamId             []byte   `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Position             uint64   `protobuf:"varint,2,opt,name=position,proto3" json:"position,omitempty"`
	Placement            int32    `protobuf:"varint,3,opt,name=placement,proto3" json:"placement,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueInspectRequest) Descriptor added in v1.124.4 

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

func (*JobQueueInspectRequest) GetPlacement added in v1.124.4 

func (m *JobQueueInspectRequest) GetPlacement() int32

func (*JobQueueInspectRequest) GetPosition added in v1.124.4 

func (m *JobQueueInspectRequest) GetPosition() uint64

func (*JobQueueInspectRequest) GetStreamId added in v1.124.4 

func (m *JobQueueInspectRequest) GetStreamId() []byte

func (*JobQueueInspectRequest) ProtoMessage added in v1.124.4 

func (*JobQueueInspectRequest) ProtoMessage()

func (*JobQueueInspectRequest) Reset added in v1.124.4 

func (m *JobQueueInspectRequest) Reset()

func (*JobQueueInspectRequest) String added in v1.124.4 

func (m *JobQueueInspectRequest) String() string

func (*JobQueueInspectRequest) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueInspectRequest) XXX_DiscardUnknown()

func (*JobQueueInspectRequest) XXX_Marshal added in v1.124.4 

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

func (*JobQueueInspectRequest) XXX_Merge added in v1.124.4 

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

func (*JobQueueInspectRequest) XXX_Size added in v1.124.4 

func (m *JobQueueInspectRequest) XXX_Size() int

func (*JobQueueInspectRequest) XXX_Unmarshal added in v1.124.4 

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

type JobQueueInspectResponse added in v1.124.4 

type JobQueueInspectResponse struct {
	Job                  *RepairJob `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Found                bool       `protobuf:"varint,2,opt,name=found,proto3" json:"found,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*JobQueueInspectResponse) Descriptor added in v1.124.4 

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

func (*JobQueueInspectResponse) GetFound added in v1.125.2 

func (m *JobQueueInspectResponse) GetFound() bool

func (*JobQueueInspectResponse) GetJob added in v1.124.4 

func (m *JobQueueInspectResponse) GetJob() *RepairJob

func (*JobQueueInspectResponse) ProtoMessage added in v1.124.4 

func (*JobQueueInspectResponse) ProtoMessage()

func (*JobQueueInspectResponse) Reset added in v1.124.4 

func (m *JobQueueInspectResponse) Reset()

func (*JobQueueInspectResponse) String added in v1.124.4 

func (m *JobQueueInspectResponse) String() string

func (*JobQueueInspectResponse) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueInspectResponse) XXX_DiscardUnknown()

func (*JobQueueInspectResponse) XXX_Marshal added in v1.124.4 

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

func (*JobQueueInspectResponse) XXX_Merge added in v1.124.4 

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

func (*JobQueueInspectResponse) XXX_Size added in v1.124.4 

func (m *JobQueueInspectResponse) XXX_Size() int

func (*JobQueueInspectResponse) XXX_Unmarshal added in v1.124.4 

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

type JobQueueLengthRequest added in v1.124.4 

type JobQueueLengthRequest struct {
	Placement            int32    `protobuf:"varint,1,opt,name=placement,proto3" json:"placement,omitempty"`
	AllPlacements        bool     `protobuf:"varint,2,opt,name=all_placements,json=allPlacements,proto3" json:"all_placements,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueLengthRequest) Descriptor added in v1.124.4 

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

func (*JobQueueLengthRequest) GetAllPlacements added in v1.125.2 

func (m *JobQueueLengthRequest) GetAllPlacements() bool

func (*JobQueueLengthRequest) GetPlacement added in v1.124.4 

func (m *JobQueueLengthRequest) GetPlacement() int32

func (*JobQueueLengthRequest) ProtoMessage added in v1.124.4 

func (*JobQueueLengthRequest) ProtoMessage()

func (*JobQueueLengthRequest) Reset added in v1.124.4 

func (m *JobQueueLengthRequest) Reset()

func (*JobQueueLengthRequest) String added in v1.124.4 

func (m *JobQueueLengthRequest) String() string

func (*JobQueueLengthRequest) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueLengthRequest) XXX_DiscardUnknown()

func (*JobQueueLengthRequest) XXX_Marshal added in v1.124.4 

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

func (*JobQueueLengthRequest) XXX_Merge added in v1.124.4 

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

func (*JobQueueLengthRequest) XXX_Size added in v1.124.4 

func (m *JobQueueLengthRequest) XXX_Size() int

func (*JobQueueLengthRequest) XXX_Unmarshal added in v1.124.4 

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

type JobQueueLengthResponse added in v1.124.4 

type JobQueueLengthResponse struct {
	RepairLength         int64    `protobuf:"varint,1,opt,name=repair_length,json=repairLength,proto3" json:"repair_length,omitempty"`
	RetryLength          int64    `protobuf:"varint,2,opt,name=retry_length,json=retryLength,proto3" json:"retry_length,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueLengthResponse) Descriptor added in v1.124.4 

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

func (*JobQueueLengthResponse) GetRepairLength added in v1.124.4 

func (m *JobQueueLengthResponse) GetRepairLength() int64

func (*JobQueueLengthResponse) GetRetryLength added in v1.124.4 

func (m *JobQueueLengthResponse) GetRetryLength() int64

func (*JobQueueLengthResponse) ProtoMessage added in v1.124.4 

func (*JobQueueLengthResponse) ProtoMessage()

func (*JobQueueLengthResponse) Reset added in v1.124.4 

func (m *JobQueueLengthResponse) Reset()

func (*JobQueueLengthResponse) String added in v1.124.4 

func (m *JobQueueLengthResponse) String() string

func (*JobQueueLengthResponse) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueLengthResponse) XXX_DiscardUnknown()

func (*JobQueueLengthResponse) XXX_Marshal added in v1.124.4 

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

func (*JobQueueLengthResponse) XXX_Merge added in v1.124.4 

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

func (*JobQueueLengthResponse) XXX_Size added in v1.124.4 

func (m *JobQueueLengthResponse) XXX_Size() int

func (*JobQueueLengthResponse) XXX_Unmarshal added in v1.124.4 

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

type JobQueuePeekRequest added in v1.124.4 

type JobQueuePeekRequest struct {
	IncludedPlacements   []int32  `protobuf:"varint,1,rep,packed,name=included_placements,json=includedPlacements,proto3" json:"included_placements,omitempty"`
	ExcludedPlacements   []int32  `protobuf:"varint,2,rep,packed,name=excluded_placements,json=excludedPlacements,proto3" json:"excluded_placements,omitempty"`
	Limit                int32    `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueuePeekRequest) Descriptor added in v1.124.4 

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

func (*JobQueuePeekRequest) GetExcludedPlacements added in v1.125.2 

func (m *JobQueuePeekRequest) GetExcludedPlacements() []int32

func (*JobQueuePeekRequest) GetIncludedPlacements added in v1.125.2 

func (m *JobQueuePeekRequest) GetIncludedPlacements() []int32

func (*JobQueuePeekRequest) GetLimit added in v1.125.2 

func (m *JobQueuePeekRequest) GetLimit() int32

func (*JobQueuePeekRequest) ProtoMessage added in v1.124.4 

func (*JobQueuePeekRequest) ProtoMessage()

func (*JobQueuePeekRequest) Reset added in v1.124.4 

func (m *JobQueuePeekRequest) Reset()

func (*JobQueuePeekRequest) String added in v1.124.4 

func (m *JobQueuePeekRequest) String() string

func (*JobQueuePeekRequest) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueuePeekRequest) XXX_DiscardUnknown()

func (*JobQueuePeekRequest) XXX_Marshal added in v1.124.4 

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

func (*JobQueuePeekRequest) XXX_Merge added in v1.124.4 

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

func (*JobQueuePeekRequest) XXX_Size added in v1.124.4 

func (m *JobQueuePeekRequest) XXX_Size() int

func (*JobQueuePeekRequest) XXX_Unmarshal added in v1.124.4 

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

type JobQueuePeekResponse added in v1.124.4 

type JobQueuePeekResponse struct {
	Jobs                 []*RepairJob `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*JobQueuePeekResponse) Descriptor added in v1.124.4 

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

func (*JobQueuePeekResponse) GetJobs added in v1.125.2 

func (m *JobQueuePeekResponse) GetJobs() []*RepairJob

func (*JobQueuePeekResponse) ProtoMessage added in v1.124.4 

func (*JobQueuePeekResponse) ProtoMessage()

func (*JobQueuePeekResponse) Reset added in v1.124.4 

func (m *JobQueuePeekResponse) Reset()

func (*JobQueuePeekResponse) String added in v1.124.4 

func (m *JobQueuePeekResponse) String() string

func (*JobQueuePeekResponse) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueuePeekResponse) XXX_DiscardUnknown()

func (*JobQueuePeekResponse) XXX_Marshal added in v1.124.4 

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

func (*JobQueuePeekResponse) XXX_Merge added in v1.124.4 

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

func (*JobQueuePeekResponse) XXX_Size added in v1.124.4 

func (m *JobQueuePeekResponse) XXX_Size() int

func (*JobQueuePeekResponse) XXX_Unmarshal added in v1.124.4 

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

type JobQueuePopRequest added in v1.124.4 

type JobQueuePopRequest struct {
	IncludedPlacements   []int32  `protobuf:"varint,1,rep,packed,name=included_placements,json=includedPlacements,proto3" json:"included_placements,omitempty"`
	ExcludedPlacements   []int32  `protobuf:"varint,2,rep,packed,name=excluded_placements,json=excludedPlacements,proto3" json:"excluded_placements,omitempty"`
	Limit                int32    `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueuePopRequest) Descriptor added in v1.124.4 

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

func (*JobQueuePopRequest) GetExcludedPlacements added in v1.124.4 

func (m *JobQueuePopRequest) GetExcludedPlacements() []int32

func (*JobQueuePopRequest) GetIncludedPlacements added in v1.124.4 

func (m *JobQueuePopRequest) GetIncludedPlacements() []int32

func (*JobQueuePopRequest) GetLimit added in v1.125.2 

func (m *JobQueuePopRequest) GetLimit() int32

func (*JobQueuePopRequest) ProtoMessage added in v1.124.4 

func (*JobQueuePopRequest) ProtoMessage()

func (*JobQueuePopRequest) Reset added in v1.124.4 

func (m *JobQueuePopRequest) Reset()

func (*JobQueuePopRequest) String added in v1.124.4 

func (m *JobQueuePopRequest) String() string

func (*JobQueuePopRequest) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueuePopRequest) XXX_DiscardUnknown()

func (*JobQueuePopRequest) XXX_Marshal added in v1.124.4 

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

func (*JobQueuePopRequest) XXX_Merge added in v1.124.4 

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

func (*JobQueuePopRequest) XXX_Size added in v1.124.4 

func (m *JobQueuePopRequest) XXX_Size() int

func (*JobQueuePopRequest) XXX_Unmarshal added in v1.124.4 

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

type JobQueuePopResponse added in v1.124.4 

type JobQueuePopResponse struct {
	Jobs                 []*RepairJob `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*JobQueuePopResponse) Descriptor added in v1.124.4 

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

func (*JobQueuePopResponse) GetJobs added in v1.125.2 

func (m *JobQueuePopResponse) GetJobs() []*RepairJob

func (*JobQueuePopResponse) ProtoMessage added in v1.124.4 

func (*JobQueuePopResponse) ProtoMessage()

func (*JobQueuePopResponse) Reset added in v1.124.4 

func (m *JobQueuePopResponse) Reset()

func (*JobQueuePopResponse) String added in v1.124.4 

func (m *JobQueuePopResponse) String() string

func (*JobQueuePopResponse) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueuePopResponse) XXX_DiscardUnknown()

func (*JobQueuePopResponse) XXX_Marshal added in v1.124.4 

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

func (*JobQueuePopResponse) XXX_Merge added in v1.124.4 

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

func (*JobQueuePopResponse) XXX_Size added in v1.124.4 

func (m *JobQueuePopResponse) XXX_Size() int

func (*JobQueuePopResponse) XXX_Unmarshal added in v1.124.4 

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

type JobQueuePushBatchRequest added in v1.124.4 

type JobQueuePushBatchRequest struct {
	Jobs                 []*RepairJob `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*JobQueuePushBatchRequest) Descriptor added in v1.124.4 

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

func (*JobQueuePushBatchRequest) GetJobs added in v1.124.4 

func (m *JobQueuePushBatchRequest) GetJobs() []*RepairJob

func (*JobQueuePushBatchRequest) ProtoMessage added in v1.124.4 

func (*JobQueuePushBatchRequest) ProtoMessage()

func (*JobQueuePushBatchRequest) Reset added in v1.124.4 

func (m *JobQueuePushBatchRequest) Reset()

func (*JobQueuePushBatchRequest) String added in v1.124.4 

func (m *JobQueuePushBatchRequest) String() string

func (*JobQueuePushBatchRequest) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueuePushBatchRequest) XXX_DiscardUnknown()

func (*JobQueuePushBatchRequest) XXX_Marshal added in v1.124.4 

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

func (*JobQueuePushBatchRequest) XXX_Merge added in v1.124.4 

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

func (*JobQueuePushBatchRequest) XXX_Size added in v1.124.4 

func (m *JobQueuePushBatchRequest) XXX_Size() int

func (*JobQueuePushBatchRequest) XXX_Unmarshal added in v1.124.4 

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

type JobQueuePushBatchResponse added in v1.124.4 

type JobQueuePushBatchResponse struct {
	NewlyInserted        []bool   `protobuf:"varint,1,rep,packed,name=newly_inserted,json=newlyInserted,proto3" json:"newly_inserted,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueuePushBatchResponse) Descriptor added in v1.124.4 

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

func (*JobQueuePushBatchResponse) GetNewlyInserted added in v1.124.4 

func (m *JobQueuePushBatchResponse) GetNewlyInserted() []bool

func (*JobQueuePushBatchResponse) ProtoMessage added in v1.124.4 

func (*JobQueuePushBatchResponse) ProtoMessage()

func (*JobQueuePushBatchResponse) Reset added in v1.124.4 

func (m *JobQueuePushBatchResponse) Reset()

func (*JobQueuePushBatchResponse) String added in v1.124.4 

func (m *JobQueuePushBatchResponse) String() string

func (*JobQueuePushBatchResponse) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueuePushBatchResponse) XXX_DiscardUnknown()

func (*JobQueuePushBatchResponse) XXX_Marshal added in v1.124.4 

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

func (*JobQueuePushBatchResponse) XXX_Merge added in v1.124.4 

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

func (*JobQueuePushBatchResponse) XXX_Size added in v1.124.4 

func (m *JobQueuePushBatchResponse) XXX_Size() int

func (*JobQueuePushBatchResponse) XXX_Unmarshal added in v1.124.4 

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

type JobQueuePushRequest added in v1.124.4 

type JobQueuePushRequest struct {
	Job                  *RepairJob `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*JobQueuePushRequest) Descriptor added in v1.124.4 

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

func (*JobQueuePushRequest) GetJob added in v1.124.4 

func (m *JobQueuePushRequest) GetJob() *RepairJob

func (*JobQueuePushRequest) ProtoMessage added in v1.124.4 

func (*JobQueuePushRequest) ProtoMessage()

func (*JobQueuePushRequest) Reset added in v1.124.4 

func (m *JobQueuePushRequest) Reset()

func (*JobQueuePushRequest) String added in v1.124.4 

func (m *JobQueuePushRequest) String() string

func (*JobQueuePushRequest) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueuePushRequest) XXX_DiscardUnknown()

func (*JobQueuePushRequest) XXX_Marshal added in v1.124.4 

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

func (*JobQueuePushRequest) XXX_Merge added in v1.124.4 

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

func (*JobQueuePushRequest) XXX_Size added in v1.124.4 

func (m *JobQueuePushRequest) XXX_Size() int

func (*JobQueuePushRequest) XXX_Unmarshal added in v1.124.4 

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

type JobQueuePushResponse added in v1.124.4 

type JobQueuePushResponse struct {
	NewlyInserted        bool     `protobuf:"varint,1,opt,name=newly_inserted,json=newlyInserted,proto3" json:"newly_inserted,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueuePushResponse) Descriptor added in v1.124.4 

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

func (*JobQueuePushResponse) GetNewlyInserted added in v1.124.4 

func (m *JobQueuePushResponse) GetNewlyInserted() bool

func (*JobQueuePushResponse) ProtoMessage added in v1.124.4 

func (*JobQueuePushResponse) ProtoMessage()

func (*JobQueuePushResponse) Reset added in v1.124.4 

func (m *JobQueuePushResponse) Reset()

func (*JobQueuePushResponse) String added in v1.124.4 

func (m *JobQueuePushResponse) String() string

func (*JobQueuePushResponse) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueuePushResponse) XXX_DiscardUnknown()

func (*JobQueuePushResponse) XXX_Marshal added in v1.124.4 

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

func (*JobQueuePushResponse) XXX_Merge added in v1.124.4 

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

func (*JobQueuePushResponse) XXX_Size added in v1.124.4 

func (m *JobQueuePushResponse) XXX_Size() int

func (*JobQueuePushResponse) XXX_Unmarshal added in v1.124.4 

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

type JobQueueStatRequest added in v1.125.2 

type JobQueueStatRequest struct {
	Placement            int32    `protobuf:"varint,1,opt,name=placement,proto3" json:"placement,omitempty"`
	AllPlacements        bool     `protobuf:"varint,2,opt,name=all_placements,json=allPlacements,proto3" json:"all_placements,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueStatRequest) Descriptor added in v1.125.2 

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

func (*JobQueueStatRequest) GetAllPlacements added in v1.125.2 

func (m *JobQueueStatRequest) GetAllPlacements() bool

func (*JobQueueStatRequest) GetPlacement added in v1.125.2 

func (m *JobQueueStatRequest) GetPlacement() int32

func (*JobQueueStatRequest) ProtoMessage added in v1.125.2 

func (*JobQueueStatRequest) ProtoMessage()

func (*JobQueueStatRequest) Reset added in v1.125.2 

func (m *JobQueueStatRequest) Reset()

func (*JobQueueStatRequest) String added in v1.125.2 

func (m *JobQueueStatRequest) String() string

func (*JobQueueStatRequest) XXX_DiscardUnknown added in v1.125.2 

func (m *JobQueueStatRequest) XXX_DiscardUnknown()

func (*JobQueueStatRequest) XXX_Marshal added in v1.125.2 

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

func (*JobQueueStatRequest) XXX_Merge added in v1.125.2 

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

func (*JobQueueStatRequest) XXX_Size added in v1.125.2 

func (m *JobQueueStatRequest) XXX_Size() int

func (*JobQueueStatRequest) XXX_Unmarshal added in v1.125.2 

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

type JobQueueStatResponse added in v1.125.2 

type JobQueueStatResponse struct {
	Stats                []*QueueStat `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*JobQueueStatResponse) Descriptor added in v1.125.2 

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

func (*JobQueueStatResponse) GetStats added in v1.125.2 

func (m *JobQueueStatResponse) GetStats() []*QueueStat

func (*JobQueueStatResponse) ProtoMessage added in v1.125.2 

func (*JobQueueStatResponse) ProtoMessage()

func (*JobQueueStatResponse) Reset added in v1.125.2 

func (m *JobQueueStatResponse) Reset()

func (*JobQueueStatResponse) String added in v1.125.2 

func (m *JobQueueStatResponse) String() string

func (*JobQueueStatResponse) XXX_DiscardUnknown added in v1.125.2 

func (m *JobQueueStatResponse) XXX_DiscardUnknown()

func (*JobQueueStatResponse) XXX_Marshal added in v1.125.2 

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

func (*JobQueueStatResponse) XXX_Merge added in v1.125.2 

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

func (*JobQueueStatResponse) XXX_Size added in v1.125.2 

func (m *JobQueueStatResponse) XXX_Size() int

func (*JobQueueStatResponse) XXX_Unmarshal added in v1.125.2 

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

type JobQueueTestingSetAttemptedTimeRequest added in v1.125.2 

type JobQueueTestingSetAttemptedTimeRequest struct {
	Placement            int32     `protobuf:"varint,1,opt,name=placement,proto3" json:"placement,omitempty"`
	StreamId             []byte    `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Position             uint64    `protobuf:"varint,3,opt,name=position,proto3" json:"position,omitempty"`
	NewTime              time.Time `protobuf:"bytes,4,opt,name=new_time,json=newTime,proto3,stdtime" json:"new_time"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*JobQueueTestingSetAttemptedTimeRequest) Descriptor added in v1.125.2 

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

func (*JobQueueTestingSetAttemptedTimeRequest) GetNewTime added in v1.125.2 

func (m *JobQueueTestingSetAttemptedTimeRequest) GetNewTime() time.Time

func (*JobQueueTestingSetAttemptedTimeRequest) GetPlacement added in v1.125.2 

func (m *JobQueueTestingSetAttemptedTimeRequest) GetPlacement() int32

func (*JobQueueTestingSetAttemptedTimeRequest) GetPosition added in v1.125.2 

func (m *JobQueueTestingSetAttemptedTimeRequest) GetPosition() uint64

func (*JobQueueTestingSetAttemptedTimeRequest) GetStreamId added in v1.125.2 

func (m *JobQueueTestingSetAttemptedTimeRequest) GetStreamId() []byte

func (*JobQueueTestingSetAttemptedTimeRequest) ProtoMessage added in v1.125.2 

func (*JobQueueTestingSetAttemptedTimeRequest) ProtoMessage()

func (*JobQueueTestingSetAttemptedTimeRequest) Reset added in v1.125.2 

func (m *JobQueueTestingSetAttemptedTimeRequest) Reset()

func (*JobQueueTestingSetAttemptedTimeRequest) String added in v1.125.2 

func (m *JobQueueTestingSetAttemptedTimeRequest) String() string

func (*JobQueueTestingSetAttemptedTimeRequest) XXX_DiscardUnknown added in v1.125.2 

func (m *JobQueueTestingSetAttemptedTimeRequest) XXX_DiscardUnknown()

func (*JobQueueTestingSetAttemptedTimeRequest) XXX_Marshal added in v1.125.2 

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

func (*JobQueueTestingSetAttemptedTimeRequest) XXX_Merge added in v1.125.2 

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

func (*JobQueueTestingSetAttemptedTimeRequest) XXX_Size added in v1.125.2 

func (m *JobQueueTestingSetAttemptedTimeRequest) XXX_Size() int

func (*JobQueueTestingSetAttemptedTimeRequest) XXX_Unmarshal added in v1.125.2 

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

type JobQueueTestingSetAttemptedTimeResponse added in v1.125.2 

type JobQueueTestingSetAttemptedTimeResponse struct {
	RowsAffected         int32    `protobuf:"varint,1,opt,name=rows_affected,json=rowsAffected,proto3" json:"rows_affected,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueTestingSetAttemptedTimeResponse) Descriptor added in v1.125.2 

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

func (*JobQueueTestingSetAttemptedTimeResponse) GetRowsAffected added in v1.125.2 

func (m *JobQueueTestingSetAttemptedTimeResponse) GetRowsAffected() int32

func (*JobQueueTestingSetAttemptedTimeResponse) ProtoMessage added in v1.125.2 

func (*JobQueueTestingSetAttemptedTimeResponse) ProtoMessage()

func (*JobQueueTestingSetAttemptedTimeResponse) Reset added in v1.125.2 

func (m *JobQueueTestingSetAttemptedTimeResponse) Reset()

func (*JobQueueTestingSetAttemptedTimeResponse) String added in v1.125.2 

func (m *JobQueueTestingSetAttemptedTimeResponse) String() string

func (*JobQueueTestingSetAttemptedTimeResponse) XXX_DiscardUnknown added in v1.125.2 

func (m *JobQueueTestingSetAttemptedTimeResponse) XXX_DiscardUnknown()

func (*JobQueueTestingSetAttemptedTimeResponse) XXX_Marshal added in v1.125.2 

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

func (*JobQueueTestingSetAttemptedTimeResponse) XXX_Merge added in v1.125.2 

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

func (*JobQueueTestingSetAttemptedTimeResponse) XXX_Size added in v1.125.2 

func (m *JobQueueTestingSetAttemptedTimeResponse) XXX_Size() int

func (*JobQueueTestingSetAttemptedTimeResponse) XXX_Unmarshal added in v1.125.2 

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

type JobQueueTestingSetUpdatedTimeRequest added in v1.126.2 

type JobQueueTestingSetUpdatedTimeRequest struct {
	Placement            int32     `protobuf:"varint,1,opt,name=placement,proto3" json:"placement,omitempty"`
	StreamId             []byte    `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Position             uint64    `protobuf:"varint,3,opt,name=position,proto3" json:"position,omitempty"`
	NewTime              time.Time `protobuf:"bytes,4,opt,name=new_time,json=newTime,proto3,stdtime" json:"new_time"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*JobQueueTestingSetUpdatedTimeRequest) Descriptor added in v1.126.2 

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

func (*JobQueueTestingSetUpdatedTimeRequest) GetNewTime added in v1.126.2 

func (m *JobQueueTestingSetUpdatedTimeRequest) GetNewTime() time.Time

func (*JobQueueTestingSetUpdatedTimeRequest) GetPlacement added in v1.126.2 

func (m *JobQueueTestingSetUpdatedTimeRequest) GetPlacement() int32

func (*JobQueueTestingSetUpdatedTimeRequest) GetPosition added in v1.126.2 

func (m *JobQueueTestingSetUpdatedTimeRequest) GetPosition() uint64

func (*JobQueueTestingSetUpdatedTimeRequest) GetStreamId added in v1.126.2 

func (m *JobQueueTestingSetUpdatedTimeRequest) GetStreamId() []byte

func (*JobQueueTestingSetUpdatedTimeRequest) ProtoMessage added in v1.126.2 

func (*JobQueueTestingSetUpdatedTimeRequest) ProtoMessage()

func (*JobQueueTestingSetUpdatedTimeRequest) Reset added in v1.126.2 

func (m *JobQueueTestingSetUpdatedTimeRequest) Reset()

func (*JobQueueTestingSetUpdatedTimeRequest) String added in v1.126.2 

func (m *JobQueueTestingSetUpdatedTimeRequest) String() string

func (*JobQueueTestingSetUpdatedTimeRequest) XXX_DiscardUnknown added in v1.126.2 

func (m *JobQueueTestingSetUpdatedTimeRequest) XXX_DiscardUnknown()

func (*JobQueueTestingSetUpdatedTimeRequest) XXX_Marshal added in v1.126.2 

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

func (*JobQueueTestingSetUpdatedTimeRequest) XXX_Merge added in v1.126.2 

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

func (*JobQueueTestingSetUpdatedTimeRequest) XXX_Size added in v1.126.2 

func (m *JobQueueTestingSetUpdatedTimeRequest) XXX_Size() int

func (*JobQueueTestingSetUpdatedTimeRequest) XXX_Unmarshal added in v1.126.2 

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

type JobQueueTestingSetUpdatedTimeResponse added in v1.126.2 

type JobQueueTestingSetUpdatedTimeResponse struct {
	RowsAffected         int32    `protobuf:"varint,1,opt,name=rows_affected,json=rowsAffected,proto3" json:"rows_affected,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueTestingSetUpdatedTimeResponse) Descriptor added in v1.126.2 

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

func (*JobQueueTestingSetUpdatedTimeResponse) GetRowsAffected added in v1.126.2 

func (m *JobQueueTestingSetUpdatedTimeResponse) GetRowsAffected() int32

func (*JobQueueTestingSetUpdatedTimeResponse) ProtoMessage added in v1.126.2 

func (*JobQueueTestingSetUpdatedTimeResponse) ProtoMessage()

func (*JobQueueTestingSetUpdatedTimeResponse) Reset added in v1.126.2 

func (m *JobQueueTestingSetUpdatedTimeResponse) Reset()

func (*JobQueueTestingSetUpdatedTimeResponse) String added in v1.126.2 

func (m *JobQueueTestingSetUpdatedTimeResponse) String() string

func (*JobQueueTestingSetUpdatedTimeResponse) XXX_DiscardUnknown added in v1.126.2 

func (m *JobQueueTestingSetUpdatedTimeResponse) XXX_DiscardUnknown()

func (*JobQueueTestingSetUpdatedTimeResponse) XXX_Marshal added in v1.126.2 

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

func (*JobQueueTestingSetUpdatedTimeResponse) XXX_Merge added in v1.126.2 

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

func (*JobQueueTestingSetUpdatedTimeResponse) XXX_Size added in v1.126.2 

func (m *JobQueueTestingSetUpdatedTimeResponse) XXX_Size() int

func (*JobQueueTestingSetUpdatedTimeResponse) XXX_Unmarshal added in v1.126.2 

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

type JobQueueTrimRequest added in v1.124.4 

type JobQueueTrimRequest struct {
	Placement            int32    `protobuf:"varint,1,opt,name=placement,proto3" json:"placement,omitempty"`
	HealthGreaterThan    float64  `protobuf:"fixed64,2,opt,name=health_greater_than,json=healthGreaterThan,proto3" json:"health_greater_than,omitempty"`
	AllPlacements        bool     `protobuf:"varint,3,opt,name=all_placements,json=allPlacements,proto3" json:"all_placements,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueTrimRequest) Descriptor added in v1.124.4 

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

func (*JobQueueTrimRequest) GetAllPlacements added in v1.125.2 

func (m *JobQueueTrimRequest) GetAllPlacements() bool

func (*JobQueueTrimRequest) GetHealthGreaterThan added in v1.124.4 

func (m *JobQueueTrimRequest) GetHealthGreaterThan() float64

func (*JobQueueTrimRequest) GetPlacement added in v1.124.4 

func (m *JobQueueTrimRequest) GetPlacement() int32

func (*JobQueueTrimRequest) ProtoMessage added in v1.124.4 

func (*JobQueueTrimRequest) ProtoMessage()

func (*JobQueueTrimRequest) Reset added in v1.124.4 

func (m *JobQueueTrimRequest) Reset()

func (*JobQueueTrimRequest) String added in v1.124.4 

func (m *JobQueueTrimRequest) String() string

func (*JobQueueTrimRequest) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueTrimRequest) XXX_DiscardUnknown()

func (*JobQueueTrimRequest) XXX_Marshal added in v1.124.4 

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

func (*JobQueueTrimRequest) XXX_Merge added in v1.124.4 

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

func (*JobQueueTrimRequest) XXX_Size added in v1.124.4 

func (m *JobQueueTrimRequest) XXX_Size() int

func (*JobQueueTrimRequest) XXX_Unmarshal added in v1.124.4 

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

type JobQueueTrimResponse added in v1.124.4 

type JobQueueTrimResponse struct {
	RemovedSegments      int32    `protobuf:"varint,1,opt,name=removed_segments,json=removedSegments,proto3" json:"removed_segments,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueTrimResponse) Descriptor added in v1.124.4 

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

func (*JobQueueTrimResponse) GetRemovedSegments added in v1.124.4 

func (m *JobQueueTrimResponse) GetRemovedSegments() int32

func (*JobQueueTrimResponse) ProtoMessage added in v1.124.4 

func (*JobQueueTrimResponse) ProtoMessage()

func (*JobQueueTrimResponse) Reset added in v1.124.4 

func (m *JobQueueTrimResponse) Reset()

func (*JobQueueTrimResponse) String added in v1.124.4 

func (m *JobQueueTrimResponse) String() string

func (*JobQueueTrimResponse) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueTrimResponse) XXX_DiscardUnknown()

func (*JobQueueTrimResponse) XXX_Marshal added in v1.124.4 

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

func (*JobQueueTrimResponse) XXX_Merge added in v1.124.4 

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

func (*JobQueueTrimResponse) XXX_Size added in v1.124.4 

func (m *JobQueueTrimResponse) XXX_Size() int

func (*JobQueueTrimResponse) XXX_Unmarshal added in v1.124.4 

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

type JobQueueTruncateRequest added in v1.124.4 

type JobQueueTruncateRequest struct {
	Placement            int32    `protobuf:"varint,1,opt,name=placement,proto3" json:"placement,omitempty"`
	AllPlacements        bool     `protobuf:"varint,2,opt,name=all_placements,json=allPlacements,proto3" json:"all_placements,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobQueueTruncateRequest) Descriptor added in v1.124.4 

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

func (*JobQueueTruncateRequest) GetAllPlacements added in v1.125.2 

func (m *JobQueueTruncateRequest) GetAllPlacements() bool

func (*JobQueueTruncateRequest) GetPlacement added in v1.124.4 

func (m *JobQueueTruncateRequest) GetPlacement() int32

func (*JobQueueTruncateRequest) ProtoMessage added in v1.124.4 

func (*JobQueueTruncateRequest) ProtoMessage()

func (*JobQueueTruncateRequest) Reset added in v1.124.4 

func (m *JobQueueTruncateRequest) Reset()

func (*JobQueueTruncateRequest) String added in v1.124.4 

func (m *JobQueueTruncateRequest) String() string

func (*JobQueueTruncateRequest) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueTruncateRequest) XXX_DiscardUnknown()

func (*JobQueueTruncateRequest) XXX_Marshal added in v1.124.4 

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

func (*JobQueueTruncateRequest) XXX_Merge added in v1.124.4 

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

func (*JobQueueTruncateRequest) XXX_Size added in v1.124.4 

func (m *JobQueueTruncateRequest) XXX_Size() int

func (*JobQueueTruncateRequest) XXX_Unmarshal added in v1.124.4 

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

type JobQueueTruncateResponse added in v1.124.4 

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

func (*JobQueueTruncateResponse) Descriptor added in v1.124.4 

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

func (*JobQueueTruncateResponse) ProtoMessage added in v1.124.4 

func (*JobQueueTruncateResponse) ProtoMessage()

func (*JobQueueTruncateResponse) Reset added in v1.124.4 

func (m *JobQueueTruncateResponse) Reset()

func (*JobQueueTruncateResponse) String added in v1.124.4 

func (m *JobQueueTruncateResponse) String() string

func (*JobQueueTruncateResponse) XXX_DiscardUnknown added in v1.124.4 

func (m *JobQueueTruncateResponse) XXX_DiscardUnknown()

func (*JobQueueTruncateResponse) XXX_Marshal added in v1.124.4 

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

func (*JobQueueTruncateResponse) XXX_Merge added in v1.124.4 

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

func (*JobQueueTruncateResponse) XXX_Size added in v1.124.4 

func (m *JobQueueTruncateResponse) XXX_Size() int

func (*JobQueueTruncateResponse) XXX_Unmarshal added in v1.124.4 

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

type NodeID 

type NodeID = storj.NodeID

NodeID is an alias to storj.NodeID for use in generated protobuf code.

type OrderLimitMetadata added in v1.19.9 

type OrderLimitMetadata struct {
	BucketId                   []byte   `protobuf:"bytes,1,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	ProjectBucketPrefix        []byte   `protobuf:"bytes,2,opt,name=project_bucket_prefix,json=projectBucketPrefix,proto3" json:"project_bucket_prefix,omitempty"`
	CompactProjectBucketPrefix []byte   `` /* 143-byte string literal not displayed */
	ProductId                  int32    `protobuf:"varint,4,opt,name=product_id,json=productId,proto3" json:"product_id,omitempty"`
	XXX_NoUnkeyedLiteral       struct{} `json:"-"`
	XXX_unrecognized           []byte   `json:"-"`
	XXX_sizecache              int32    `json:"-"`
}

OrderLimitMetadata is used to transmit meta information about an order limit. This data will be encrypted.

func (*OrderLimitMetadata) Descriptor added in v1.19.9 

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

func (*OrderLimitMetadata) GetBucketId added in v1.19.9 

func (m *OrderLimitMetadata) GetBucketId() []byte

func (*OrderLimitMetadata) GetCompactProjectBucketPrefix added in v1.19.9 

func (m *OrderLimitMetadata) GetCompactProjectBucketPrefix() []byte

func (*OrderLimitMetadata) GetProductId added in v1.123.4 

func (m *OrderLimitMetadata) GetProductId() int32

func (*OrderLimitMetadata) GetProjectBucketPrefix added in v1.19.9 

func (m *OrderLimitMetadata) GetProjectBucketPrefix() []byte

func (*OrderLimitMetadata) ProtoMessage added in v1.19.9 

func (*OrderLimitMetadata) ProtoMessage()

func (*OrderLimitMetadata) Reset added in v1.19.9 

func (m *OrderLimitMetadata) Reset()

func (*OrderLimitMetadata) String added in v1.19.9 

func (m *OrderLimitMetadata) String() string

func (*OrderLimitMetadata) XXX_DiscardUnknown added in v1.19.9 

func (m *OrderLimitMetadata) XXX_DiscardUnknown()

func (*OrderLimitMetadata) XXX_Marshal added in v1.19.9 

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

func (*OrderLimitMetadata) XXX_Merge added in v1.19.9 

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

func (*OrderLimitMetadata) XXX_Size added in v1.19.9 

func (m *OrderLimitMetadata) XXX_Size() int

func (*OrderLimitMetadata) XXX_Unmarshal added in v1.19.9 

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

type PieceID 

type PieceID = storj.PieceID

PieceID is an alias to storj.PieceID for use in generated protobuf code.

type QueueStat added in v1.125.2 

type QueueStat struct {
	Placement            int32      `protobuf:"varint,1,opt,name=placement,proto3" json:"placement,omitempty"`
	Count                int64      `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	MaxInsertedAt        time.Time  `protobuf:"bytes,3,opt,name=max_inserted_at,json=maxInsertedAt,proto3,stdtime" json:"max_inserted_at"`
	MinInsertedAt        time.Time  `protobuf:"bytes,4,opt,name=min_inserted_at,json=minInsertedAt,proto3,stdtime" json:"min_inserted_at"`
	MaxAttemptedAt       *time.Time `protobuf:"bytes,5,opt,name=max_attempted_at,json=maxAttemptedAt,proto3,stdtime" json:"max_attempted_at,omitempty"`
	MinAttemptedAt       *time.Time `protobuf:"bytes,6,opt,name=min_attempted_at,json=minAttemptedAt,proto3,stdtime" json:"min_attempted_at,omitempty"`
	MinSegmentHealth     float64    `protobuf:"fixed64,7,opt,name=min_segment_health,json=minSegmentHealth,proto3" json:"min_segment_health,omitempty"`
	MaxSegmentHealth     float64    `protobuf:"fixed64,8,opt,name=max_segment_health,json=maxSegmentHealth,proto3" json:"max_segment_health,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*QueueStat) Descriptor added in v1.125.2 

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

func (*QueueStat) GetCount added in v1.125.2 

func (m *QueueStat) GetCount() int64

func (*QueueStat) GetMaxAttemptedAt added in v1.125.2 

func (m *QueueStat) GetMaxAttemptedAt() *time.Time

func (*QueueStat) GetMaxInsertedAt added in v1.125.2 

func (m *QueueStat) GetMaxInsertedAt() time.Time

func (*QueueStat) GetMaxSegmentHealth added in v1.125.2 

func (m *QueueStat) GetMaxSegmentHealth() float64

func (*QueueStat) GetMinAttemptedAt added in v1.125.2 

func (m *QueueStat) GetMinAttemptedAt() *time.Time

func (*QueueStat) GetMinInsertedAt added in v1.125.2 

func (m *QueueStat) GetMinInsertedAt() time.Time

func (*QueueStat) GetMinSegmentHealth added in v1.125.2 

func (m *QueueStat) GetMinSegmentHealth() float64

func (*QueueStat) GetPlacement added in v1.125.2 

func (m *QueueStat) GetPlacement() int32

func (*QueueStat) ProtoMessage added in v1.125.2 

func (*QueueStat) ProtoMessage()

func (*QueueStat) Reset added in v1.125.2 

func (m *QueueStat) Reset()

func (*QueueStat) String added in v1.125.2 

func (m *QueueStat) String() string

func (*QueueStat) XXX_DiscardUnknown added in v1.125.2 

func (m *QueueStat) XXX_DiscardUnknown()

func (*QueueStat) XXX_Marshal added in v1.125.2 

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

func (*QueueStat) XXX_Merge added in v1.125.2 

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

func (*QueueStat) XXX_Size added in v1.125.2 

func (m *QueueStat) XXX_Size() int

func (*QueueStat) XXX_Unmarshal added in v1.125.2 

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

type RepairJob added in v1.124.4 

type RepairJob struct {
	StreamId             []byte     `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Position             uint64     `protobuf:"varint,2,opt,name=position,proto3" json:"position,omitempty"`
	Health               float64    `protobuf:"fixed64,3,opt,name=health,proto3" json:"health,omitempty"`
	InsertedAt           *time.Time `protobuf:"bytes,4,opt,name=inserted_at,json=insertedAt,proto3,stdtime" json:"inserted_at,omitempty"`
	LastAttemptedAt      *time.Time `protobuf:"bytes,5,opt,name=last_attempted_at,json=lastAttemptedAt,proto3,stdtime" json:"last_attempted_at,omitempty"`
	NumAttempts          int32      `protobuf:"varint,6,opt,name=num_attempts,json=numAttempts,proto3" json:"num_attempts,omitempty"`
	Placement            int32      `protobuf:"varint,7,opt,name=placement,proto3" json:"placement,omitempty"`
	NumMissing           int32      `protobuf:"varint,8,opt,name=num_missing,json=numMissing,proto3" json:"num_missing,omitempty"`
	NumOutOfPlacement    int32      `protobuf:"varint,9,opt,name=num_out_of_placement,json=numOutOfPlacement,proto3" json:"num_out_of_placement,omitempty"`
	UpdatedAt            *time.Time `protobuf:"bytes,10,opt,name=updated_at,json=updatedAt,proto3,stdtime" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*RepairJob) Descriptor added in v1.124.4 

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

func (*RepairJob) GetHealth added in v1.124.4 

func (m *RepairJob) GetHealth() float64

func (*RepairJob) GetInsertedAt added in v1.124.4 

func (m *RepairJob) GetInsertedAt() *time.Time

func (*RepairJob) GetLastAttemptedAt added in v1.124.4 

func (m *RepairJob) GetLastAttemptedAt() *time.Time

func (*RepairJob) GetNumAttempts added in v1.124.4 

func (m *RepairJob) GetNumAttempts() int32

func (*RepairJob) GetNumMissing added in v1.124.4 

func (m *RepairJob) GetNumMissing() int32

func (*RepairJob) GetNumOutOfPlacement added in v1.124.4 

func (m *RepairJob) GetNumOutOfPlacement() int32

func (*RepairJob) GetPlacement added in v1.124.4 

func (m *RepairJob) GetPlacement() int32

func (*RepairJob) GetPosition added in v1.124.4 

func (m *RepairJob) GetPosition() uint64

func (*RepairJob) GetStreamId added in v1.124.4 

func (m *RepairJob) GetStreamId() []byte

func (*RepairJob) GetUpdatedAt added in v1.124.4 

func (m *RepairJob) GetUpdatedAt() *time.Time

func (*RepairJob) ProtoMessage added in v1.124.4 

func (*RepairJob) ProtoMessage()

func (*RepairJob) Reset added in v1.124.4 

func (m *RepairJob) Reset()

func (*RepairJob) String added in v1.124.4 

func (m *RepairJob) String() string

func (*RepairJob) XXX_DiscardUnknown added in v1.124.4 

func (m *RepairJob) XXX_DiscardUnknown()

func (*RepairJob) XXX_Marshal added in v1.124.4 

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

func (*RepairJob) XXX_Merge added in v1.124.4 

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

func (*RepairJob) XXX_Size added in v1.124.4 

func (m *RepairJob) XXX_Size() int

func (*RepairJob) XXX_Unmarshal added in v1.124.4 

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

type RepairJobDefinition 

type RepairJobDefinition struct {
	// Identifier for this job
	JobId []byte `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Signed GET orders for all believed-healthy pieces to be downloaded
	GetOrders []*pb.AddressedOrderLimit `protobuf:"bytes,2,rep,name=get_orders,json=getOrders,proto3" json:"get_orders,omitempty"`
	// Private piece key to use for fetching
	PrivateKeyForGet []byte `protobuf:"bytes,3,opt,name=private_key_for_get,json=privateKeyForGet,proto3" json:"private_key_for_get,omitempty"`
	// Signed PUT orders for all possible pieces to be uploaded (not including
	// piece numbers in get_orders)
	PutOrders []*pb.AddressedOrderLimit `protobuf:"bytes,4,rep,name=put_orders,json=putOrders,proto3" json:"put_orders,omitempty"`
	// Private piece key to use for storing
	PrivateKeyForPut []byte `protobuf:"bytes,5,opt,name=private_key_for_put,json=privateKeyForPut,proto3" json:"private_key_for_put,omitempty"`
	// Redundancy scheme used by the segment to be repaired
	Redundancy *pb.RedundancyScheme `protobuf:"bytes,6,opt,name=redundancy,proto3" json:"redundancy,omitempty"`
	// Size of the segment to be repaired
	SegmentSize int64 `protobuf:"varint,7,opt,name=segment_size,json=segmentSize,proto3" json:"segment_size,omitempty"`
	// Target piece count (worker should try to upload enough pieces so that
	// this count is achieved)
	DesiredPieceCount int32 `protobuf:"varint,8,opt,name=desired_piece_count,json=desiredPieceCount,proto3" json:"desired_piece_count,omitempty"`
	// Job expiration time
	ExpirationTime       time.Time `protobuf:"bytes,9,opt,name=expiration_time,json=expirationTime,proto3,stdtime" json:"expiration_time"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*RepairJobDefinition) Descriptor 

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

func (*RepairJobDefinition) GetDesiredPieceCount 

func (m *RepairJobDefinition) GetDesiredPieceCount() int32

func (*RepairJobDefinition) GetExpirationTime 

func (m *RepairJobDefinition) GetExpirationTime() time.Time

func (*RepairJobDefinition) GetGetOrders 

func (m *RepairJobDefinition) GetGetOrders() []*pb.AddressedOrderLimit

func (*RepairJobDefinition) GetJobId 

func (m *RepairJobDefinition) GetJobId() []byte

func (*RepairJobDefinition) GetPrivateKeyForGet 

func (m *RepairJobDefinition) GetPrivateKeyForGet() []byte

func (*RepairJobDefinition) GetPrivateKeyForPut 

func (m *RepairJobDefinition) GetPrivateKeyForPut() []byte

func (*RepairJobDefinition) GetPutOrders 

func (m *RepairJobDefinition) GetPutOrders() []*pb.AddressedOrderLimit

func (*RepairJobDefinition) GetRedundancy 

func (m *RepairJobDefinition) GetRedundancy() *pb.RedundancyScheme

func (*RepairJobDefinition) GetSegmentSize 

func (m *RepairJobDefinition) GetSegmentSize() int64

func (*RepairJobDefinition) ProtoMessage 

func (*RepairJobDefinition) ProtoMessage()

func (*RepairJobDefinition) Reset 

func (m *RepairJobDefinition) Reset()

func (*RepairJobDefinition) String 

func (m *RepairJobDefinition) String() string

func (*RepairJobDefinition) XXX_DiscardUnknown 

func (m *RepairJobDefinition) XXX_DiscardUnknown()

func (*RepairJobDefinition) XXX_Marshal 

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

func (*RepairJobDefinition) XXX_Merge 

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

func (*RepairJobDefinition) XXX_Size 

func (m *RepairJobDefinition) XXX_Size() int

func (*RepairJobDefinition) XXX_Unmarshal 

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

type RepairJobRequest 

type RepairJobRequest struct {
	// When not the first request, this will include the result of the last job
	LastJobResult        *RepairJobResult `protobuf:"bytes,1,opt,name=last_job_result,json=lastJobResult,proto3" json:"last_job_result,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*RepairJobRequest) Descriptor 

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

func (*RepairJobRequest) GetLastJobResult 

func (m *RepairJobRequest) GetLastJobResult() *RepairJobResult

func (*RepairJobRequest) ProtoMessage 

func (*RepairJobRequest) ProtoMessage()

func (*RepairJobRequest) Reset 

func (m *RepairJobRequest) Reset()

func (*RepairJobRequest) String 

func (m *RepairJobRequest) String() string

func (*RepairJobRequest) XXX_DiscardUnknown 

func (m *RepairJobRequest) XXX_DiscardUnknown()

func (*RepairJobRequest) XXX_Marshal 

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

func (*RepairJobRequest) XXX_Merge 

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

func (*RepairJobRequest) XXX_Size 

func (m *RepairJobRequest) XXX_Size() int

func (*RepairJobRequest) XXX_Unmarshal 

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

type RepairJobResponse 

type RepairJobResponse struct {
	// When a job is available, this will be filled in
	NewJob *RepairJobDefinition `protobuf:"bytes,1,opt,name=new_job,json=newJob,proto3" json:"new_job,omitempty"`
	// Otherwise, client should wait this many milliseconds and then try again
	ComeBackInMillis     int32    `protobuf:"varint,2,opt,name=come_back_in_millis,json=comeBackInMillis,proto3" json:"come_back_in_millis,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RepairJobResponse) Descriptor 

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

func (*RepairJobResponse) GetComeBackInMillis 

func (m *RepairJobResponse) GetComeBackInMillis() int32

func (*RepairJobResponse) GetNewJob 

func (m *RepairJobResponse) GetNewJob() *RepairJobDefinition

func (*RepairJobResponse) ProtoMessage 

func (*RepairJobResponse) ProtoMessage()

func (*RepairJobResponse) Reset 

func (m *RepairJobResponse) Reset()

func (*RepairJobResponse) String 

func (m *RepairJobResponse) String() string

func (*RepairJobResponse) XXX_DiscardUnknown 

func (m *RepairJobResponse) XXX_DiscardUnknown()

func (*RepairJobResponse) XXX_Marshal 

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

func (*RepairJobResponse) XXX_Merge 

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

func (*RepairJobResponse) XXX_Size 

func (m *RepairJobResponse) XXX_Size() int

func (*RepairJobResponse) XXX_Unmarshal 

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

type RepairJobResult 

type RepairJobResult struct {
	// Identifier for this job, as given in RepairJobResponse
	JobId []byte `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Set nonzero only if the segment could not be reconstructed because of
	// too few pieces available.
	IrreparablePiecesRetrieved int32 `` /* 142-byte string literal not displayed */
	// Set only if the segment could not be reconstructed.
	ReconstructError string `protobuf:"bytes,3,opt,name=reconstruct_error,json=reconstructError,proto3" json:"reconstruct_error,omitempty"`
	// Set only if new pieces could not be stored to any new nodes.
	StoreError string `protobuf:"bytes,4,opt,name=store_error,json=storeError,proto3" json:"store_error,omitempty"`
	// PieceHashes signed by storage nodes which were used to accomplish repair
	NewPiecesStored []*pb.PieceHash `protobuf:"bytes,5,rep,name=new_pieces_stored,json=newPiecesStored,proto3" json:"new_pieces_stored,omitempty"`
	// A copy of the put_orders list as provided in the corresponding
	// RepairJobDefinition
	PutOrders []*pb.AddressedOrderLimit `protobuf:"bytes,6,rep,name=put_orders,json=putOrders,proto3" json:"put_orders,omitempty"`
	// Pieces which should be _removed_ from the pointer. This will include
	// pieces for which the expected owning storage node returned a "not found"
	// error, as well as pieces which were downloaded but failed their
	// validation check.
	DeletePieceNums      []int32  `protobuf:"varint,7,rep,packed,name=delete_piece_nums,json=deletePieceNums,proto3" json:"delete_piece_nums,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RepairJobResult) Descriptor 

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

func (*RepairJobResult) GetDeletePieceNums 

func (m *RepairJobResult) GetDeletePieceNums() []int32

func (*RepairJobResult) GetIrreparablePiecesRetrieved 

func (m *RepairJobResult) GetIrreparablePiecesRetrieved() int32

func (*RepairJobResult) GetJobId 

func (m *RepairJobResult) GetJobId() []byte

func (*RepairJobResult) GetNewPiecesStored 

func (m *RepairJobResult) GetNewPiecesStored() []*pb.PieceHash

func (*RepairJobResult) GetPutOrders 

func (m *RepairJobResult) GetPutOrders() []*pb.AddressedOrderLimit

func (*RepairJobResult) GetReconstructError 

func (m *RepairJobResult) GetReconstructError() string

func (*RepairJobResult) GetStoreError 

func (m *RepairJobResult) GetStoreError() string

func (*RepairJobResult) ProtoMessage 

func (*RepairJobResult) ProtoMessage()

func (*RepairJobResult) Reset 

func (m *RepairJobResult) Reset()

func (*RepairJobResult) String 

func (m *RepairJobResult) String() string

func (*RepairJobResult) XXX_DiscardUnknown 

func (m *RepairJobResult) XXX_DiscardUnknown()

func (*RepairJobResult) XXX_Marshal 

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

func (*RepairJobResult) XXX_Merge 

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

func (*RepairJobResult) XXX_Size 

func (m *RepairJobResult) XXX_Size() int

func (*RepairJobResult) XXX_Unmarshal 

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

type RetainInfo added in v1.63.1 

type RetainInfo struct {
	CreationDate time.Time `protobuf:"bytes,1,opt,name=creation_date,json=creationDate,proto3,stdtime" json:"creation_date"`
	Filter       []byte    `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	// number of pieces to retain on the node through the above bloom filter.
	PieceCount           int64    `protobuf:"varint,3,opt,name=piece_count,json=pieceCount,proto3" json:"piece_count,omitempty"`
	StorageNodeId        NodeID   `protobuf:"bytes,4,opt,name=storage_node_id,json=storageNodeId,proto3,customtype=NodeID" json:"storage_node_id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

RetainInfo is used to pass info generated from a database backup to the live garbage collection (gc) process. The live process will send it out to the storage nodes.

func (*RetainInfo) Descriptor added in v1.63.1 

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

func (*RetainInfo) GetCreationDate added in v1.63.1 

func (m *RetainInfo) GetCreationDate() time.Time

func (*RetainInfo) GetFilter added in v1.63.1 

func (m *RetainInfo) GetFilter() []byte

func (*RetainInfo) GetPieceCount added in v1.63.1 

func (m *RetainInfo) GetPieceCount() int64

func (*RetainInfo) ProtoMessage added in v1.63.1 

func (*RetainInfo) ProtoMessage()

func (*RetainInfo) Reset added in v1.63.1 

func (m *RetainInfo) Reset()

func (*RetainInfo) String added in v1.63.1 

func (m *RetainInfo) String() string

func (*RetainInfo) XXX_DiscardUnknown added in v1.63.1 

func (m *RetainInfo) XXX_DiscardUnknown()

func (*RetainInfo) XXX_Marshal added in v1.63.1 

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

func (*RetainInfo) XXX_Merge added in v1.63.1 

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

func (*RetainInfo) XXX_Size added in v1.63.1 

func (m *RetainInfo) XXX_Size() int

func (*RetainInfo) XXX_Unmarshal added in v1.63.1 

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

type SegmentID 

type SegmentID struct {
	StreamId             *StreamID                 `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	PartNumber           int32                     `protobuf:"varint,2,opt,name=part_number,json=partNumber,proto3" json:"part_number,omitempty"`
	Index                int32                     `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	RootPieceId          PieceID                   `protobuf:"bytes,5,opt,name=root_piece_id,json=rootPieceId,proto3,customtype=PieceID" json:"root_piece_id"`
	OriginalOrderLimits  []*pb.AddressedOrderLimit `protobuf:"bytes,6,rep,name=original_order_limits,json=originalOrderLimits,proto3" json:"original_order_limits,omitempty"`
	CreationDate         time.Time                 `protobuf:"bytes,7,opt,name=creation_date,json=creationDate,proto3,stdtime" json:"creation_date"`
	RedundancyScheme     *pb.RedundancyScheme      `protobuf:"bytes,9,opt,name=redundancy_scheme,json=redundancyScheme,proto3" json:"redundancy_scheme,omitempty"`
	SatelliteSignature   []byte                    `protobuf:"bytes,8,opt,name=satellite_signature,json=satelliteSignature,proto3" json:"satellite_signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*SegmentID) Descriptor 

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

func (*SegmentID) GetCreationDate 

func (m *SegmentID) GetCreationDate() time.Time

func (*SegmentID) GetIndex 

func (m *SegmentID) GetIndex() int32

func (*SegmentID) GetOriginalOrderLimits 

func (m *SegmentID) GetOriginalOrderLimits() []*pb.AddressedOrderLimit

func (*SegmentID) GetPartNumber 

func (m *SegmentID) GetPartNumber() int32

func (*SegmentID) GetRedundancyScheme added in v1.114.4 

func (m *SegmentID) GetRedundancyScheme() *pb.RedundancyScheme

func (*SegmentID) GetSatelliteSignature 

func (m *SegmentID) GetSatelliteSignature() []byte

func (*SegmentID) GetStreamId 

func (m *SegmentID) GetStreamId() *StreamID

func (*SegmentID) ProtoMessage 

func (*SegmentID) ProtoMessage()

func (*SegmentID) Reset 

func (m *SegmentID) Reset()

func (*SegmentID) String 

func (m *SegmentID) String() string

func (*SegmentID) XXX_DiscardUnknown 

func (m *SegmentID) XXX_DiscardUnknown()

func (*SegmentID) XXX_Marshal 

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

func (*SegmentID) XXX_Merge 

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

func (*SegmentID) XXX_Size 

func (m *SegmentID) XXX_Size() int

func (*SegmentID) XXX_Unmarshal 

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

type StreamID 

type StreamID struct {
	Bucket               []byte                   `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	EncryptedObjectKey   []byte                   `protobuf:"bytes,2,opt,name=encrypted_object_key,json=encryptedObjectKey,proto3" json:"encrypted_object_key,omitempty"`
	Version              int64                    `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	EncryptionParameters *pb.EncryptionParameters `protobuf:"bytes,12,opt,name=encryption_parameters,json=encryptionParameters,proto3" json:"encryption_parameters,omitempty"`
	CreationDate         time.Time                `protobuf:"bytes,5,opt,name=creation_date,json=creationDate,proto3,stdtime" json:"creation_date"`
	ExpirationDate       time.Time                `protobuf:"bytes,6,opt,name=expiration_date,json=expirationDate,proto3,stdtime" json:"expiration_date"`
	MultipartObject      bool                     `protobuf:"varint,11,opt,name=multipart_object,json=multipartObject,proto3" json:"multipart_object,omitempty"`
	SatelliteSignature   []byte                   `protobuf:"bytes,9,opt,name=satellite_signature,json=satelliteSignature,proto3" json:"satellite_signature,omitempty"`
	StreamId             []byte                   `protobuf:"bytes,10,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Placement            int32                    `protobuf:"varint,13,opt,name=placement,proto3" json:"placement,omitempty"`
	Versioned            bool                     `protobuf:"varint,15,opt,name=versioned,proto3" json:"versioned,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*StreamID) Descriptor 

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

func (*StreamID) GetBucket 

func (m *StreamID) GetBucket() []byte

func (*StreamID) GetCreationDate 

func (m *StreamID) GetCreationDate() time.Time

func (*StreamID) GetEncryptedObjectKey added in v1.41.1 

func (m *StreamID) GetEncryptedObjectKey() []byte

func (*StreamID) GetEncryptionParameters added in v1.26.2 

func (m *StreamID) GetEncryptionParameters() *pb.EncryptionParameters

func (*StreamID) GetExpirationDate 

func (m *StreamID) GetExpirationDate() time.Time

func (*StreamID) GetMultipartObject added in v1.26.2 

func (m *StreamID) GetMultipartObject() bool

func (*StreamID) GetPlacement added in v1.44.1 

func (m *StreamID) GetPlacement() int32

func (*StreamID) GetSatelliteSignature 

func (m *StreamID) GetSatelliteSignature() []byte

func (*StreamID) GetStreamId 

func (m *StreamID) GetStreamId() []byte

func (*StreamID) GetVersion 

func (m *StreamID) GetVersion() int64

func (*StreamID) GetVersioned added in v1.93.1 

func (m *StreamID) GetVersioned() bool

func (*StreamID) ProtoMessage 

func (*StreamID) ProtoMessage()

func (*StreamID) Reset 

func (m *StreamID) Reset()

func (*StreamID) String 

func (m *StreamID) String() string

func (*StreamID) XXX_DiscardUnknown 

func (m *StreamID) XXX_DiscardUnknown()

func (*StreamID) XXX_Marshal 

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

func (*StreamID) XXX_Merge 

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

func (*StreamID) XXX_Size 

func (m *StreamID) XXX_Size() int

func (*StreamID) XXX_Unmarshal 

func (m *StreamID) 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.