Documentation
¶
Overview ¶
Package internalpb contains proto definitions for satellite internal tools.
Index ¶
- func DRPCRegisterHealthInspector(mux drpc.Mux, impl DRPCHealthInspectorServer) error
- func DRPCRegisterIrreparableInspector(mux drpc.Mux, impl DRPCIrreparableInspectorServer) error
- func DRPCRegisterOverlayInspector(mux drpc.Mux, impl DRPCOverlayInspectorServer) error
- func DRPCRegisterRepairCoordinator(mux drpc.Mux, impl DRPCRepairCoordinatorServer) error
- type AuditHistory
- func (*AuditHistory) Descriptor() ([]byte, []int)
- func (m *AuditHistory) GetScore() float64
- func (m *AuditHistory) GetWindows() []*AuditWindow
- func (*AuditHistory) ProtoMessage()
- func (m *AuditHistory) Reset()
- func (m *AuditHistory) String() string
- func (m *AuditHistory) XXX_DiscardUnknown()
- func (m *AuditHistory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AuditHistory) XXX_Merge(src proto.Message)
- func (m *AuditHistory) XXX_Size() int
- func (m *AuditHistory) XXX_Unmarshal(b []byte) error
- type AuditWindow
- func (*AuditWindow) Descriptor() ([]byte, []int)
- func (m *AuditWindow) GetOnlineCount() int32
- func (m *AuditWindow) GetTotalCount() int32
- func (m *AuditWindow) GetWindowStart() time.Time
- func (*AuditWindow) ProtoMessage()
- func (m *AuditWindow) Reset()
- func (m *AuditWindow) String() string
- func (m *AuditWindow) XXX_DiscardUnknown()
- func (m *AuditWindow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AuditWindow) XXX_Merge(src proto.Message)
- func (m *AuditWindow) XXX_Size() int
- func (m *AuditWindow) XXX_Unmarshal(b []byte) error
- type CountNodesRequest
- func (*CountNodesRequest) Descriptor() ([]byte, []int)
- func (*CountNodesRequest) ProtoMessage()
- func (m *CountNodesRequest) Reset()
- func (m *CountNodesRequest) String() string
- func (m *CountNodesRequest) XXX_DiscardUnknown()
- func (m *CountNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CountNodesRequest) XXX_Merge(src proto.Message)
- func (m *CountNodesRequest) XXX_Size() int
- func (m *CountNodesRequest) XXX_Unmarshal(b []byte) error
- type CountNodesResponse
- func (*CountNodesResponse) Descriptor() ([]byte, []int)
- func (m *CountNodesResponse) GetCount() int64
- func (*CountNodesResponse) ProtoMessage()
- func (m *CountNodesResponse) Reset()
- func (m *CountNodesResponse) String() string
- func (m *CountNodesResponse) XXX_DiscardUnknown()
- func (m *CountNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CountNodesResponse) XXX_Merge(src proto.Message)
- func (m *CountNodesResponse) XXX_Size() int
- func (m *CountNodesResponse) XXX_Unmarshal(b []byte) error
- type DRPCHealthInspectorClient
- type DRPCHealthInspectorDescription
- type DRPCHealthInspectorServer
- type DRPCHealthInspector_ObjectHealthStream
- type DRPCHealthInspector_SegmentHealthStream
- type DRPCIrreparableInspectorClient
- type DRPCIrreparableInspectorDescription
- type DRPCIrreparableInspectorServer
- type DRPCIrreparableInspector_ListIrreparableSegmentsStream
- type DRPCOverlayInspectorClient
- type DRPCOverlayInspectorDescription
- type DRPCOverlayInspectorServer
- type DRPCOverlayInspector_CountNodesStream
- type DRPCOverlayInspector_DumpNodesStream
- type DRPCRepairCoordinatorClient
- type DRPCRepairCoordinatorDescription
- type DRPCRepairCoordinatorServer
- type DRPCRepairCoordinator_RepairJobStream
- type DumpNodesRequest
- func (*DumpNodesRequest) Descriptor() ([]byte, []int)
- func (*DumpNodesRequest) ProtoMessage()
- func (m *DumpNodesRequest) Reset()
- func (m *DumpNodesRequest) String() string
- func (m *DumpNodesRequest) XXX_DiscardUnknown()
- func (m *DumpNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DumpNodesRequest) XXX_Merge(src proto.Message)
- func (m *DumpNodesRequest) XXX_Size() int
- func (m *DumpNodesRequest) XXX_Unmarshal(b []byte) error
- type DumpNodesResponse
- func (*DumpNodesResponse) Descriptor() ([]byte, []int)
- func (m *DumpNodesResponse) GetNodes() []*pb.Node
- func (*DumpNodesResponse) ProtoMessage()
- func (m *DumpNodesResponse) Reset()
- func (m *DumpNodesResponse) String() string
- func (m *DumpNodesResponse) XXX_DiscardUnknown()
- func (m *DumpNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DumpNodesResponse) XXX_Merge(src proto.Message)
- func (m *DumpNodesResponse) XXX_Size() int
- func (m *DumpNodesResponse) XXX_Unmarshal(b []byte) error
- type InjuredSegment
- func (*InjuredSegment) Descriptor() ([]byte, []int)
- func (m *InjuredSegment) GetInsertedTime() time.Time
- func (m *InjuredSegment) GetLostPieces() []int32
- func (m *InjuredSegment) GetPath() []byte
- func (*InjuredSegment) ProtoMessage()
- func (m *InjuredSegment) Reset()
- func (n *InjuredSegment) Scan(value interface{}) error
- func (m *InjuredSegment) String() string
- func (n InjuredSegment) Value() (driver.Value, error)
- func (m *InjuredSegment) XXX_DiscardUnknown()
- func (m *InjuredSegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *InjuredSegment) XXX_Merge(src proto.Message)
- func (m *InjuredSegment) XXX_Size() int
- func (m *InjuredSegment) XXX_Unmarshal(b []byte) error
- type IrreparableSegment
- func (*IrreparableSegment) Descriptor() ([]byte, []int)
- func (m *IrreparableSegment) GetLastRepairAttempt() int64
- func (m *IrreparableSegment) GetLostPieces() int32
- func (m *IrreparableSegment) GetPath() []byte
- func (m *IrreparableSegment) GetRepairAttemptCount() int64
- func (m *IrreparableSegment) GetSegmentDetail() *pb.Pointer
- func (*IrreparableSegment) ProtoMessage()
- func (m *IrreparableSegment) Reset()
- func (m *IrreparableSegment) String() string
- func (m *IrreparableSegment) XXX_DiscardUnknown()
- func (m *IrreparableSegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *IrreparableSegment) XXX_Merge(src proto.Message)
- func (m *IrreparableSegment) XXX_Size() int
- func (m *IrreparableSegment) XXX_Unmarshal(b []byte) error
- type ListIrreparableSegmentsRequest
- func (*ListIrreparableSegmentsRequest) Descriptor() ([]byte, []int)
- func (m *ListIrreparableSegmentsRequest) GetLastSeenSegmentPath() []byte
- func (m *ListIrreparableSegmentsRequest) GetLimit() int32
- func (*ListIrreparableSegmentsRequest) ProtoMessage()
- func (m *ListIrreparableSegmentsRequest) Reset()
- func (m *ListIrreparableSegmentsRequest) String() string
- func (m *ListIrreparableSegmentsRequest) XXX_DiscardUnknown()
- func (m *ListIrreparableSegmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListIrreparableSegmentsRequest) XXX_Merge(src proto.Message)
- func (m *ListIrreparableSegmentsRequest) XXX_Size() int
- func (m *ListIrreparableSegmentsRequest) XXX_Unmarshal(b []byte) error
- type ListIrreparableSegmentsResponse
- func (*ListIrreparableSegmentsResponse) Descriptor() ([]byte, []int)
- func (m *ListIrreparableSegmentsResponse) GetSegments() []*IrreparableSegment
- func (*ListIrreparableSegmentsResponse) ProtoMessage()
- func (m *ListIrreparableSegmentsResponse) Reset()
- func (m *ListIrreparableSegmentsResponse) String() string
- func (m *ListIrreparableSegmentsResponse) XXX_DiscardUnknown()
- func (m *ListIrreparableSegmentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListIrreparableSegmentsResponse) XXX_Merge(src proto.Message)
- func (m *ListIrreparableSegmentsResponse) XXX_Size() int
- func (m *ListIrreparableSegmentsResponse) XXX_Unmarshal(b []byte) error
- type NodeID
- type ObjectHealthRequest
- func (*ObjectHealthRequest) Descriptor() ([]byte, []int)
- func (m *ObjectHealthRequest) GetBucket() []byte
- func (m *ObjectHealthRequest) GetEncryptedPath() []byte
- func (m *ObjectHealthRequest) GetEndBeforeSegment() int64
- func (m *ObjectHealthRequest) GetLimit() int32
- func (m *ObjectHealthRequest) GetProjectId() []byte
- func (m *ObjectHealthRequest) GetStartAfterSegment() int64
- func (*ObjectHealthRequest) ProtoMessage()
- func (m *ObjectHealthRequest) Reset()
- func (m *ObjectHealthRequest) String() string
- func (m *ObjectHealthRequest) XXX_DiscardUnknown()
- func (m *ObjectHealthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ObjectHealthRequest) XXX_Merge(src proto.Message)
- func (m *ObjectHealthRequest) XXX_Size() int
- func (m *ObjectHealthRequest) XXX_Unmarshal(b []byte) error
- type ObjectHealthResponse
- func (*ObjectHealthResponse) Descriptor() ([]byte, []int)
- func (m *ObjectHealthResponse) GetRedundancy() *pb.RedundancyScheme
- func (m *ObjectHealthResponse) GetSegments() []*SegmentHealth
- func (*ObjectHealthResponse) ProtoMessage()
- func (m *ObjectHealthResponse) Reset()
- func (m *ObjectHealthResponse) String() string
- func (m *ObjectHealthResponse) XXX_DiscardUnknown()
- func (m *ObjectHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ObjectHealthResponse) XXX_Merge(src proto.Message)
- func (m *ObjectHealthResponse) XXX_Size() int
- func (m *ObjectHealthResponse) XXX_Unmarshal(b []byte) error
- type OrderLimitMetadata
- func (*OrderLimitMetadata) Descriptor() ([]byte, []int)
- func (m *OrderLimitMetadata) GetBucketId() []byte
- func (m *OrderLimitMetadata) GetCompactProjectBucketPrefix() []byte
- func (m *OrderLimitMetadata) GetProjectBucketPrefix() []byte
- func (*OrderLimitMetadata) ProtoMessage()
- func (m *OrderLimitMetadata) Reset()
- func (m *OrderLimitMetadata) String() string
- func (m *OrderLimitMetadata) XXX_DiscardUnknown()
- func (m *OrderLimitMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OrderLimitMetadata) XXX_Merge(src proto.Message)
- func (m *OrderLimitMetadata) XXX_Size() int
- func (m *OrderLimitMetadata) XXX_Unmarshal(b []byte) error
- type PieceID
- type RepairJobDefinition
- func (*RepairJobDefinition) Descriptor() ([]byte, []int)
- func (m *RepairJobDefinition) GetDesiredPieceCount() int32
- func (m *RepairJobDefinition) GetExpirationTime() time.Time
- func (m *RepairJobDefinition) GetGetOrders() []*pb.AddressedOrderLimit
- func (m *RepairJobDefinition) GetJobId() []byte
- func (m *RepairJobDefinition) GetPrivateKeyForGet() []byte
- func (m *RepairJobDefinition) GetPrivateKeyForPut() []byte
- func (m *RepairJobDefinition) GetPutOrders() []*pb.AddressedOrderLimit
- func (m *RepairJobDefinition) GetRedundancy() *pb.RedundancyScheme
- func (m *RepairJobDefinition) GetSegmentSize() int64
- func (*RepairJobDefinition) ProtoMessage()
- func (m *RepairJobDefinition) Reset()
- func (m *RepairJobDefinition) String() string
- func (m *RepairJobDefinition) XXX_DiscardUnknown()
- func (m *RepairJobDefinition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RepairJobDefinition) XXX_Merge(src proto.Message)
- func (m *RepairJobDefinition) XXX_Size() int
- func (m *RepairJobDefinition) XXX_Unmarshal(b []byte) error
- type RepairJobRequest
- func (*RepairJobRequest) Descriptor() ([]byte, []int)
- func (m *RepairJobRequest) GetLastJobResult() *RepairJobResult
- func (*RepairJobRequest) ProtoMessage()
- func (m *RepairJobRequest) Reset()
- func (m *RepairJobRequest) String() string
- func (m *RepairJobRequest) XXX_DiscardUnknown()
- func (m *RepairJobRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RepairJobRequest) XXX_Merge(src proto.Message)
- func (m *RepairJobRequest) XXX_Size() int
- func (m *RepairJobRequest) XXX_Unmarshal(b []byte) error
- type RepairJobResponse
- func (*RepairJobResponse) Descriptor() ([]byte, []int)
- func (m *RepairJobResponse) GetComeBackInMillis() int32
- func (m *RepairJobResponse) GetNewJob() *RepairJobDefinition
- func (*RepairJobResponse) ProtoMessage()
- func (m *RepairJobResponse) Reset()
- func (m *RepairJobResponse) String() string
- func (m *RepairJobResponse) XXX_DiscardUnknown()
- func (m *RepairJobResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RepairJobResponse) XXX_Merge(src proto.Message)
- func (m *RepairJobResponse) XXX_Size() int
- func (m *RepairJobResponse) XXX_Unmarshal(b []byte) error
- type RepairJobResult
- func (*RepairJobResult) Descriptor() ([]byte, []int)
- func (m *RepairJobResult) GetDeletePieceNums() []int32
- func (m *RepairJobResult) GetIrreparablePiecesRetrieved() int32
- func (m *RepairJobResult) GetJobId() []byte
- func (m *RepairJobResult) GetNewPiecesStored() []*pb.PieceHash
- func (m *RepairJobResult) GetPutOrders() []*pb.AddressedOrderLimit
- func (m *RepairJobResult) GetReconstructError() string
- func (m *RepairJobResult) GetStoreError() string
- func (*RepairJobResult) ProtoMessage()
- func (m *RepairJobResult) Reset()
- func (m *RepairJobResult) String() string
- func (m *RepairJobResult) XXX_DiscardUnknown()
- func (m *RepairJobResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RepairJobResult) XXX_Merge(src proto.Message)
- func (m *RepairJobResult) XXX_Size() int
- func (m *RepairJobResult) XXX_Unmarshal(b []byte) error
- type SegmentHealth
- func (*SegmentHealth) Descriptor() ([]byte, []int)
- func (m *SegmentHealth) GetSegment() []byte
- func (*SegmentHealth) ProtoMessage()
- func (m *SegmentHealth) Reset()
- func (m *SegmentHealth) String() string
- func (m *SegmentHealth) XXX_DiscardUnknown()
- func (m *SegmentHealth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SegmentHealth) XXX_Merge(src proto.Message)
- func (m *SegmentHealth) XXX_Size() int
- func (m *SegmentHealth) XXX_Unmarshal(b []byte) error
- type SegmentHealthRequest
- func (*SegmentHealthRequest) Descriptor() ([]byte, []int)
- func (m *SegmentHealthRequest) GetBucket() []byte
- func (m *SegmentHealthRequest) GetEncryptedPath() []byte
- func (m *SegmentHealthRequest) GetProjectId() []byte
- func (m *SegmentHealthRequest) GetSegmentIndex() int64
- func (*SegmentHealthRequest) ProtoMessage()
- func (m *SegmentHealthRequest) Reset()
- func (m *SegmentHealthRequest) String() string
- func (m *SegmentHealthRequest) XXX_DiscardUnknown()
- func (m *SegmentHealthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SegmentHealthRequest) XXX_Merge(src proto.Message)
- func (m *SegmentHealthRequest) XXX_Size() int
- func (m *SegmentHealthRequest) XXX_Unmarshal(b []byte) error
- type SegmentHealthResponse
- func (*SegmentHealthResponse) Descriptor() ([]byte, []int)
- func (m *SegmentHealthResponse) GetHealth() *SegmentHealth
- func (m *SegmentHealthResponse) GetRedundancy() *pb.RedundancyScheme
- func (*SegmentHealthResponse) ProtoMessage()
- func (m *SegmentHealthResponse) Reset()
- func (m *SegmentHealthResponse) String() string
- func (m *SegmentHealthResponse) XXX_DiscardUnknown()
- func (m *SegmentHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SegmentHealthResponse) XXX_Merge(src proto.Message)
- func (m *SegmentHealthResponse) XXX_Size() int
- func (m *SegmentHealthResponse) XXX_Unmarshal(b []byte) error
- type SegmentID
- func (*SegmentID) Descriptor() ([]byte, []int)
- func (m *SegmentID) GetCreationDate() time.Time
- func (m *SegmentID) GetIndex() int32
- func (m *SegmentID) GetOriginalOrderLimits() []*pb.AddressedOrderLimit
- func (m *SegmentID) GetPartNumber() int32
- func (m *SegmentID) GetSatelliteSignature() []byte
- func (m *SegmentID) GetStreamId() *StreamID
- func (*SegmentID) ProtoMessage()
- func (m *SegmentID) Reset()
- func (m *SegmentID) String() string
- func (m *SegmentID) XXX_DiscardUnknown()
- func (m *SegmentID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SegmentID) XXX_Merge(src proto.Message)
- func (m *SegmentID) XXX_Size() int
- func (m *SegmentID) XXX_Unmarshal(b []byte) error
- type StreamID
- func (*StreamID) Descriptor() ([]byte, []int)
- func (m *StreamID) GetBucket() []byte
- func (m *StreamID) GetCreationDate() time.Time
- func (m *StreamID) GetEncryptedPath() []byte
- func (m *StreamID) GetExpirationDate() time.Time
- func (m *StreamID) GetMultipartObject() bool
- func (m *StreamID) GetRedundancy() *pb.RedundancyScheme
- func (m *StreamID) GetSatelliteSignature() []byte
- func (m *StreamID) GetStreamId() []byte
- func (m *StreamID) GetVersion() int32
- func (*StreamID) ProtoMessage()
- func (m *StreamID) Reset()
- func (m *StreamID) String() string
- func (m *StreamID) XXX_DiscardUnknown()
- func (m *StreamID) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StreamID) XXX_Merge(src proto.Message)
- func (m *StreamID) XXX_Size() int
- func (m *StreamID) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DRPCRegisterHealthInspector ¶
func DRPCRegisterHealthInspector(mux drpc.Mux, impl DRPCHealthInspectorServer) error
func DRPCRegisterIrreparableInspector ¶
func DRPCRegisterIrreparableInspector(mux drpc.Mux, impl DRPCIrreparableInspectorServer) error
func DRPCRegisterOverlayInspector ¶
func DRPCRegisterOverlayInspector(mux drpc.Mux, impl DRPCOverlayInspectorServer) error
func DRPCRegisterRepairCoordinator ¶
func DRPCRegisterRepairCoordinator(mux drpc.Mux, impl DRPCRepairCoordinatorServer) error
Types ¶
type AuditHistory ¶
type AuditHistory struct {
Windows []*AuditWindow `protobuf:"bytes,1,rep,name=windows,proto3" json:"windows,omitempty"`
Score float64 `protobuf:"fixed64,2,opt,name=score,proto3" json:"score,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*AuditHistory) Descriptor ¶
func (*AuditHistory) Descriptor() ([]byte, []int)
func (*AuditHistory) GetWindows ¶
func (m *AuditHistory) GetWindows() []*AuditWindow
func (*AuditHistory) ProtoMessage ¶
func (*AuditHistory) ProtoMessage()
func (*AuditHistory) XXX_DiscardUnknown ¶
func (m *AuditHistory) XXX_DiscardUnknown()
func (*AuditHistory) XXX_Marshal ¶
func (m *AuditHistory) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AuditHistory) XXX_Unmarshal ¶
func (m *AuditHistory) XXX_Unmarshal(b []byte) error
type AuditWindow ¶
type AuditWindow struct {
WindowStart time.Time `protobuf:"bytes,1,opt,name=window_start,json=windowStart,proto3,stdtime" json:"window_start"`
OnlineCount int32 `protobuf:"varint,2,opt,name=online_count,json=onlineCount,proto3" json:"online_count,omitempty"`
TotalCount int32 `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*AuditWindow) Descriptor ¶
func (*AuditWindow) Descriptor() ([]byte, []int)
func (*AuditWindow) GetOnlineCount ¶
func (m *AuditWindow) GetOnlineCount() int32
func (*AuditWindow) GetTotalCount ¶
func (m *AuditWindow) GetTotalCount() int32
func (*AuditWindow) GetWindowStart ¶
func (m *AuditWindow) GetWindowStart() time.Time
func (*AuditWindow) ProtoMessage ¶
func (*AuditWindow) ProtoMessage()
func (*AuditWindow) XXX_DiscardUnknown ¶
func (m *AuditWindow) XXX_DiscardUnknown()
func (*AuditWindow) XXX_Marshal ¶
func (m *AuditWindow) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AuditWindow) XXX_Unmarshal ¶
func (m *AuditWindow) XXX_Unmarshal(b []byte) error
type CountNodesRequest ¶
type CountNodesRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*CountNodesRequest) Descriptor ¶
func (*CountNodesRequest) Descriptor() ([]byte, []int)
func (*CountNodesRequest) ProtoMessage ¶
func (*CountNodesRequest) ProtoMessage()
func (*CountNodesRequest) XXX_DiscardUnknown ¶
func (m *CountNodesRequest) XXX_DiscardUnknown()
func (*CountNodesRequest) XXX_Marshal ¶
func (m *CountNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CountNodesRequest) XXX_Unmarshal ¶
func (m *CountNodesRequest) XXX_Unmarshal(b []byte) error
type CountNodesResponse ¶
type CountNodesResponse struct {
Count int64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*CountNodesResponse) Descriptor ¶
func (*CountNodesResponse) Descriptor() ([]byte, []int)
func (*CountNodesResponse) ProtoMessage ¶
func (*CountNodesResponse) ProtoMessage()
func (*CountNodesResponse) XXX_DiscardUnknown ¶
func (m *CountNodesResponse) XXX_DiscardUnknown()
func (*CountNodesResponse) XXX_Marshal ¶
func (m *CountNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CountNodesResponse) XXX_Unmarshal ¶
func (m *CountNodesResponse) XXX_Unmarshal(b []byte) error
type DRPCHealthInspectorClient ¶
type DRPCHealthInspectorClient interface {
DRPCConn() drpc.Conn
// ObjectHealth will return stats about the health of an object
ObjectHealth(ctx context.Context, in *ObjectHealthRequest) (*ObjectHealthResponse, error)
// SegmentHealth will return stats about the health of a segment
SegmentHealth(ctx context.Context, in *SegmentHealthRequest) (*SegmentHealthResponse, error)
}
func NewDRPCHealthInspectorClient ¶
func NewDRPCHealthInspectorClient(cc drpc.Conn) DRPCHealthInspectorClient
type DRPCHealthInspectorDescription ¶
type DRPCHealthInspectorDescription struct{}
func (DRPCHealthInspectorDescription) Method ¶
func (DRPCHealthInspectorDescription) Method(n int) (string, drpc.Receiver, interface{}, bool)
func (DRPCHealthInspectorDescription) NumMethods ¶
func (DRPCHealthInspectorDescription) NumMethods() int
type DRPCHealthInspectorServer ¶
type DRPCHealthInspectorServer interface {
// ObjectHealth will return stats about the health of an object
ObjectHealth(context.Context, *ObjectHealthRequest) (*ObjectHealthResponse, error)
// SegmentHealth will return stats about the health of a segment
SegmentHealth(context.Context, *SegmentHealthRequest) (*SegmentHealthResponse, error)
}
type DRPCHealthInspector_ObjectHealthStream ¶
type DRPCHealthInspector_ObjectHealthStream interface {
drpc.Stream
SendAndClose(*ObjectHealthResponse) error
}
type DRPCHealthInspector_SegmentHealthStream ¶
type DRPCHealthInspector_SegmentHealthStream interface {
drpc.Stream
SendAndClose(*SegmentHealthResponse) error
}
type DRPCIrreparableInspectorClient ¶
type DRPCIrreparableInspectorClient interface {
DRPCConn() drpc.Conn
// ListIrreparableSegments returns damaged segments
ListIrreparableSegments(ctx context.Context, in *ListIrreparableSegmentsRequest) (*ListIrreparableSegmentsResponse, error)
}
func NewDRPCIrreparableInspectorClient ¶
func NewDRPCIrreparableInspectorClient(cc drpc.Conn) DRPCIrreparableInspectorClient
type DRPCIrreparableInspectorDescription ¶
type DRPCIrreparableInspectorDescription struct{}
func (DRPCIrreparableInspectorDescription) Method ¶
func (DRPCIrreparableInspectorDescription) Method(n int) (string, drpc.Receiver, interface{}, bool)
func (DRPCIrreparableInspectorDescription) NumMethods ¶
func (DRPCIrreparableInspectorDescription) NumMethods() int
type DRPCIrreparableInspectorServer ¶
type DRPCIrreparableInspectorServer interface {
// ListIrreparableSegments returns damaged segments
ListIrreparableSegments(context.Context, *ListIrreparableSegmentsRequest) (*ListIrreparableSegmentsResponse, error)
}
type DRPCIrreparableInspector_ListIrreparableSegmentsStream ¶
type DRPCIrreparableInspector_ListIrreparableSegmentsStream interface {
drpc.Stream
SendAndClose(*ListIrreparableSegmentsResponse) error
}
type DRPCOverlayInspectorClient ¶
type DRPCOverlayInspectorClient interface {
DRPCConn() drpc.Conn
// CountNodes returns the number of nodes in the cache
CountNodes(ctx context.Context, in *CountNodesRequest) (*CountNodesResponse, error)
// DumpNodes returns all the nodes in the cache
DumpNodes(ctx context.Context, in *DumpNodesRequest) (*DumpNodesResponse, error)
}
func NewDRPCOverlayInspectorClient ¶
func NewDRPCOverlayInspectorClient(cc drpc.Conn) DRPCOverlayInspectorClient
type DRPCOverlayInspectorDescription ¶
type DRPCOverlayInspectorDescription struct{}
func (DRPCOverlayInspectorDescription) Method ¶
func (DRPCOverlayInspectorDescription) Method(n int) (string, drpc.Receiver, interface{}, bool)
func (DRPCOverlayInspectorDescription) NumMethods ¶
func (DRPCOverlayInspectorDescription) NumMethods() int
type DRPCOverlayInspectorServer ¶
type DRPCOverlayInspectorServer interface {
// CountNodes returns the number of nodes in the cache
CountNodes(context.Context, *CountNodesRequest) (*CountNodesResponse, error)
// DumpNodes returns all the nodes in the cache
DumpNodes(context.Context, *DumpNodesRequest) (*DumpNodesResponse, error)
}
type DRPCOverlayInspector_CountNodesStream ¶
type DRPCOverlayInspector_CountNodesStream interface {
drpc.Stream
SendAndClose(*CountNodesResponse) error
}
type DRPCOverlayInspector_DumpNodesStream ¶
type DRPCOverlayInspector_DumpNodesStream interface {
drpc.Stream
SendAndClose(*DumpNodesResponse) 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.Receiver, interface{}, bool)
func (DRPCRepairCoordinatorDescription) NumMethods ¶
func (DRPCRepairCoordinatorDescription) NumMethods() int
type DRPCRepairCoordinatorServer ¶
type DRPCRepairCoordinatorServer interface {
RepairJob(context.Context, *RepairJobRequest) (*RepairJobResponse, error)
}
type DRPCRepairCoordinator_RepairJobStream ¶
type DRPCRepairCoordinator_RepairJobStream interface {
drpc.Stream
SendAndClose(*RepairJobResponse) error
}
type DumpNodesRequest ¶
type DumpNodesRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*DumpNodesRequest) Descriptor ¶
func (*DumpNodesRequest) Descriptor() ([]byte, []int)
func (*DumpNodesRequest) ProtoMessage ¶
func (*DumpNodesRequest) ProtoMessage()
func (*DumpNodesRequest) XXX_DiscardUnknown ¶
func (m *DumpNodesRequest) XXX_DiscardUnknown()
func (*DumpNodesRequest) XXX_Marshal ¶
func (m *DumpNodesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DumpNodesRequest) XXX_Unmarshal ¶
func (m *DumpNodesRequest) XXX_Unmarshal(b []byte) error
type DumpNodesResponse ¶
type DumpNodesResponse struct {
Nodes []*pb.Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*DumpNodesResponse) Descriptor ¶
func (*DumpNodesResponse) Descriptor() ([]byte, []int)
func (*DumpNodesResponse) ProtoMessage ¶
func (*DumpNodesResponse) ProtoMessage()
func (*DumpNodesResponse) XXX_DiscardUnknown ¶
func (m *DumpNodesResponse) XXX_DiscardUnknown()
func (*DumpNodesResponse) XXX_Marshal ¶
func (m *DumpNodesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DumpNodesResponse) XXX_Unmarshal ¶
func (m *DumpNodesResponse) XXX_Unmarshal(b []byte) error
type InjuredSegment ¶
type InjuredSegment struct {
Path []byte `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
LostPieces []int32 `protobuf:"varint,2,rep,packed,name=lost_pieces,json=lostPieces,proto3" json:"lost_pieces,omitempty"`
InsertedTime time.Time `protobuf:"bytes,3,opt,name=inserted_time,json=insertedTime,proto3,stdtime" json:"inserted_time"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
InjuredSegment is the queue item used for the data repair queue.
func (*InjuredSegment) Descriptor ¶
func (*InjuredSegment) Descriptor() ([]byte, []int)
func (*InjuredSegment) GetInsertedTime ¶
func (m *InjuredSegment) GetInsertedTime() time.Time
func (*InjuredSegment) GetLostPieces ¶
func (m *InjuredSegment) GetLostPieces() []int32
func (*InjuredSegment) ProtoMessage ¶
func (*InjuredSegment) ProtoMessage()
func (*InjuredSegment) Scan ¶
func (n *InjuredSegment) Scan(value interface{}) error
Scan implements the Scanner interface.
func (InjuredSegment) Value ¶
func (n InjuredSegment) Value() (driver.Value, error)
Value implements the driver Valuer interface.
func (*InjuredSegment) XXX_DiscardUnknown ¶
func (m *InjuredSegment) XXX_DiscardUnknown()
func (*InjuredSegment) XXX_Marshal ¶
func (m *InjuredSegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*InjuredSegment) XXX_Unmarshal ¶
func (m *InjuredSegment) XXX_Unmarshal(b []byte) error
type IrreparableSegment ¶
type IrreparableSegment struct {
Path []byte `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
SegmentDetail *pb.Pointer `protobuf:"bytes,2,opt,name=segment_detail,json=segmentDetail,proto3" json:"segment_detail,omitempty"`
LostPieces int32 `protobuf:"varint,3,opt,name=lost_pieces,json=lostPieces,proto3" json:"lost_pieces,omitempty"`
LastRepairAttempt int64 `protobuf:"varint,4,opt,name=last_repair_attempt,json=lastRepairAttempt,proto3" json:"last_repair_attempt,omitempty"`
RepairAttemptCount int64 `protobuf:"varint,5,opt,name=repair_attempt_count,json=repairAttemptCount,proto3" json:"repair_attempt_count,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*IrreparableSegment) Descriptor ¶
func (*IrreparableSegment) Descriptor() ([]byte, []int)
func (*IrreparableSegment) GetLastRepairAttempt ¶
func (m *IrreparableSegment) GetLastRepairAttempt() int64
func (*IrreparableSegment) GetLostPieces ¶
func (m *IrreparableSegment) GetLostPieces() int32
func (*IrreparableSegment) GetRepairAttemptCount ¶
func (m *IrreparableSegment) GetRepairAttemptCount() int64
func (*IrreparableSegment) GetSegmentDetail ¶
func (m *IrreparableSegment) GetSegmentDetail() *pb.Pointer
func (*IrreparableSegment) ProtoMessage ¶
func (*IrreparableSegment) ProtoMessage()
func (*IrreparableSegment) XXX_DiscardUnknown ¶
func (m *IrreparableSegment) XXX_DiscardUnknown()
func (*IrreparableSegment) XXX_Marshal ¶
func (m *IrreparableSegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*IrreparableSegment) XXX_Unmarshal ¶
func (m *IrreparableSegment) XXX_Unmarshal(b []byte) error
type ListIrreparableSegmentsRequest ¶
type ListIrreparableSegmentsRequest struct {
Limit int32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
LastSeenSegmentPath []byte `protobuf:"bytes,2,opt,name=last_seen_segment_path,json=lastSeenSegmentPath,proto3" json:"last_seen_segment_path,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ListIrreparableSegmentsRequest) Descriptor ¶
func (*ListIrreparableSegmentsRequest) Descriptor() ([]byte, []int)
func (*ListIrreparableSegmentsRequest) GetLastSeenSegmentPath ¶
func (m *ListIrreparableSegmentsRequest) GetLastSeenSegmentPath() []byte
func (*ListIrreparableSegmentsRequest) GetLimit ¶
func (m *ListIrreparableSegmentsRequest) GetLimit() int32
func (*ListIrreparableSegmentsRequest) ProtoMessage ¶
func (*ListIrreparableSegmentsRequest) ProtoMessage()
func (*ListIrreparableSegmentsRequest) String ¶
func (m *ListIrreparableSegmentsRequest) String() string
func (*ListIrreparableSegmentsRequest) XXX_DiscardUnknown ¶
func (m *ListIrreparableSegmentsRequest) XXX_DiscardUnknown()
func (*ListIrreparableSegmentsRequest) XXX_Marshal ¶
func (m *ListIrreparableSegmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListIrreparableSegmentsRequest) XXX_Merge ¶
func (m *ListIrreparableSegmentsRequest) XXX_Merge(src proto.Message)
func (*ListIrreparableSegmentsRequest) XXX_Size ¶
func (m *ListIrreparableSegmentsRequest) XXX_Size() int
func (*ListIrreparableSegmentsRequest) XXX_Unmarshal ¶
func (m *ListIrreparableSegmentsRequest) XXX_Unmarshal(b []byte) error
type ListIrreparableSegmentsResponse ¶
type ListIrreparableSegmentsResponse struct {
Segments []*IrreparableSegment `protobuf:"bytes,1,rep,name=segments,proto3" json:"segments,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ListIrreparableSegmentsResponse) Descriptor ¶
func (*ListIrreparableSegmentsResponse) Descriptor() ([]byte, []int)
func (*ListIrreparableSegmentsResponse) GetSegments ¶
func (m *ListIrreparableSegmentsResponse) GetSegments() []*IrreparableSegment
func (*ListIrreparableSegmentsResponse) ProtoMessage ¶
func (*ListIrreparableSegmentsResponse) ProtoMessage()
func (*ListIrreparableSegmentsResponse) String ¶
func (m *ListIrreparableSegmentsResponse) String() string
func (*ListIrreparableSegmentsResponse) XXX_DiscardUnknown ¶
func (m *ListIrreparableSegmentsResponse) XXX_DiscardUnknown()
func (*ListIrreparableSegmentsResponse) XXX_Marshal ¶
func (m *ListIrreparableSegmentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListIrreparableSegmentsResponse) XXX_Merge ¶
func (m *ListIrreparableSegmentsResponse) XXX_Merge(src proto.Message)
func (*ListIrreparableSegmentsResponse) XXX_Size ¶
func (m *ListIrreparableSegmentsResponse) XXX_Size() int
func (*ListIrreparableSegmentsResponse) XXX_Unmarshal ¶
func (m *ListIrreparableSegmentsResponse) 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 ObjectHealthRequest ¶
type ObjectHealthRequest struct {
EncryptedPath []byte `protobuf:"bytes,1,opt,name=encrypted_path,json=encryptedPath,proto3" json:"encrypted_path,omitempty"`
Bucket []byte `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
ProjectId []byte `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
StartAfterSegment int64 `protobuf:"varint,4,opt,name=start_after_segment,json=startAfterSegment,proto3" json:"start_after_segment,omitempty"`
EndBeforeSegment int64 `protobuf:"varint,5,opt,name=end_before_segment,json=endBeforeSegment,proto3" json:"end_before_segment,omitempty"`
Limit int32 `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ObjectHealthRequest) Descriptor ¶
func (*ObjectHealthRequest) Descriptor() ([]byte, []int)
func (*ObjectHealthRequest) GetEncryptedPath ¶
func (m *ObjectHealthRequest) GetEncryptedPath() []byte
func (*ObjectHealthRequest) GetEndBeforeSegment ¶
func (m *ObjectHealthRequest) GetEndBeforeSegment() int64
func (*ObjectHealthRequest) GetProjectId ¶
func (m *ObjectHealthRequest) GetProjectId() []byte
func (*ObjectHealthRequest) GetStartAfterSegment ¶
func (m *ObjectHealthRequest) GetStartAfterSegment() int64
func (*ObjectHealthRequest) ProtoMessage ¶
func (*ObjectHealthRequest) ProtoMessage()
func (*ObjectHealthRequest) XXX_DiscardUnknown ¶
func (m *ObjectHealthRequest) XXX_DiscardUnknown()
func (*ObjectHealthRequest) XXX_Marshal ¶
func (m *ObjectHealthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ObjectHealthRequest) XXX_Unmarshal ¶
func (m *ObjectHealthRequest) XXX_Unmarshal(b []byte) error
type ObjectHealthResponse ¶
type ObjectHealthResponse struct {
Segments []*SegmentHealth `protobuf:"bytes,1,rep,name=segments,proto3" json:"segments,omitempty"`
Redundancy *pb.RedundancyScheme `protobuf:"bytes,2,opt,name=redundancy,proto3" json:"redundancy,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ObjectHealthResponse) Descriptor ¶
func (*ObjectHealthResponse) Descriptor() ([]byte, []int)
func (*ObjectHealthResponse) GetRedundancy ¶
func (m *ObjectHealthResponse) GetRedundancy() *pb.RedundancyScheme
func (*ObjectHealthResponse) GetSegments ¶
func (m *ObjectHealthResponse) GetSegments() []*SegmentHealth
func (*ObjectHealthResponse) ProtoMessage ¶
func (*ObjectHealthResponse) ProtoMessage()
func (*ObjectHealthResponse) XXX_DiscardUnknown ¶
func (m *ObjectHealthResponse) XXX_DiscardUnknown()
func (*ObjectHealthResponse) XXX_Marshal ¶
func (m *ObjectHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ObjectHealthResponse) XXX_Merge ¶
func (m *ObjectHealthResponse) XXX_Merge(src proto.Message)
func (*ObjectHealthResponse) XXX_Unmarshal ¶
func (m *ObjectHealthResponse) XXX_Unmarshal(b []byte) error
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 */
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) GetProjectBucketPrefix ¶ added in v1.19.9
func (m *OrderLimitMetadata) GetProjectBucketPrefix() []byte
func (*OrderLimitMetadata) ProtoMessage ¶ added in v1.19.9
func (*OrderLimitMetadata) ProtoMessage()
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_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 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) 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) 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_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) 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_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) ProtoMessage ¶
func (*RepairJobResponse) ProtoMessage()
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_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) 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) 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_Unmarshal ¶
func (m *RepairJobResult) XXX_Unmarshal(b []byte) error
type SegmentHealth ¶
type SegmentHealth struct {
HealthyIds []NodeID `protobuf:"bytes,1,rep,name=healthy_ids,json=healthyIds,proto3,customtype=NodeID" json:"healthy_ids,omitempty"`
UnhealthyIds []NodeID `protobuf:"bytes,2,rep,name=unhealthy_ids,json=unhealthyIds,proto3,customtype=NodeID" json:"unhealthy_ids,omitempty"`
OfflineIds []NodeID `protobuf:"bytes,3,rep,name=offline_ids,json=offlineIds,proto3,customtype=NodeID" json:"offline_ids,omitempty"`
Segment []byte `protobuf:"bytes,4,opt,name=segment,proto3" json:"segment,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*SegmentHealth) Descriptor ¶
func (*SegmentHealth) Descriptor() ([]byte, []int)
func (*SegmentHealth) GetSegment ¶
func (m *SegmentHealth) GetSegment() []byte
func (*SegmentHealth) ProtoMessage ¶
func (*SegmentHealth) ProtoMessage()
func (*SegmentHealth) XXX_DiscardUnknown ¶
func (m *SegmentHealth) XXX_DiscardUnknown()
func (*SegmentHealth) XXX_Marshal ¶
func (m *SegmentHealth) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SegmentHealth) XXX_Unmarshal ¶
func (m *SegmentHealth) XXX_Unmarshal(b []byte) error
type SegmentHealthRequest ¶
type SegmentHealthRequest struct {
Bucket []byte `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
EncryptedPath []byte `protobuf:"bytes,2,opt,name=encrypted_path,json=encryptedPath,proto3" json:"encrypted_path,omitempty"`
SegmentIndex int64 `protobuf:"varint,3,opt,name=segment_index,json=segmentIndex,proto3" json:"segment_index,omitempty"`
ProjectId []byte `protobuf:"bytes,4,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*SegmentHealthRequest) Descriptor ¶
func (*SegmentHealthRequest) Descriptor() ([]byte, []int)
func (*SegmentHealthRequest) GetEncryptedPath ¶
func (m *SegmentHealthRequest) GetEncryptedPath() []byte
func (*SegmentHealthRequest) GetProjectId ¶
func (m *SegmentHealthRequest) GetProjectId() []byte
func (*SegmentHealthRequest) GetSegmentIndex ¶
func (m *SegmentHealthRequest) GetSegmentIndex() int64
func (*SegmentHealthRequest) ProtoMessage ¶
func (*SegmentHealthRequest) ProtoMessage()
func (*SegmentHealthRequest) XXX_DiscardUnknown ¶
func (m *SegmentHealthRequest) XXX_DiscardUnknown()
func (*SegmentHealthRequest) XXX_Marshal ¶
func (m *SegmentHealthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SegmentHealthRequest) XXX_Merge ¶
func (m *SegmentHealthRequest) XXX_Merge(src proto.Message)
func (*SegmentHealthRequest) XXX_Unmarshal ¶
func (m *SegmentHealthRequest) XXX_Unmarshal(b []byte) error
type SegmentHealthResponse ¶
type SegmentHealthResponse struct {
Health *SegmentHealth `protobuf:"bytes,1,opt,name=health,proto3" json:"health,omitempty"`
Redundancy *pb.RedundancyScheme `protobuf:"bytes,2,opt,name=redundancy,proto3" json:"redundancy,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*SegmentHealthResponse) Descriptor ¶
func (*SegmentHealthResponse) Descriptor() ([]byte, []int)
func (*SegmentHealthResponse) GetHealth ¶
func (m *SegmentHealthResponse) GetHealth() *SegmentHealth
func (*SegmentHealthResponse) GetRedundancy ¶
func (m *SegmentHealthResponse) GetRedundancy() *pb.RedundancyScheme
func (*SegmentHealthResponse) ProtoMessage ¶
func (*SegmentHealthResponse) ProtoMessage()
func (*SegmentHealthResponse) XXX_DiscardUnknown ¶
func (m *SegmentHealthResponse) XXX_DiscardUnknown()
func (*SegmentHealthResponse) XXX_Marshal ¶
func (m *SegmentHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SegmentHealthResponse) XXX_Merge ¶
func (m *SegmentHealthResponse) XXX_Merge(src proto.Message)
func (*SegmentHealthResponse) XXX_Unmarshal ¶
func (m *SegmentHealthResponse) 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"`
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) GetOriginalOrderLimits ¶
func (m *SegmentID) GetOriginalOrderLimits() []*pb.AddressedOrderLimit
func (*SegmentID) GetPartNumber ¶
func (m *SegmentID) GetPartNumber() int32
func (*SegmentID) GetSatelliteSignature ¶
func (m *SegmentID) GetSatelliteSignature() []byte
func (*SegmentID) GetStreamId ¶
func (m *SegmentID) GetStreamId() *StreamID
func (*SegmentID) ProtoMessage ¶
func (*SegmentID) ProtoMessage()
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_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"`
EncryptedPath []byte `protobuf:"bytes,2,opt,name=encrypted_path,json=encryptedPath,proto3" json:"encrypted_path,omitempty"`
Version int32 `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
Redundancy *pb.RedundancyScheme `protobuf:"bytes,4,opt,name=redundancy,proto3" json:"redundancy,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"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*StreamID) Descriptor ¶
func (*StreamID) Descriptor() ([]byte, []int)
func (*StreamID) GetCreationDate ¶
func (m *StreamID) GetCreationDate() time.Time
func (*StreamID) GetEncryptedPath ¶
func (m *StreamID) GetEncryptedPath() []byte
func (*StreamID) GetExpirationDate ¶
func (m *StreamID) GetExpirationDate() time.Time
func (*StreamID) GetMultipartObject ¶ added in v1.26.2
func (m *StreamID) GetMultipartObject() bool
func (*StreamID) GetRedundancy ¶
func (m *StreamID) GetRedundancy() *pb.RedundancyScheme
func (*StreamID) GetSatelliteSignature ¶
func (m *StreamID) GetSatelliteSignature() []byte
func (*StreamID) GetStreamId ¶
func (m *StreamID) GetStreamId() []byte
func (*StreamID) GetVersion ¶
func (m *StreamID) GetVersion() int32
func (*StreamID) ProtoMessage ¶
func (*StreamID) ProtoMessage()
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_Unmarshal ¶
func (m *StreamID) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.