pb

Jan 1, 2020

Changes in this version

type DRPCPiecestoreClient

+ DeletePieces func(ctx context.Context, in *DeletePiecesRequest) (*DeletePiecesResponse, error)

type DRPCPiecestoreServer

+ DeletePieces func(context.Context, *DeletePiecesRequest) (*DeletePiecesResponse, error)

+ type DRPCPiecestore_DeletePiecesStream interface

+ SendAndClose func(*DeletePiecesResponse) error

+ type DeletePiecesRequest struct

+ PieceIds []PieceID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeletePiecesRequest) Descriptor() ([]byte, []int)

+ func (*DeletePiecesRequest) ProtoMessage()

+ func (m *DeletePiecesRequest) Reset()

+ func (m *DeletePiecesRequest) String() string

+ func (m *DeletePiecesRequest) XXX_DiscardUnknown()

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

+ func (m *DeletePiecesRequest) XXX_Merge(src proto.Message)

+ func (m *DeletePiecesRequest) XXX_Size() int

+ func (m *DeletePiecesRequest) XXX_Unmarshal(b []byte) error

+ type DeletePiecesResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeletePiecesResponse) Descriptor() ([]byte, []int)

+ func (*DeletePiecesResponse) ProtoMessage()

+ func (m *DeletePiecesResponse) Reset()

+ func (m *DeletePiecesResponse) String() string

+ func (m *DeletePiecesResponse) XXX_DiscardUnknown()

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

+ func (m *DeletePiecesResponse) XXX_Merge(src proto.Message)

+ func (m *DeletePiecesResponse) XXX_Size() int

+ func (m *DeletePiecesResponse) XXX_Unmarshal(b []byte) error

type PiecestoreClient

+ DeletePieces func(ctx context.Context, in *DeletePiecesRequest, opts ...grpc.CallOption) (*DeletePiecesResponse, error)

type PiecestoreServer

+ DeletePieces func(context.Context, *DeletePiecesRequest) (*DeletePiecesResponse, error)

Dec 10, 2019

Changes in this version

type DRPCPiecestoreClient

+ DeletePiece func(ctx context.Context, in *PieceDeletePieceRequest) (*PieceDeletePieceResponse, error)

+ RestoreTrash func(ctx context.Context, in *RestoreTrashRequest) (*RestoreTrashResponse, error)

type DRPCPiecestoreServer

+ DeletePiece func(context.Context, *PieceDeletePieceRequest) (*PieceDeletePieceResponse, error)

+ RestoreTrash func(context.Context, *RestoreTrashRequest) (*RestoreTrashResponse, error)

+ type DRPCPiecestore_DeletePieceStream interface

+ SendAndClose func(*PieceDeletePieceResponse) error

+ type DRPCPiecestore_RestoreTrashStream interface

+ SendAndClose func(*RestoreTrashResponse) error

type ExitProgress

+ CompletionReceipt []byte

+ func (m *ExitProgress) GetCompletionReceipt() []byte

type GetTokensRequest

+ OwnerSatelliteId NodeID

+ OwnerUserId []byte

+ func (m *GetTokensRequest) GetOwnerUserId() []byte

type GetTokensResponse

+ TokenSecrets [][]byte

+ func (m *GetTokensResponse) GetTokenSecrets() [][]byte

+ type PieceDeletePieceRequest struct

+ PieceId PieceID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceDeletePieceRequest) Descriptor() ([]byte, []int)

+ func (*PieceDeletePieceRequest) ProtoMessage()

+ func (m *PieceDeletePieceRequest) Reset()

+ func (m *PieceDeletePieceRequest) String() string

+ func (m *PieceDeletePieceRequest) XXX_DiscardUnknown()

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

+ func (m *PieceDeletePieceRequest) XXX_Merge(src proto.Message)

+ func (m *PieceDeletePieceRequest) XXX_Size() int

+ func (m *PieceDeletePieceRequest) XXX_Unmarshal(b []byte) error

+ type PieceDeletePieceResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceDeletePieceResponse) Descriptor() ([]byte, []int)

+ func (*PieceDeletePieceResponse) ProtoMessage()

+ func (m *PieceDeletePieceResponse) Reset()

+ func (m *PieceDeletePieceResponse) String() string

+ func (m *PieceDeletePieceResponse) XXX_DiscardUnknown()

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

+ func (m *PieceDeletePieceResponse) XXX_Merge(src proto.Message)

+ func (m *PieceDeletePieceResponse) XXX_Size() int

+ func (m *PieceDeletePieceResponse) XXX_Unmarshal(b []byte) error

type PiecestoreClient

+ DeletePiece func(ctx context.Context, in *PieceDeletePieceRequest, opts ...grpc.CallOption) (*PieceDeletePieceResponse, error)

+ RestoreTrash func(ctx context.Context, in *RestoreTrashRequest, opts ...grpc.CallOption) (*RestoreTrashResponse, error)

type PiecestoreServer

+ DeletePiece func(context.Context, *PieceDeletePieceRequest) (*PieceDeletePieceResponse, error)

+ RestoreTrash func(context.Context, *RestoreTrashRequest) (*RestoreTrashResponse, error)

type RequestHeader

+ UserAgent []byte

+ func (m *RequestHeader) GetUserAgent() []byte

+ type RestoreTrashRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RestoreTrashRequest) Descriptor() ([]byte, []int)

+ func (*RestoreTrashRequest) ProtoMessage()

+ func (m *RestoreTrashRequest) Reset()

+ func (m *RestoreTrashRequest) String() string

+ func (m *RestoreTrashRequest) XXX_DiscardUnknown()

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

+ func (m *RestoreTrashRequest) XXX_Merge(src proto.Message)

+ func (m *RestoreTrashRequest) XXX_Size() int

+ func (m *RestoreTrashRequest) XXX_Unmarshal(b []byte) error

+ type RestoreTrashResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RestoreTrashResponse) Descriptor() ([]byte, []int)

+ func (*RestoreTrashResponse) ProtoMessage()

+ func (m *RestoreTrashResponse) Reset()

+ func (m *RestoreTrashResponse) String() string

+ func (m *RestoreTrashResponse) XXX_DiscardUnknown()

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

+ func (m *RestoreTrashResponse) XXX_Merge(src proto.Message)

+ func (m *RestoreTrashResponse) XXX_Size() int

+ func (m *RestoreTrashResponse) XXX_Unmarshal(b []byte) error

Nov 19, 2019

Changes in this version

+ func DRPCRegisterReferralManager(srv drpc.Server, impl DRPCReferralManagerServer)

+ func RegisterReferralManagerServer(s *grpc.Server, srv ReferralManagerServer)

+ type DRPCReferralManagerClient interface

+ DRPCConn func() drpc.Conn

+ GetTokens func(ctx context.Context, in *GetTokensRequest) (*GetTokensResponse, error)

+ RedeemToken func(ctx context.Context, in *RedeemTokenRequest) (*RedeemTokenResponse, error)

+ func NewDRPCReferralManagerClient(cc drpc.Conn) DRPCReferralManagerClient

+ type DRPCReferralManagerDescription struct

+ func (DRPCReferralManagerDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCReferralManagerDescription) NumMethods() int

+ type DRPCReferralManagerServer interface

+ GetTokens func(context.Context, *GetTokensRequest) (*GetTokensResponse, error)

+ RedeemToken func(context.Context, *RedeemTokenRequest) (*RedeemTokenResponse, error)

+ type DRPCReferralManager_GetTokensStream interface

+ SendAndClose func(*GetTokensResponse) error

+ type DRPCReferralManager_RedeemTokenStream interface

+ SendAndClose func(*RedeemTokenResponse) error

+ type GetTokensRequest struct

+ UserId []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTokensRequest) Descriptor() ([]byte, []int)

+ func (*GetTokensRequest) ProtoMessage()

+ func (m *GetTokensRequest) GetUserId() []byte

+ func (m *GetTokensRequest) Reset()

+ func (m *GetTokensRequest) String() string

+ func (m *GetTokensRequest) XXX_DiscardUnknown()

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

+ func (m *GetTokensRequest) XXX_Merge(src proto.Message)

+ func (m *GetTokensRequest) XXX_Size() int

+ func (m *GetTokensRequest) XXX_Unmarshal(b []byte) error

+ type GetTokensResponse struct

+ Token [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetTokensResponse) Descriptor() ([]byte, []int)

+ func (*GetTokensResponse) ProtoMessage()

+ func (m *GetTokensResponse) GetToken() [][]byte

+ func (m *GetTokensResponse) Reset()

+ func (m *GetTokensResponse) String() string

+ func (m *GetTokensResponse) XXX_DiscardUnknown()

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

+ func (m *GetTokensResponse) XXX_Merge(src proto.Message)

+ func (m *GetTokensResponse) XXX_Size() int

+ func (m *GetTokensResponse) XXX_Unmarshal(b []byte) error

+ type RedeemTokenRequest struct

+ RedeemSatelliteId NodeID

+ RedeemUserId []byte

+ Token []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RedeemTokenRequest) Descriptor() ([]byte, []int)

+ func (*RedeemTokenRequest) ProtoMessage()

+ func (m *RedeemTokenRequest) GetRedeemUserId() []byte

+ func (m *RedeemTokenRequest) GetToken() []byte

+ func (m *RedeemTokenRequest) Reset()

+ func (m *RedeemTokenRequest) String() string

+ func (m *RedeemTokenRequest) XXX_DiscardUnknown()

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

+ func (m *RedeemTokenRequest) XXX_Merge(src proto.Message)

+ func (m *RedeemTokenRequest) XXX_Size() int

+ func (m *RedeemTokenRequest) XXX_Unmarshal(b []byte) error

+ type RedeemTokenResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RedeemTokenResponse) Descriptor() ([]byte, []int)

+ func (*RedeemTokenResponse) ProtoMessage()

+ func (m *RedeemTokenResponse) Reset()

+ func (m *RedeemTokenResponse) String() string

+ func (m *RedeemTokenResponse) XXX_DiscardUnknown()

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

+ func (m *RedeemTokenResponse) XXX_Merge(src proto.Message)

+ func (m *RedeemTokenResponse) XXX_Size() int

+ func (m *RedeemTokenResponse) XXX_Unmarshal(b []byte) error

+ type ReferralManagerClient interface

+ GetTokens func(ctx context.Context, in *GetTokensRequest, opts ...grpc.CallOption) (*GetTokensResponse, error)

+ RedeemToken func(ctx context.Context, in *RedeemTokenRequest, opts ...grpc.CallOption) (*RedeemTokenResponse, error)

+ func NewReferralManagerClient(cc *grpc.ClientConn) ReferralManagerClient

+ type ReferralManagerServer interface

+ GetTokens func(context.Context, *GetTokensRequest) (*GetTokensResponse, error)

+ RedeemToken func(context.Context, *RedeemTokenRequest) (*RedeemTokenResponse, error)

Nov 5, 2019

Changes in this version

+ func DRPCRegisterPayments(srv drpc.Server, impl DRPCPaymentsServer)

+ func RegisterPaymentsServer(s *grpc.Server, srv PaymentsServer)

+ type ApplyInvoiceRecordsRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ApplyInvoiceRecordsRequest) Descriptor() ([]byte, []int)

+ func (*ApplyInvoiceRecordsRequest) ProtoMessage()

+ func (m *ApplyInvoiceRecordsRequest) Reset()

+ func (m *ApplyInvoiceRecordsRequest) String() string

+ func (m *ApplyInvoiceRecordsRequest) XXX_DiscardUnknown()

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

+ func (m *ApplyInvoiceRecordsRequest) XXX_Merge(src proto.Message)

+ func (m *ApplyInvoiceRecordsRequest) XXX_Size() int

+ func (m *ApplyInvoiceRecordsRequest) XXX_Unmarshal(b []byte) error

+ type ApplyInvoiceRecordsResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ApplyInvoiceRecordsResponse) Descriptor() ([]byte, []int)

+ func (*ApplyInvoiceRecordsResponse) ProtoMessage()

+ func (m *ApplyInvoiceRecordsResponse) Reset()

+ func (m *ApplyInvoiceRecordsResponse) String() string

+ func (m *ApplyInvoiceRecordsResponse) XXX_DiscardUnknown()

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

+ func (m *ApplyInvoiceRecordsResponse) XXX_Merge(src proto.Message)

+ func (m *ApplyInvoiceRecordsResponse) XXX_Size() int

+ func (m *ApplyInvoiceRecordsResponse) XXX_Unmarshal(b []byte) error

+ type CreateInvoicesRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateInvoicesRequest) Descriptor() ([]byte, []int)

+ func (*CreateInvoicesRequest) ProtoMessage()

+ func (m *CreateInvoicesRequest) Reset()

+ func (m *CreateInvoicesRequest) String() string

+ func (m *CreateInvoicesRequest) XXX_DiscardUnknown()

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

+ func (m *CreateInvoicesRequest) XXX_Merge(src proto.Message)

+ func (m *CreateInvoicesRequest) XXX_Size() int

+ func (m *CreateInvoicesRequest) XXX_Unmarshal(b []byte) error

+ type CreateInvoicesResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateInvoicesResponse) Descriptor() ([]byte, []int)

+ func (*CreateInvoicesResponse) ProtoMessage()

+ func (m *CreateInvoicesResponse) Reset()

+ func (m *CreateInvoicesResponse) String() string

+ func (m *CreateInvoicesResponse) XXX_DiscardUnknown()

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

+ func (m *CreateInvoicesResponse) XXX_Merge(src proto.Message)

+ func (m *CreateInvoicesResponse) XXX_Size() int

+ func (m *CreateInvoicesResponse) XXX_Unmarshal(b []byte) error

+ type DRPCPaymentsClient interface

+ ApplyInvoiceRecords func(ctx context.Context, in *ApplyInvoiceRecordsRequest) (*ApplyInvoiceRecordsResponse, error)

+ CreateInvoices func(ctx context.Context, in *CreateInvoicesRequest) (*CreateInvoicesResponse, error)

+ DRPCConn func() drpc.Conn

+ PrepareInvoiceRecords func(ctx context.Context, in *PrepareInvoiceRecordsRequest) (*PrepareInvoiceRecordsResponse, error)

+ func NewDRPCPaymentsClient(cc drpc.Conn) DRPCPaymentsClient

+ type DRPCPaymentsDescription struct

+ func (DRPCPaymentsDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCPaymentsDescription) NumMethods() int

+ type DRPCPaymentsServer interface

+ ApplyInvoiceRecords func(context.Context, *ApplyInvoiceRecordsRequest) (*ApplyInvoiceRecordsResponse, error)

+ CreateInvoices func(context.Context, *CreateInvoicesRequest) (*CreateInvoicesResponse, error)

+ PrepareInvoiceRecords func(context.Context, *PrepareInvoiceRecordsRequest) (*PrepareInvoiceRecordsResponse, error)

+ type DRPCPayments_ApplyInvoiceRecordsStream interface

+ SendAndClose func(*ApplyInvoiceRecordsResponse) error

+ type DRPCPayments_CreateInvoicesStream interface

+ SendAndClose func(*CreateInvoicesResponse) error

+ type DRPCPayments_PrepareInvoiceRecordsStream interface

+ SendAndClose func(*PrepareInvoiceRecordsResponse) error

type ExitCompleted

+ Completed time.Time

+ NodeId NodeID

+ SatelliteId NodeID

+ func (m *ExitCompleted) GetCompleted() time.Time

type ExitFailed

+ Failed time.Time

+ NodeId NodeID

+ SatelliteId NodeID

+ func (m *ExitFailed) GetFailed() time.Time

type ExitFailed_Reason

+ const ExitFailed_INACTIVE_TIMEFRAME_EXCEEDED

+ const ExitFailed_OVERALL_FAILURE_PERCENTAGE_EXCEEDED

+ type PaymentsClient interface

+ ApplyInvoiceRecords func(ctx context.Context, in *ApplyInvoiceRecordsRequest, opts ...grpc.CallOption) (*ApplyInvoiceRecordsResponse, error)

+ CreateInvoices func(ctx context.Context, in *CreateInvoicesRequest, opts ...grpc.CallOption) (*CreateInvoicesResponse, error)

+ PrepareInvoiceRecords func(ctx context.Context, in *PrepareInvoiceRecordsRequest, opts ...grpc.CallOption) (*PrepareInvoiceRecordsResponse, error)

+ func NewPaymentsClient(cc *grpc.ClientConn) PaymentsClient

+ type PaymentsServer interface

+ ApplyInvoiceRecords func(context.Context, *ApplyInvoiceRecordsRequest) (*ApplyInvoiceRecordsResponse, error)

+ CreateInvoices func(context.Context, *CreateInvoicesRequest) (*CreateInvoicesResponse, error)

+ PrepareInvoiceRecords func(context.Context, *PrepareInvoiceRecordsRequest) (*PrepareInvoiceRecordsResponse, error)

+ type PrepareInvoiceRecordsRequest struct

+ Period time.Time

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PrepareInvoiceRecordsRequest) Descriptor() ([]byte, []int)

+ func (*PrepareInvoiceRecordsRequest) ProtoMessage()

+ func (m *PrepareInvoiceRecordsRequest) GetPeriod() time.Time

+ func (m *PrepareInvoiceRecordsRequest) Reset()

+ func (m *PrepareInvoiceRecordsRequest) String() string

+ func (m *PrepareInvoiceRecordsRequest) XXX_DiscardUnknown()

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

+ func (m *PrepareInvoiceRecordsRequest) XXX_Merge(src proto.Message)

+ func (m *PrepareInvoiceRecordsRequest) XXX_Size() int

+ func (m *PrepareInvoiceRecordsRequest) XXX_Unmarshal(b []byte) error

+ type PrepareInvoiceRecordsResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PrepareInvoiceRecordsResponse) Descriptor() ([]byte, []int)

+ func (*PrepareInvoiceRecordsResponse) ProtoMessage()

+ func (m *PrepareInvoiceRecordsResponse) Reset()

+ func (m *PrepareInvoiceRecordsResponse) String() string

+ func (m *PrepareInvoiceRecordsResponse) XXX_DiscardUnknown()

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

+ func (m *PrepareInvoiceRecordsResponse) XXX_Merge(src proto.Message)

+ func (m *PrepareInvoiceRecordsResponse) XXX_Size() int

+ func (m *PrepareInvoiceRecordsResponse) XXX_Unmarshal(b []byte) error

Oct 23, 2019

Changes in this version

+ var ExitFailed_Reason_name = map[int32]string

+ var ExitFailed_Reason_value = map[string]int32

+ var TransferFailed_Error_name = map[int32]string

+ var TransferFailed_Error_value = map[string]int32

+ func DRPCRegisterNodeGracefulExit(srv drpc.Server, impl DRPCNodeGracefulExitServer)

+ func DRPCRegisterSatelliteGracefulExit(srv drpc.Server, impl DRPCSatelliteGracefulExitServer)

+ func RegisterNodeGracefulExitServer(s *grpc.Server, srv NodeGracefulExitServer)

+ func RegisterSatelliteGracefulExitServer(s *grpc.Server, srv SatelliteGracefulExitServer)

+ type DRPCNodeGracefulExitClient interface

+ DRPCConn func() drpc.Conn

+ GetExitProgress func(ctx context.Context, in *GetExitProgressRequest) (*GetExitProgressResponse, error)

+ GetNonExitingSatellites func(ctx context.Context, in *GetNonExitingSatellitesRequest) (*GetNonExitingSatellitesResponse, error)

+ InitiateGracefulExit func(ctx context.Context, in *InitiateGracefulExitRequest) (*ExitProgress, error)

+ func NewDRPCNodeGracefulExitClient(cc drpc.Conn) DRPCNodeGracefulExitClient

+ type DRPCNodeGracefulExitDescription struct

+ func (DRPCNodeGracefulExitDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCNodeGracefulExitDescription) NumMethods() int

+ type DRPCNodeGracefulExitServer interface

+ GetExitProgress func(context.Context, *GetExitProgressRequest) (*GetExitProgressResponse, error)

+ GetNonExitingSatellites func(context.Context, *GetNonExitingSatellitesRequest) (*GetNonExitingSatellitesResponse, error)

+ InitiateGracefulExit func(context.Context, *InitiateGracefulExitRequest) (*ExitProgress, error)

+ type DRPCNodeGracefulExit_GetExitProgressStream interface

+ SendAndClose func(*GetExitProgressResponse) error

+ type DRPCNodeGracefulExit_GetNonExitingSatellitesStream interface

+ SendAndClose func(*GetNonExitingSatellitesResponse) error

+ type DRPCNodeGracefulExit_InitiateGracefulExitStream interface

+ SendAndClose func(*ExitProgress) error

+ type DRPCSatelliteGracefulExitClient interface

+ DRPCConn func() drpc.Conn

+ Process func(ctx context.Context) (DRPCSatelliteGracefulExit_ProcessClient, error)

+ func NewDRPCSatelliteGracefulExitClient(cc drpc.Conn) DRPCSatelliteGracefulExitClient

+ type DRPCSatelliteGracefulExitDescription struct

+ func (DRPCSatelliteGracefulExitDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCSatelliteGracefulExitDescription) NumMethods() int

+ type DRPCSatelliteGracefulExitServer interface

+ Process func(DRPCSatelliteGracefulExit_ProcessStream) error

+ type DRPCSatelliteGracefulExit_ProcessClient interface

+ Recv func() (*SatelliteMessage, error)

+ Send func(*StorageNodeMessage) error

+ type DRPCSatelliteGracefulExit_ProcessStream interface

+ Recv func() (*StorageNodeMessage, error)

+ Send func(*SatelliteMessage) error

+ type DeletePiece struct

+ OriginalPieceId PieceID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeletePiece) Descriptor() ([]byte, []int)

+ func (*DeletePiece) ProtoMessage()

+ func (m *DeletePiece) Reset()

+ func (m *DeletePiece) String() string

+ func (m *DeletePiece) XXX_DiscardUnknown()

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

+ func (m *DeletePiece) XXX_Merge(src proto.Message)

+ func (m *DeletePiece) XXX_Size() int

+ func (m *DeletePiece) XXX_Unmarshal(b []byte) error

+ type ExitCompleted struct

+ ExitCompleteSignature []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ExitCompleted) Descriptor() ([]byte, []int)

+ func (*ExitCompleted) ProtoMessage()

+ func (m *ExitCompleted) GetExitCompleteSignature() []byte

+ func (m *ExitCompleted) Reset()

+ func (m *ExitCompleted) String() string

+ func (m *ExitCompleted) XXX_DiscardUnknown()

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

+ func (m *ExitCompleted) XXX_Merge(src proto.Message)

+ func (m *ExitCompleted) XXX_Size() int

+ func (m *ExitCompleted) XXX_Unmarshal(b []byte) error

+ type ExitFailed struct

+ ExitFailureSignature []byte

+ Reason ExitFailed_Reason

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ExitFailed) Descriptor() ([]byte, []int)

+ func (*ExitFailed) ProtoMessage()

+ func (m *ExitFailed) GetExitFailureSignature() []byte

+ func (m *ExitFailed) GetReason() ExitFailed_Reason

+ func (m *ExitFailed) Reset()

+ func (m *ExitFailed) String() string

+ func (m *ExitFailed) XXX_DiscardUnknown()

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

+ func (m *ExitFailed) XXX_Merge(src proto.Message)

+ func (m *ExitFailed) XXX_Size() int

+ func (m *ExitFailed) XXX_Unmarshal(b []byte) error

+ type ExitFailed_Reason int32

+ const ExitFailed_VERIFICATION_FAILED

+ func (ExitFailed_Reason) EnumDescriptor() ([]byte, []int)

+ func (x ExitFailed_Reason) String() string

+ type ExitProgress struct

+ DomainName string

+ NodeId NodeID

+ PercentComplete float32

+ Successful bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ExitProgress) Descriptor() ([]byte, []int)

+ func (*ExitProgress) ProtoMessage()

+ func (m *ExitProgress) GetDomainName() string

+ func (m *ExitProgress) GetPercentComplete() float32

+ func (m *ExitProgress) GetSuccessful() bool

+ func (m *ExitProgress) Reset()

+ func (m *ExitProgress) String() string

+ func (m *ExitProgress) XXX_DiscardUnknown()

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

+ func (m *ExitProgress) XXX_Merge(src proto.Message)

+ func (m *ExitProgress) XXX_Size() int

+ func (m *ExitProgress) XXX_Unmarshal(b []byte) error

+ type GetExitProgressRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetExitProgressRequest) Descriptor() ([]byte, []int)

+ func (*GetExitProgressRequest) ProtoMessage()

+ func (m *GetExitProgressRequest) Reset()

+ func (m *GetExitProgressRequest) String() string

+ func (m *GetExitProgressRequest) XXX_DiscardUnknown()

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

+ func (m *GetExitProgressRequest) XXX_Merge(src proto.Message)

+ func (m *GetExitProgressRequest) XXX_Size() int

+ func (m *GetExitProgressRequest) XXX_Unmarshal(b []byte) error

+ type GetExitProgressResponse struct

+ Progress []*ExitProgress

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetExitProgressResponse) Descriptor() ([]byte, []int)

+ func (*GetExitProgressResponse) ProtoMessage()

+ func (m *GetExitProgressResponse) GetProgress() []*ExitProgress

+ func (m *GetExitProgressResponse) Reset()

+ func (m *GetExitProgressResponse) String() string

+ func (m *GetExitProgressResponse) XXX_DiscardUnknown()

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

+ func (m *GetExitProgressResponse) XXX_Merge(src proto.Message)

+ func (m *GetExitProgressResponse) XXX_Size() int

+ func (m *GetExitProgressResponse) XXX_Unmarshal(b []byte) error

+ type GetNonExitingSatellitesRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetNonExitingSatellitesRequest) Descriptor() ([]byte, []int)

+ func (*GetNonExitingSatellitesRequest) ProtoMessage()

+ func (m *GetNonExitingSatellitesRequest) Reset()

+ func (m *GetNonExitingSatellitesRequest) String() string

+ func (m *GetNonExitingSatellitesRequest) XXX_DiscardUnknown()

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

+ func (m *GetNonExitingSatellitesRequest) XXX_Merge(src proto.Message)

+ func (m *GetNonExitingSatellitesRequest) XXX_Size() int

+ func (m *GetNonExitingSatellitesRequest) XXX_Unmarshal(b []byte) error

+ type GetNonExitingSatellitesResponse struct

+ Satellites []*NonExitingSatellite

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetNonExitingSatellitesResponse) Descriptor() ([]byte, []int)

+ func (*GetNonExitingSatellitesResponse) ProtoMessage()

+ func (m *GetNonExitingSatellitesResponse) GetSatellites() []*NonExitingSatellite

+ func (m *GetNonExitingSatellitesResponse) Reset()

+ func (m *GetNonExitingSatellitesResponse) String() string

+ func (m *GetNonExitingSatellitesResponse) XXX_DiscardUnknown()

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

+ func (m *GetNonExitingSatellitesResponse) XXX_Merge(src proto.Message)

+ func (m *GetNonExitingSatellitesResponse) XXX_Size() int

+ func (m *GetNonExitingSatellitesResponse) XXX_Unmarshal(b []byte) error

+ type InitiateGracefulExitRequest struct

+ NodeId NodeID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*InitiateGracefulExitRequest) Descriptor() ([]byte, []int)

+ func (*InitiateGracefulExitRequest) ProtoMessage()

+ func (m *InitiateGracefulExitRequest) Reset()

+ func (m *InitiateGracefulExitRequest) String() string

+ func (m *InitiateGracefulExitRequest) XXX_DiscardUnknown()

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

+ func (m *InitiateGracefulExitRequest) XXX_Merge(src proto.Message)

+ func (m *InitiateGracefulExitRequest) XXX_Size() int

+ func (m *InitiateGracefulExitRequest) XXX_Unmarshal(b []byte) error

+ type NodeGracefulExitClient interface

+ GetExitProgress func(ctx context.Context, in *GetExitProgressRequest, opts ...grpc.CallOption) (*GetExitProgressResponse, error)

+ GetNonExitingSatellites func(ctx context.Context, in *GetNonExitingSatellitesRequest, ...) (*GetNonExitingSatellitesResponse, error)

+ InitiateGracefulExit func(ctx context.Context, in *InitiateGracefulExitRequest, opts ...grpc.CallOption) (*ExitProgress, error)

+ func NewNodeGracefulExitClient(cc *grpc.ClientConn) NodeGracefulExitClient

+ type NodeGracefulExitServer interface

+ GetExitProgress func(context.Context, *GetExitProgressRequest) (*GetExitProgressResponse, error)

+ GetNonExitingSatellites func(context.Context, *GetNonExitingSatellitesRequest) (*GetNonExitingSatellitesResponse, error)

+ InitiateGracefulExit func(context.Context, *InitiateGracefulExitRequest) (*ExitProgress, error)

+ type NonExitingSatellite struct

+ DomainName string

+ NodeId NodeID

+ SpaceUsed float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NonExitingSatellite) Descriptor() ([]byte, []int)

+ func (*NonExitingSatellite) ProtoMessage()

+ func (m *NonExitingSatellite) GetDomainName() string

+ func (m *NonExitingSatellite) GetSpaceUsed() float64

+ func (m *NonExitingSatellite) Reset()

+ func (m *NonExitingSatellite) String() string

+ func (m *NonExitingSatellite) XXX_DiscardUnknown()

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

+ func (m *NonExitingSatellite) XXX_Merge(src proto.Message)

+ func (m *NonExitingSatellite) XXX_Size() int

+ func (m *NonExitingSatellite) XXX_Unmarshal(b []byte) error

+ type NotReady struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NotReady) Descriptor() ([]byte, []int)

+ func (*NotReady) ProtoMessage()

+ func (m *NotReady) Reset()

+ func (m *NotReady) String() string

+ func (m *NotReady) XXX_DiscardUnknown()

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

+ func (m *NotReady) XXX_Merge(src proto.Message)

+ func (m *NotReady) XXX_Size() int

+ func (m *NotReady) XXX_Unmarshal(b []byte) error

type PieceAction

+ const PieceAction_PUT_GRACEFUL_EXIT

+ type SatelliteGracefulExitClient interface

+ Process func(ctx context.Context, opts ...grpc.CallOption) (SatelliteGracefulExit_ProcessClient, error)

+ func NewSatelliteGracefulExitClient(cc *grpc.ClientConn) SatelliteGracefulExitClient

+ type SatelliteGracefulExitServer interface

+ Process func(SatelliteGracefulExit_ProcessServer) error

+ type SatelliteGracefulExit_ProcessClient interface

+ Recv func() (*SatelliteMessage, error)

+ Send func(*StorageNodeMessage) error

+ type SatelliteGracefulExit_ProcessServer interface

+ Recv func() (*StorageNodeMessage, error)

+ Send func(*SatelliteMessage) error

+ type SatelliteMessage struct

+ Message isSatelliteMessage_Message

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SatelliteMessage) Descriptor() ([]byte, []int)

+ func (*SatelliteMessage) ProtoMessage()

+ func (*SatelliteMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *SatelliteMessage) GetDeletePiece() *DeletePiece

+ func (m *SatelliteMessage) GetExitCompleted() *ExitCompleted

+ func (m *SatelliteMessage) GetExitFailed() *ExitFailed

+ func (m *SatelliteMessage) GetMessage() isSatelliteMessage_Message

+ func (m *SatelliteMessage) GetNotReady() *NotReady

+ func (m *SatelliteMessage) GetTransferPiece() *TransferPiece

+ func (m *SatelliteMessage) Reset()

+ func (m *SatelliteMessage) String() string

+ func (m *SatelliteMessage) XXX_DiscardUnknown()

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

+ func (m *SatelliteMessage) XXX_Merge(src proto.Message)

+ func (m *SatelliteMessage) XXX_Size() int

+ func (m *SatelliteMessage) XXX_Unmarshal(b []byte) error

+ type SatelliteMessage_DeletePiece struct

+ DeletePiece *DeletePiece

+ type SatelliteMessage_ExitCompleted struct

+ ExitCompleted *ExitCompleted

+ type SatelliteMessage_ExitFailed struct

+ ExitFailed *ExitFailed

+ type SatelliteMessage_NotReady struct

+ NotReady *NotReady

+ type SatelliteMessage_TransferPiece struct

+ TransferPiece *TransferPiece

+ type StorageNodeMessage struct

+ Message isStorageNodeMessage_Message

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StorageNodeMessage) Descriptor() ([]byte, []int)

+ func (*StorageNodeMessage) ProtoMessage()

+ func (*StorageNodeMessage) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *StorageNodeMessage) GetFailed() *TransferFailed

+ func (m *StorageNodeMessage) GetMessage() isStorageNodeMessage_Message

+ func (m *StorageNodeMessage) GetSucceeded() *TransferSucceeded

+ func (m *StorageNodeMessage) Reset()

+ func (m *StorageNodeMessage) String() string

+ func (m *StorageNodeMessage) XXX_DiscardUnknown()

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

+ func (m *StorageNodeMessage) XXX_Merge(src proto.Message)

+ func (m *StorageNodeMessage) XXX_Size() int

+ func (m *StorageNodeMessage) XXX_Unmarshal(b []byte) error

+ type StorageNodeMessage_Failed struct

+ Failed *TransferFailed

+ type StorageNodeMessage_Succeeded struct

+ Succeeded *TransferSucceeded

+ type TransferFailed struct

+ Error TransferFailed_Error

+ OriginalPieceId PieceID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TransferFailed) Descriptor() ([]byte, []int)

+ func (*TransferFailed) ProtoMessage()

+ func (m *TransferFailed) GetError() TransferFailed_Error

+ func (m *TransferFailed) Reset()

+ func (m *TransferFailed) String() string

+ func (m *TransferFailed) XXX_DiscardUnknown()

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

+ func (m *TransferFailed) XXX_Merge(src proto.Message)

+ func (m *TransferFailed) XXX_Size() int

+ func (m *TransferFailed) XXX_Unmarshal(b []byte) error

+ type TransferFailed_Error int32

+ const TransferFailed_HASH_VERIFICATION

+ const TransferFailed_NOT_FOUND

+ const TransferFailed_STORAGE_NODE_UNAVAILABLE

+ const TransferFailed_UNKNOWN

+ func (TransferFailed_Error) EnumDescriptor() ([]byte, []int)

+ func (x TransferFailed_Error) String() string

+ type TransferPiece struct

+ AddressedOrderLimit *AddressedOrderLimit

+ OriginalPieceId PieceID

+ PrivateKey PiecePrivateKey

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TransferPiece) Descriptor() ([]byte, []int)

+ func (*TransferPiece) ProtoMessage()

+ func (m *TransferPiece) GetAddressedOrderLimit() *AddressedOrderLimit

+ func (m *TransferPiece) Reset()

+ func (m *TransferPiece) String() string

+ func (m *TransferPiece) XXX_DiscardUnknown()

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

+ func (m *TransferPiece) XXX_Merge(src proto.Message)

+ func (m *TransferPiece) XXX_Size() int

+ func (m *TransferPiece) XXX_Unmarshal(b []byte) error

+ type TransferSucceeded struct

+ OriginalOrderLimit *OrderLimit

+ OriginalPieceHash *PieceHash

+ OriginalPieceId PieceID

+ ReplacementPieceHash *PieceHash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TransferSucceeded) Descriptor() ([]byte, []int)

+ func (*TransferSucceeded) ProtoMessage()

+ func (m *TransferSucceeded) GetOriginalOrderLimit() *OrderLimit

+ func (m *TransferSucceeded) GetOriginalPieceHash() *PieceHash

+ func (m *TransferSucceeded) GetReplacementPieceHash() *PieceHash

+ func (m *TransferSucceeded) Reset()

+ func (m *TransferSucceeded) String() string

+ func (m *TransferSucceeded) XXX_DiscardUnknown()

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

+ func (m *TransferSucceeded) XXX_Merge(src proto.Message)

+ func (m *TransferSucceeded) XXX_Size() int

+ func (m *TransferSucceeded) XXX_Unmarshal(b []byte) error

Oct 2, 2019

Changes in this version

type BatchRequest

+ Header *RequestHeader

+ func (m *BatchRequest) GetHeader() *RequestHeader

type BucketCreateRequest

+ Header *RequestHeader

+ func (m *BucketCreateRequest) GetHeader() *RequestHeader

type BucketDeleteRequest

+ Header *RequestHeader

+ func (m *BucketDeleteRequest) GetHeader() *RequestHeader

type BucketGetRequest

+ Header *RequestHeader

+ func (m *BucketGetRequest) GetHeader() *RequestHeader

type BucketListRequest

+ Header *RequestHeader

+ func (m *BucketListRequest) GetHeader() *RequestHeader

type BucketSetAttributionRequest

+ Header *RequestHeader

+ func (m *BucketSetAttributionRequest) GetHeader() *RequestHeader

type ListSegmentsRequestOld

+ Header *RequestHeader

+ func (m *ListSegmentsRequestOld) GetHeader() *RequestHeader

type ObjectBeginDeleteRequest

+ Header *RequestHeader

+ func (m *ObjectBeginDeleteRequest) GetHeader() *RequestHeader

type ObjectBeginRequest

+ Header *RequestHeader

+ func (m *ObjectBeginRequest) GetHeader() *RequestHeader

type ObjectCommitRequest

+ Header *RequestHeader

+ func (m *ObjectCommitRequest) GetHeader() *RequestHeader

type ObjectFinishDeleteRequest

+ Header *RequestHeader

+ func (m *ObjectFinishDeleteRequest) GetHeader() *RequestHeader

type ObjectGetRequest

+ Header *RequestHeader

+ func (m *ObjectGetRequest) GetHeader() *RequestHeader

type ObjectListRequest

+ Header *RequestHeader

+ func (m *ObjectListRequest) GetHeader() *RequestHeader

type Pointer

+ LastRepaired time.Time

+ PieceHashesVerified bool

+ RepairCount int32

+ func (m *Pointer) GetLastRepaired() time.Time

+ func (m *Pointer) GetPieceHashesVerified() bool

+ func (m *Pointer) GetRepairCount() int32

type ProjectInfoRequest

+ Header *RequestHeader

+ func (m *ProjectInfoRequest) GetHeader() *RequestHeader

+ type RequestHeader struct

+ ApiKey []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RequestHeader) Descriptor() ([]byte, []int)

+ func (*RequestHeader) ProtoMessage()

+ func (m *RequestHeader) GetApiKey() []byte

+ func (m *RequestHeader) Reset()

+ func (m *RequestHeader) String() string

+ func (m *RequestHeader) XXX_DiscardUnknown()

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

+ func (m *RequestHeader) XXX_Merge(src proto.Message)

+ func (m *RequestHeader) XXX_Size() int

+ func (m *RequestHeader) XXX_Unmarshal(b []byte) error

type SegmentBeginDeleteRequest

+ Header *RequestHeader

+ func (m *SegmentBeginDeleteRequest) GetHeader() *RequestHeader

type SegmentBeginRequest

+ Header *RequestHeader

+ func (m *SegmentBeginRequest) GetHeader() *RequestHeader

type SegmentCommitRequest

+ Header *RequestHeader

+ func (m *SegmentCommitRequest) GetHeader() *RequestHeader

type SegmentCommitRequestOld

+ Header *RequestHeader

+ func (m *SegmentCommitRequestOld) GetHeader() *RequestHeader

type SegmentCommitResponse

+ SuccessfulPieces int32

+ func (m *SegmentCommitResponse) GetSuccessfulPieces() int32

type SegmentDeleteRequestOld

+ Header *RequestHeader

+ func (m *SegmentDeleteRequestOld) GetHeader() *RequestHeader

type SegmentDownloadRequest

+ Header *RequestHeader

+ func (m *SegmentDownloadRequest) GetHeader() *RequestHeader

type SegmentDownloadRequestOld

+ Header *RequestHeader

+ func (m *SegmentDownloadRequestOld) GetHeader() *RequestHeader

type SegmentFinishDeleteRequest

+ Header *RequestHeader

+ func (m *SegmentFinishDeleteRequest) GetHeader() *RequestHeader

type SegmentInfoRequestOld

+ Header *RequestHeader

+ func (m *SegmentInfoRequestOld) GetHeader() *RequestHeader

type SegmentListRequest

+ Header *RequestHeader

+ func (m *SegmentListRequest) GetHeader() *RequestHeader

type SegmentMakeInlineRequest

+ Header *RequestHeader

+ func (m *SegmentMakeInlineRequest) GetHeader() *RequestHeader

type SegmentWriteRequestOld

+ Header *RequestHeader

+ func (m *SegmentWriteRequestOld) GetHeader() *RequestHeader

type SetAttributionRequestOld

+ Header *RequestHeader

+ func (m *SetAttributionRequestOld) GetHeader() *RequestHeader

Sep 19, 2019

Changes in this version

+ func DRPCRegisterCertificates(srv drpc.Server, impl DRPCCertificatesServer)

+ func DRPCRegisterContact(srv drpc.Server, impl DRPCContactServer)

+ func DRPCRegisterHealthInspector(srv drpc.Server, impl DRPCHealthInspectorServer)

+ func DRPCRegisterIrreparableInspector(srv drpc.Server, impl DRPCIrreparableInspectorServer)

+ func DRPCRegisterKadInspector(srv drpc.Server, impl DRPCKadInspectorServer)

+ func DRPCRegisterMetainfo(srv drpc.Server, impl DRPCMetainfoServer)

+ func DRPCRegisterNode(srv drpc.Server, impl DRPCNodeServer)

+ func DRPCRegisterNodeStats(srv drpc.Server, impl DRPCNodeStatsServer)

+ func DRPCRegisterNodes(srv drpc.Server, impl DRPCNodesServer)

+ func DRPCRegisterOrders(srv drpc.Server, impl DRPCOrdersServer)

+ func DRPCRegisterOverlayInspector(srv drpc.Server, impl DRPCOverlayInspectorServer)

+ func DRPCRegisterPieceStoreInspector(srv drpc.Server, impl DRPCPieceStoreInspectorServer)

+ func DRPCRegisterPiecestore(srv drpc.Server, impl DRPCPiecestoreServer)

+ func DRPCRegisterVouchers(srv drpc.Server, impl DRPCVouchersServer)

+ func RegisterContactServer(s *grpc.Server, srv ContactServer)

+ func RegisterNodeServer(s *grpc.Server, srv NodeServer)

+ type CheckInRequest struct

+ Address string

+ Capacity *NodeCapacity

+ Operator *NodeOperator

+ Version string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CheckInRequest) Descriptor() ([]byte, []int)

+ func (*CheckInRequest) ProtoMessage()

+ func (m *CheckInRequest) GetAddress() string

+ func (m *CheckInRequest) GetCapacity() *NodeCapacity

+ func (m *CheckInRequest) GetOperator() *NodeOperator

+ func (m *CheckInRequest) GetVersion() string

+ func (m *CheckInRequest) Reset()

+ func (m *CheckInRequest) String() string

+ func (m *CheckInRequest) XXX_DiscardUnknown()

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

+ func (m *CheckInRequest) XXX_Merge(src proto.Message)

+ func (m *CheckInRequest) XXX_Size() int

+ func (m *CheckInRequest) XXX_Unmarshal(b []byte) error

+ type CheckInResponse struct

+ PingErrorMessage string

+ PingNodeSuccess bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CheckInResponse) Descriptor() ([]byte, []int)

+ func (*CheckInResponse) ProtoMessage()

+ func (m *CheckInResponse) GetPingErrorMessage() string

+ func (m *CheckInResponse) GetPingNodeSuccess() bool

+ func (m *CheckInResponse) Reset()

+ func (m *CheckInResponse) String() string

+ func (m *CheckInResponse) XXX_DiscardUnknown()

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

+ func (m *CheckInResponse) XXX_Merge(src proto.Message)

+ func (m *CheckInResponse) XXX_Size() int

+ func (m *CheckInResponse) XXX_Unmarshal(b []byte) error

+ type ContactClient interface

+ PingNode func(ctx context.Context, in *ContactPingRequest, opts ...grpc.CallOption) (*ContactPingResponse, error)

+ func NewContactClient(cc *grpc.ClientConn) ContactClient

+ type ContactPingRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ContactPingRequest) Descriptor() ([]byte, []int)

+ func (*ContactPingRequest) ProtoMessage()

+ func (m *ContactPingRequest) Reset()

+ func (m *ContactPingRequest) String() string

+ func (m *ContactPingRequest) XXX_DiscardUnknown()

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

+ func (m *ContactPingRequest) XXX_Merge(src proto.Message)

+ func (m *ContactPingRequest) XXX_Size() int

+ func (m *ContactPingRequest) XXX_Unmarshal(b []byte) error

+ type ContactPingResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ContactPingResponse) Descriptor() ([]byte, []int)

+ func (*ContactPingResponse) ProtoMessage()

+ func (m *ContactPingResponse) Reset()

+ func (m *ContactPingResponse) String() string

+ func (m *ContactPingResponse) XXX_DiscardUnknown()

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

+ func (m *ContactPingResponse) XXX_Merge(src proto.Message)

+ func (m *ContactPingResponse) XXX_Size() int

+ func (m *ContactPingResponse) XXX_Unmarshal(b []byte) error

+ type ContactServer interface

+ PingNode func(context.Context, *ContactPingRequest) (*ContactPingResponse, error)

+ type DRPCCertificatesClient interface

+ DRPCConn func() drpc.Conn

+ Sign func(ctx context.Context, in *SigningRequest) (*SigningResponse, error)

+ func NewDRPCCertificatesClient(cc drpc.Conn) DRPCCertificatesClient

+ type DRPCCertificatesDescription struct

+ func (DRPCCertificatesDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCCertificatesDescription) NumMethods() int

+ type DRPCCertificatesServer interface

+ Sign func(context.Context, *SigningRequest) (*SigningResponse, error)

+ type DRPCCertificates_SignStream interface

+ SendAndClose func(*SigningResponse) error

+ type DRPCContactClient interface

+ DRPCConn func() drpc.Conn

+ PingNode func(ctx context.Context, in *ContactPingRequest) (*ContactPingResponse, error)

+ func NewDRPCContactClient(cc drpc.Conn) DRPCContactClient

+ type DRPCContactDescription struct

+ func (DRPCContactDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCContactDescription) NumMethods() int

+ type DRPCContactServer interface

+ PingNode func(context.Context, *ContactPingRequest) (*ContactPingResponse, error)

+ type DRPCContact_PingNodeStream interface

+ SendAndClose func(*ContactPingResponse) error

+ type DRPCHealthInspectorClient interface

+ DRPCConn func() drpc.Conn

+ ObjectHealth func(ctx context.Context, in *ObjectHealthRequest) (*ObjectHealthResponse, error)

+ SegmentHealth func(ctx context.Context, in *SegmentHealthRequest) (*SegmentHealthResponse, error)

+ func NewDRPCHealthInspectorClient(cc drpc.Conn) DRPCHealthInspectorClient

+ type DRPCHealthInspectorDescription struct

+ func (DRPCHealthInspectorDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCHealthInspectorDescription) NumMethods() int

+ type DRPCHealthInspectorServer interface

+ ObjectHealth func(context.Context, *ObjectHealthRequest) (*ObjectHealthResponse, error)

+ SegmentHealth func(context.Context, *SegmentHealthRequest) (*SegmentHealthResponse, error)

+ type DRPCHealthInspector_ObjectHealthStream interface

+ SendAndClose func(*ObjectHealthResponse) error

+ type DRPCHealthInspector_SegmentHealthStream interface

+ SendAndClose func(*SegmentHealthResponse) error

+ type DRPCIrreparableInspectorClient interface

+ DRPCConn func() drpc.Conn

+ ListIrreparableSegments func(ctx context.Context, in *ListIrreparableSegmentsRequest) (*ListIrreparableSegmentsResponse, error)

+ func NewDRPCIrreparableInspectorClient(cc drpc.Conn) DRPCIrreparableInspectorClient

+ type DRPCIrreparableInspectorDescription struct

+ func (DRPCIrreparableInspectorDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCIrreparableInspectorDescription) NumMethods() int

+ type DRPCIrreparableInspectorServer interface

+ ListIrreparableSegments func(context.Context, *ListIrreparableSegmentsRequest) (*ListIrreparableSegmentsResponse, error)

+ type DRPCIrreparableInspector_ListIrreparableSegmentsStream interface

+ SendAndClose func(*ListIrreparableSegmentsResponse) error

+ type DRPCKadInspectorClient interface

+ CountNodes func(ctx context.Context, in *CountNodesRequest) (*CountNodesResponse, error)

+ DRPCConn func() drpc.Conn

+ DumpNodes func(ctx context.Context, in *DumpNodesRequest) (*DumpNodesResponse, error)

+ FindNear func(ctx context.Context, in *FindNearRequest) (*FindNearResponse, error)

+ GetBucketList func(ctx context.Context, in *GetBucketListRequest) (*GetBucketListResponse, error)

+ LookupNode func(ctx context.Context, in *LookupNodeRequest) (*LookupNodeResponse, error)

+ NodeInfo func(ctx context.Context, in *NodeInfoRequest) (*NodeInfoResponse, error)

+ PingNode func(ctx context.Context, in *PingNodeRequest) (*PingNodeResponse, error)

+ func NewDRPCKadInspectorClient(cc drpc.Conn) DRPCKadInspectorClient

+ type DRPCKadInspectorDescription struct

+ func (DRPCKadInspectorDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCKadInspectorDescription) NumMethods() int

+ type DRPCKadInspectorServer interface

+ CountNodes func(context.Context, *CountNodesRequest) (*CountNodesResponse, error)

+ DumpNodes func(context.Context, *DumpNodesRequest) (*DumpNodesResponse, error)

+ FindNear func(context.Context, *FindNearRequest) (*FindNearResponse, error)

+ GetBucketList func(context.Context, *GetBucketListRequest) (*GetBucketListResponse, error)

+ LookupNode func(context.Context, *LookupNodeRequest) (*LookupNodeResponse, error)

+ NodeInfo func(context.Context, *NodeInfoRequest) (*NodeInfoResponse, error)

+ PingNode func(context.Context, *PingNodeRequest) (*PingNodeResponse, error)

+ type DRPCKadInspector_CountNodesStream interface

+ SendAndClose func(*CountNodesResponse) error

+ type DRPCKadInspector_DumpNodesStream interface

+ SendAndClose func(*DumpNodesResponse) error

+ type DRPCKadInspector_FindNearStream interface

+ SendAndClose func(*FindNearResponse) error

+ type DRPCKadInspector_GetBucketListStream interface

+ SendAndClose func(*GetBucketListResponse) error

+ type DRPCKadInspector_LookupNodeStream interface

+ SendAndClose func(*LookupNodeResponse) error

+ type DRPCKadInspector_NodeInfoStream interface

+ SendAndClose func(*NodeInfoResponse) error

+ type DRPCKadInspector_PingNodeStream interface

+ SendAndClose func(*PingNodeResponse) error

+ type DRPCMetainfoClient interface

+ Batch func(ctx context.Context, in *BatchRequest) (*BatchResponse, error)

+ BeginDeleteObject func(ctx context.Context, in *ObjectBeginDeleteRequest) (*ObjectBeginDeleteResponse, error)

+ BeginDeleteSegment func(ctx context.Context, in *SegmentBeginDeleteRequest) (*SegmentBeginDeleteResponse, error)

+ BeginObject func(ctx context.Context, in *ObjectBeginRequest) (*ObjectBeginResponse, error)

+ BeginSegment func(ctx context.Context, in *SegmentBeginRequest) (*SegmentBeginResponse, error)

+ CommitObject func(ctx context.Context, in *ObjectCommitRequest) (*ObjectCommitResponse, error)

+ CommitSegment func(ctx context.Context, in *SegmentCommitRequest) (*SegmentCommitResponse, error)

+ CommitSegmentOld func(ctx context.Context, in *SegmentCommitRequestOld) (*SegmentCommitResponseOld, error)

+ CreateBucket func(ctx context.Context, in *BucketCreateRequest) (*BucketCreateResponse, error)

+ CreateSegmentOld func(ctx context.Context, in *SegmentWriteRequestOld) (*SegmentWriteResponseOld, error)

+ DRPCConn func() drpc.Conn

+ DeleteBucket func(ctx context.Context, in *BucketDeleteRequest) (*BucketDeleteResponse, error)

+ DeleteSegmentOld func(ctx context.Context, in *SegmentDeleteRequestOld) (*SegmentDeleteResponseOld, error)

+ DownloadSegment func(ctx context.Context, in *SegmentDownloadRequest) (*SegmentDownloadResponse, error)

+ DownloadSegmentOld func(ctx context.Context, in *SegmentDownloadRequestOld) (*SegmentDownloadResponseOld, error)

+ FinishDeleteObject func(ctx context.Context, in *ObjectFinishDeleteRequest) (*ObjectFinishDeleteResponse, error)

+ FinishDeleteSegment func(ctx context.Context, in *SegmentFinishDeleteRequest) (*SegmentFinishDeleteResponse, error)

+ GetBucket func(ctx context.Context, in *BucketGetRequest) (*BucketGetResponse, error)

+ GetObject func(ctx context.Context, in *ObjectGetRequest) (*ObjectGetResponse, error)

+ ListBuckets func(ctx context.Context, in *BucketListRequest) (*BucketListResponse, error)

+ ListObjects func(ctx context.Context, in *ObjectListRequest) (*ObjectListResponse, error)

+ ListSegments func(ctx context.Context, in *SegmentListRequest) (*SegmentListResponse, error)

+ ListSegmentsOld func(ctx context.Context, in *ListSegmentsRequestOld) (*ListSegmentsResponseOld, error)

+ MakeInlineSegment func(ctx context.Context, in *SegmentMakeInlineRequest) (*SegmentMakeInlineResponse, error)

+ ProjectInfo func(ctx context.Context, in *ProjectInfoRequest) (*ProjectInfoResponse, error)

+ SegmentInfoOld func(ctx context.Context, in *SegmentInfoRequestOld) (*SegmentInfoResponseOld, error)

+ SetAttributionOld func(ctx context.Context, in *SetAttributionRequestOld) (*SetAttributionResponseOld, error)

+ SetBucketAttribution func(ctx context.Context, in *BucketSetAttributionRequest) (*BucketSetAttributionResponse, error)

+ func NewDRPCMetainfoClient(cc drpc.Conn) DRPCMetainfoClient

+ type DRPCMetainfoDescription struct

+ func (DRPCMetainfoDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCMetainfoDescription) NumMethods() int

+ type DRPCMetainfoServer interface

+ Batch func(context.Context, *BatchRequest) (*BatchResponse, error)

+ BeginDeleteObject func(context.Context, *ObjectBeginDeleteRequest) (*ObjectBeginDeleteResponse, error)

+ BeginDeleteSegment func(context.Context, *SegmentBeginDeleteRequest) (*SegmentBeginDeleteResponse, error)

+ BeginObject func(context.Context, *ObjectBeginRequest) (*ObjectBeginResponse, error)

+ BeginSegment func(context.Context, *SegmentBeginRequest) (*SegmentBeginResponse, error)

+ CommitObject func(context.Context, *ObjectCommitRequest) (*ObjectCommitResponse, error)

+ CommitSegment func(context.Context, *SegmentCommitRequest) (*SegmentCommitResponse, error)

+ CommitSegmentOld func(context.Context, *SegmentCommitRequestOld) (*SegmentCommitResponseOld, error)

+ CreateBucket func(context.Context, *BucketCreateRequest) (*BucketCreateResponse, error)

+ CreateSegmentOld func(context.Context, *SegmentWriteRequestOld) (*SegmentWriteResponseOld, error)

+ DeleteBucket func(context.Context, *BucketDeleteRequest) (*BucketDeleteResponse, error)

+ DeleteSegmentOld func(context.Context, *SegmentDeleteRequestOld) (*SegmentDeleteResponseOld, error)

+ DownloadSegment func(context.Context, *SegmentDownloadRequest) (*SegmentDownloadResponse, error)

+ DownloadSegmentOld func(context.Context, *SegmentDownloadRequestOld) (*SegmentDownloadResponseOld, error)

+ FinishDeleteObject func(context.Context, *ObjectFinishDeleteRequest) (*ObjectFinishDeleteResponse, error)

+ FinishDeleteSegment func(context.Context, *SegmentFinishDeleteRequest) (*SegmentFinishDeleteResponse, error)

+ GetBucket func(context.Context, *BucketGetRequest) (*BucketGetResponse, error)

+ GetObject func(context.Context, *ObjectGetRequest) (*ObjectGetResponse, error)

+ ListBuckets func(context.Context, *BucketListRequest) (*BucketListResponse, error)

+ ListObjects func(context.Context, *ObjectListRequest) (*ObjectListResponse, error)

+ ListSegments func(context.Context, *SegmentListRequest) (*SegmentListResponse, error)

+ ListSegmentsOld func(context.Context, *ListSegmentsRequestOld) (*ListSegmentsResponseOld, error)

+ MakeInlineSegment func(context.Context, *SegmentMakeInlineRequest) (*SegmentMakeInlineResponse, error)

+ ProjectInfo func(context.Context, *ProjectInfoRequest) (*ProjectInfoResponse, error)

+ SegmentInfoOld func(context.Context, *SegmentInfoRequestOld) (*SegmentInfoResponseOld, error)

+ SetAttributionOld func(context.Context, *SetAttributionRequestOld) (*SetAttributionResponseOld, error)

+ SetBucketAttribution func(context.Context, *BucketSetAttributionRequest) (*BucketSetAttributionResponse, error)

+ type DRPCMetainfo_BatchStream interface

+ SendAndClose func(*BatchResponse) error

+ type DRPCMetainfo_BeginDeleteObjectStream interface

+ SendAndClose func(*ObjectBeginDeleteResponse) error

+ type DRPCMetainfo_BeginDeleteSegmentStream interface

+ SendAndClose func(*SegmentBeginDeleteResponse) error

+ type DRPCMetainfo_BeginObjectStream interface

+ SendAndClose func(*ObjectBeginResponse) error

+ type DRPCMetainfo_BeginSegmentStream interface

+ SendAndClose func(*SegmentBeginResponse) error

+ type DRPCMetainfo_CommitObjectStream interface

+ SendAndClose func(*ObjectCommitResponse) error

+ type DRPCMetainfo_CommitSegmentOldStream interface

+ SendAndClose func(*SegmentCommitResponseOld) error

+ type DRPCMetainfo_CommitSegmentStream interface

+ SendAndClose func(*SegmentCommitResponse) error

+ type DRPCMetainfo_CreateBucketStream interface

+ SendAndClose func(*BucketCreateResponse) error

+ type DRPCMetainfo_CreateSegmentOldStream interface

+ SendAndClose func(*SegmentWriteResponseOld) error

+ type DRPCMetainfo_DeleteBucketStream interface

+ SendAndClose func(*BucketDeleteResponse) error

+ type DRPCMetainfo_DeleteSegmentOldStream interface

+ SendAndClose func(*SegmentDeleteResponseOld) error

+ type DRPCMetainfo_DownloadSegmentOldStream interface

+ SendAndClose func(*SegmentDownloadResponseOld) error

+ type DRPCMetainfo_DownloadSegmentStream interface

+ SendAndClose func(*SegmentDownloadResponse) error

+ type DRPCMetainfo_FinishDeleteObjectStream interface

+ SendAndClose func(*ObjectFinishDeleteResponse) error

+ type DRPCMetainfo_FinishDeleteSegmentStream interface

+ SendAndClose func(*SegmentFinishDeleteResponse) error

+ type DRPCMetainfo_GetBucketStream interface

+ SendAndClose func(*BucketGetResponse) error

+ type DRPCMetainfo_GetObjectStream interface

+ SendAndClose func(*ObjectGetResponse) error

+ type DRPCMetainfo_ListBucketsStream interface

+ SendAndClose func(*BucketListResponse) error

+ type DRPCMetainfo_ListObjectsStream interface

+ SendAndClose func(*ObjectListResponse) error

+ type DRPCMetainfo_ListSegmentsOldStream interface

+ SendAndClose func(*ListSegmentsResponseOld) error

+ type DRPCMetainfo_ListSegmentsStream interface

+ SendAndClose func(*SegmentListResponse) error

+ type DRPCMetainfo_MakeInlineSegmentStream interface

+ SendAndClose func(*SegmentMakeInlineResponse) error

+ type DRPCMetainfo_ProjectInfoStream interface

+ SendAndClose func(*ProjectInfoResponse) error

+ type DRPCMetainfo_SegmentInfoOldStream interface

+ SendAndClose func(*SegmentInfoResponseOld) error

+ type DRPCMetainfo_SetAttributionOldStream interface

+ SendAndClose func(*SetAttributionResponseOld) error

+ type DRPCMetainfo_SetBucketAttributionStream interface

+ SendAndClose func(*BucketSetAttributionResponse) error

+ type DRPCNodeClient interface

+ CheckIn func(ctx context.Context, in *CheckInRequest) (*CheckInResponse, error)

+ DRPCConn func() drpc.Conn

+ func NewDRPCNodeClient(cc drpc.Conn) DRPCNodeClient

+ type DRPCNodeDescription struct

+ func (DRPCNodeDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCNodeDescription) NumMethods() int

+ type DRPCNodeServer interface

+ CheckIn func(context.Context, *CheckInRequest) (*CheckInResponse, error)

+ type DRPCNodeStatsClient interface

+ DRPCConn func() drpc.Conn

+ DailyStorageUsage func(ctx context.Context, in *DailyStorageUsageRequest) (*DailyStorageUsageResponse, error)

+ GetStats func(ctx context.Context, in *GetStatsRequest) (*GetStatsResponse, error)

+ func NewDRPCNodeStatsClient(cc drpc.Conn) DRPCNodeStatsClient

+ type DRPCNodeStatsDescription struct

+ func (DRPCNodeStatsDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCNodeStatsDescription) NumMethods() int

+ type DRPCNodeStatsServer interface

+ DailyStorageUsage func(context.Context, *DailyStorageUsageRequest) (*DailyStorageUsageResponse, error)

+ GetStats func(context.Context, *GetStatsRequest) (*GetStatsResponse, error)

+ type DRPCNodeStats_DailyStorageUsageStream interface

+ SendAndClose func(*DailyStorageUsageResponse) error

+ type DRPCNodeStats_GetStatsStream interface

+ SendAndClose func(*GetStatsResponse) error

+ type DRPCNode_CheckInStream interface

+ SendAndClose func(*CheckInResponse) error

+ type DRPCNodesClient interface

+ DRPCConn func() drpc.Conn

+ Ping func(ctx context.Context, in *PingRequest) (*PingResponse, error)

+ Query func(ctx context.Context, in *QueryRequest) (*QueryResponse, error)

+ RequestInfo func(ctx context.Context, in *InfoRequest) (*InfoResponse, error)

+ func NewDRPCNodesClient(cc drpc.Conn) DRPCNodesClient

+ type DRPCNodesDescription struct

+ func (DRPCNodesDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCNodesDescription) NumMethods() int

+ type DRPCNodesServer interface

+ Ping func(context.Context, *PingRequest) (*PingResponse, error)

+ Query func(context.Context, *QueryRequest) (*QueryResponse, error)

+ RequestInfo func(context.Context, *InfoRequest) (*InfoResponse, error)

+ type DRPCNodes_PingStream interface

+ SendAndClose func(*PingResponse) error

+ type DRPCNodes_QueryStream interface

+ SendAndClose func(*QueryResponse) error

+ type DRPCNodes_RequestInfoStream interface

+ SendAndClose func(*InfoResponse) error

+ type DRPCOrdersClient interface

+ DRPCConn func() drpc.Conn

+ Settlement func(ctx context.Context) (DRPCOrders_SettlementClient, error)

+ func NewDRPCOrdersClient(cc drpc.Conn) DRPCOrdersClient

+ type DRPCOrdersDescription struct

+ func (DRPCOrdersDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCOrdersDescription) NumMethods() int

+ type DRPCOrdersServer interface

+ Settlement func(DRPCOrders_SettlementStream) error

+ type DRPCOrders_SettlementClient interface

+ Recv func() (*SettlementResponse, error)

+ Send func(*SettlementRequest) error

+ type DRPCOrders_SettlementStream interface

+ Recv func() (*SettlementRequest, error)

+ Send func(*SettlementResponse) error

+ type DRPCOverlayInspectorClient interface

+ CountNodes func(ctx context.Context, in *CountNodesRequest) (*CountNodesResponse, error)

+ DRPCConn func() drpc.Conn

+ DumpNodes func(ctx context.Context, in *DumpNodesRequest) (*DumpNodesResponse, error)

+ func NewDRPCOverlayInspectorClient(cc drpc.Conn) DRPCOverlayInspectorClient

+ type DRPCOverlayInspectorDescription struct

+ func (DRPCOverlayInspectorDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCOverlayInspectorDescription) NumMethods() int

+ type DRPCOverlayInspectorServer interface

+ CountNodes func(context.Context, *CountNodesRequest) (*CountNodesResponse, error)

+ DumpNodes func(context.Context, *DumpNodesRequest) (*DumpNodesResponse, error)

+ type DRPCOverlayInspector_CountNodesStream interface

+ SendAndClose func(*CountNodesResponse) error

+ type DRPCOverlayInspector_DumpNodesStream interface

+ SendAndClose func(*DumpNodesResponse) error

+ type DRPCPieceStoreInspectorClient interface

+ DRPCConn func() drpc.Conn

+ Dashboard func(ctx context.Context, in *DashboardRequest) (*DashboardResponse, error)

+ Stats func(ctx context.Context, in *StatsRequest) (*StatSummaryResponse, error)

+ func NewDRPCPieceStoreInspectorClient(cc drpc.Conn) DRPCPieceStoreInspectorClient

+ type DRPCPieceStoreInspectorDescription struct

+ func (DRPCPieceStoreInspectorDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCPieceStoreInspectorDescription) NumMethods() int

+ type DRPCPieceStoreInspectorServer interface

+ Dashboard func(context.Context, *DashboardRequest) (*DashboardResponse, error)

+ Stats func(context.Context, *StatsRequest) (*StatSummaryResponse, error)

+ type DRPCPieceStoreInspector_DashboardStream interface

+ SendAndClose func(*DashboardResponse) error

+ type DRPCPieceStoreInspector_StatsStream interface

+ SendAndClose func(*StatSummaryResponse) error

+ type DRPCPiecestoreClient interface

+ DRPCConn func() drpc.Conn

+ Delete func(ctx context.Context, in *PieceDeleteRequest) (*PieceDeleteResponse, error)

+ Download func(ctx context.Context) (DRPCPiecestore_DownloadClient, error)

+ Retain func(ctx context.Context, in *RetainRequest) (*RetainResponse, error)

+ Upload func(ctx context.Context) (DRPCPiecestore_UploadClient, error)

+ func NewDRPCPiecestoreClient(cc drpc.Conn) DRPCPiecestoreClient

+ type DRPCPiecestoreDescription struct

+ func (DRPCPiecestoreDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCPiecestoreDescription) NumMethods() int

+ type DRPCPiecestoreServer interface

+ Delete func(context.Context, *PieceDeleteRequest) (*PieceDeleteResponse, error)

+ Download func(DRPCPiecestore_DownloadStream) error

+ Retain func(context.Context, *RetainRequest) (*RetainResponse, error)

+ Upload func(DRPCPiecestore_UploadStream) error

+ type DRPCPiecestore_DeleteStream interface

+ SendAndClose func(*PieceDeleteResponse) error

+ type DRPCPiecestore_DownloadClient interface

+ Recv func() (*PieceDownloadResponse, error)

+ Send func(*PieceDownloadRequest) error

+ type DRPCPiecestore_DownloadStream interface

+ Recv func() (*PieceDownloadRequest, error)

+ Send func(*PieceDownloadResponse) error

+ type DRPCPiecestore_RetainStream interface

+ SendAndClose func(*RetainResponse) error

+ type DRPCPiecestore_UploadClient interface

+ CloseAndRecv func() (*PieceUploadResponse, error)

+ Send func(*PieceUploadRequest) error

+ type DRPCPiecestore_UploadStream interface

+ Recv func() (*PieceUploadRequest, error)

+ SendAndClose func(*PieceUploadResponse) error

+ type DRPCVouchersClient interface

+ DRPCConn func() drpc.Conn

+ Request func(ctx context.Context, in *VoucherRequest) (*VoucherResponse, error)

+ func NewDRPCVouchersClient(cc drpc.Conn) DRPCVouchersClient

+ type DRPCVouchersDescription struct

+ func (DRPCVouchersDescription) Method(n int) (string, drpc.Handler, interface{}, bool)

+ func (DRPCVouchersDescription) NumMethods() int

+ type DRPCVouchersServer interface

+ Request func(context.Context, *VoucherRequest) (*VoucherResponse, error)

+ type DRPCVouchers_RequestStream interface

+ SendAndClose func(*VoucherResponse) error

type DashboardResponse

+ LastPingFromAddress string

+ LastPingFromId *NodeID

+ func (m *DashboardResponse) GetLastPingFromAddress() string

+ type NodeClient interface

+ CheckIn func(ctx context.Context, in *CheckInRequest, opts ...grpc.CallOption) (*CheckInResponse, error)

+ func NewNodeClient(cc *grpc.ClientConn) NodeClient

+ type NodeServer interface

+ CheckIn func(context.Context, *CheckInRequest) (*CheckInResponse, error)

Aug 26, 2019

Changes in this version

type GetStatsResponse

+ Disqualified *time.Time

+ func (m *GetStatsResponse) GetDisqualified() *time.Time

type PieceDownloadResponse

+ Hash *PieceHash

+ Limit *OrderLimit

+ func (m *PieceDownloadResponse) GetHash() *PieceHash

+ func (m *PieceDownloadResponse) GetLimit() *OrderLimit

type StreamInfo

+ DeprecatedNumberOfSegments int64

+ func (m *StreamInfo) GetDeprecatedNumberOfSegments() int64

type StreamMeta

+ NumberOfSegments int64

+ func (m *StreamMeta) GetNumberOfSegments() int64

+ type UnimplementedPiecestoreServer struct

+ func (*UnimplementedPiecestoreServer) Delete(ctx context.Context, req *PieceDeleteRequest) (*PieceDeleteResponse, error)

+ func (*UnimplementedPiecestoreServer) Download(srv Piecestore_DownloadServer) error

+ func (*UnimplementedPiecestoreServer) Retain(ctx context.Context, req *RetainRequest) (*RetainResponse, error)

+ func (*UnimplementedPiecestoreServer) Upload(srv Piecestore_UploadServer) error

Aug 20, 2019

Changes in this version

+ var PieceHeader_FormatVersion_name = map[int32]string

+ var PieceHeader_FormatVersion_value = map[string]int32

type DailyStorageUsageResponse_StorageUsage

+ Timestamp time.Time

+ func (m *DailyStorageUsageResponse_StorageUsage) GetTimestamp() time.Time

+ type PieceHeader struct

+ CreationTime time.Time

+ FormatVersion PieceHeader_FormatVersion

+ Hash []byte

+ OrderLimit OrderLimit

+ Signature []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceHeader) Descriptor() ([]byte, []int)

+ func (*PieceHeader) ProtoMessage()

+ func (m *PieceHeader) GetCreationTime() time.Time

+ func (m *PieceHeader) GetFormatVersion() PieceHeader_FormatVersion

+ func (m *PieceHeader) GetHash() []byte

+ func (m *PieceHeader) GetOrderLimit() OrderLimit

+ func (m *PieceHeader) GetSignature() []byte

+ func (m *PieceHeader) Reset()

+ func (m *PieceHeader) String() string

+ func (m *PieceHeader) XXX_DiscardUnknown()

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

+ func (m *PieceHeader) XXX_Merge(src proto.Message)

+ func (m *PieceHeader) XXX_Size() int

+ func (m *PieceHeader) XXX_Unmarshal(b []byte) error

+ type PieceHeader_FormatVersion int32

+ const PieceHeader_FORMAT_V0

+ const PieceHeader_FORMAT_V1

+ func (PieceHeader_FormatVersion) EnumDescriptor() ([]byte, []int)

+ func (x PieceHeader_FormatVersion) String() string

Aug 13, 2019

Changes in this version

+ type BatchRequest struct

+ Requests []*BatchRequestItem

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BatchRequest) Descriptor() ([]byte, []int)

+ func (*BatchRequest) ProtoMessage()

+ func (m *BatchRequest) GetRequests() []*BatchRequestItem

+ func (m *BatchRequest) Reset()

+ func (m *BatchRequest) String() string

+ func (m *BatchRequest) XXX_DiscardUnknown()

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

+ func (m *BatchRequest) XXX_Merge(src proto.Message)

+ func (m *BatchRequest) XXX_Size() int

+ func (m *BatchRequest) XXX_Unmarshal(b []byte) error

+ type BatchRequestItem struct

+ Request isBatchRequestItem_Request

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BatchRequestItem) Descriptor() ([]byte, []int)

+ func (*BatchRequestItem) ProtoMessage()

+ func (*BatchRequestItem) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *BatchRequestItem) GetBucketCreate() *BucketCreateRequest

+ func (m *BatchRequestItem) GetBucketDelete() *BucketDeleteRequest

+ func (m *BatchRequestItem) GetBucketGet() *BucketGetRequest

+ func (m *BatchRequestItem) GetBucketList() *BucketListRequest

+ func (m *BatchRequestItem) GetBucketSetAttribution() *BucketSetAttributionRequest

+ func (m *BatchRequestItem) GetObjectBegin() *ObjectBeginRequest

+ func (m *BatchRequestItem) GetObjectBeginDelete() *ObjectBeginDeleteRequest

+ func (m *BatchRequestItem) GetObjectCommit() *ObjectCommitRequest

+ func (m *BatchRequestItem) GetObjectFinishDelete() *ObjectFinishDeleteRequest

+ func (m *BatchRequestItem) GetObjectGet() *ObjectGetRequest

+ func (m *BatchRequestItem) GetObjectList() *ObjectListRequest

+ func (m *BatchRequestItem) GetRequest() isBatchRequestItem_Request

+ func (m *BatchRequestItem) GetSegmentBegin() *SegmentBeginRequest

+ func (m *BatchRequestItem) GetSegmentBeginDelete() *SegmentBeginDeleteRequest

+ func (m *BatchRequestItem) GetSegmentCommit() *SegmentCommitRequest

+ func (m *BatchRequestItem) GetSegmentDownload() *SegmentDownloadRequest

+ func (m *BatchRequestItem) GetSegmentFinishDelete() *SegmentFinishDeleteRequest

+ func (m *BatchRequestItem) GetSegmentList() *SegmentListRequest

+ func (m *BatchRequestItem) GetSegmentMakeInline() *SegmentMakeInlineRequest

+ func (m *BatchRequestItem) Reset()

+ func (m *BatchRequestItem) String() string

+ func (m *BatchRequestItem) XXX_DiscardUnknown()

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

+ func (m *BatchRequestItem) XXX_Merge(src proto.Message)

+ func (m *BatchRequestItem) XXX_Size() int

+ func (m *BatchRequestItem) XXX_Unmarshal(b []byte) error

+ type BatchRequestItem_BucketCreate struct

+ BucketCreate *BucketCreateRequest

+ type BatchRequestItem_BucketDelete struct

+ BucketDelete *BucketDeleteRequest

+ type BatchRequestItem_BucketGet struct

+ BucketGet *BucketGetRequest

+ type BatchRequestItem_BucketList struct

+ BucketList *BucketListRequest

+ type BatchRequestItem_BucketSetAttribution struct

+ BucketSetAttribution *BucketSetAttributionRequest

+ type BatchRequestItem_ObjectBegin struct

+ ObjectBegin *ObjectBeginRequest

+ type BatchRequestItem_ObjectBeginDelete struct

+ ObjectBeginDelete *ObjectBeginDeleteRequest

+ type BatchRequestItem_ObjectCommit struct

+ ObjectCommit *ObjectCommitRequest

+ type BatchRequestItem_ObjectFinishDelete struct

+ ObjectFinishDelete *ObjectFinishDeleteRequest

+ type BatchRequestItem_ObjectGet struct

+ ObjectGet *ObjectGetRequest

+ type BatchRequestItem_ObjectList struct

+ ObjectList *ObjectListRequest

+ type BatchRequestItem_SegmentBegin struct

+ SegmentBegin *SegmentBeginRequest

+ type BatchRequestItem_SegmentBeginDelete struct

+ SegmentBeginDelete *SegmentBeginDeleteRequest

+ type BatchRequestItem_SegmentCommit struct

+ SegmentCommit *SegmentCommitRequest

+ type BatchRequestItem_SegmentDownload struct

+ SegmentDownload *SegmentDownloadRequest

+ type BatchRequestItem_SegmentFinishDelete struct

+ SegmentFinishDelete *SegmentFinishDeleteRequest

+ type BatchRequestItem_SegmentList struct

+ SegmentList *SegmentListRequest

+ type BatchRequestItem_SegmentMakeInline struct

+ SegmentMakeInline *SegmentMakeInlineRequest

+ type BatchResponse struct

+ Responses []*BatchResponseItem

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BatchResponse) Descriptor() ([]byte, []int)

+ func (*BatchResponse) ProtoMessage()

+ func (m *BatchResponse) GetResponses() []*BatchResponseItem

+ func (m *BatchResponse) Reset()

+ func (m *BatchResponse) String() string

+ func (m *BatchResponse) XXX_DiscardUnknown()

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

+ func (m *BatchResponse) XXX_Merge(src proto.Message)

+ func (m *BatchResponse) XXX_Size() int

+ func (m *BatchResponse) XXX_Unmarshal(b []byte) error

+ type BatchResponseItem struct

+ Response isBatchResponseItem_Response

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BatchResponseItem) Descriptor() ([]byte, []int)

+ func (*BatchResponseItem) ProtoMessage()

+ func (*BatchResponseItem) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *BatchResponseItem) GetBucketCreate() *BucketCreateResponse

+ func (m *BatchResponseItem) GetBucketDelete() *BucketDeleteResponse

+ func (m *BatchResponseItem) GetBucketGet() *BucketGetResponse

+ func (m *BatchResponseItem) GetBucketList() *BucketListResponse

+ func (m *BatchResponseItem) GetBucketSetAttribution() *BucketSetAttributionResponse

+ func (m *BatchResponseItem) GetObjectBegin() *ObjectBeginResponse

+ func (m *BatchResponseItem) GetObjectBeginDelete() *ObjectBeginDeleteResponse

+ func (m *BatchResponseItem) GetObjectCommit() *ObjectCommitResponse

+ func (m *BatchResponseItem) GetObjectFinishDelete() *ObjectFinishDeleteResponse

+ func (m *BatchResponseItem) GetObjectGet() *ObjectGetResponse

+ func (m *BatchResponseItem) GetObjectList() *ObjectListResponse

+ func (m *BatchResponseItem) GetResponse() isBatchResponseItem_Response

+ func (m *BatchResponseItem) GetSegmentBegin() *SegmentBeginResponse

+ func (m *BatchResponseItem) GetSegmentBeginDelete() *SegmentBeginDeleteResponse

+ func (m *BatchResponseItem) GetSegmentCommit() *SegmentCommitResponse

+ func (m *BatchResponseItem) GetSegmentDownload() *SegmentDownloadResponse

+ func (m *BatchResponseItem) GetSegmentFinishDelete() *SegmentFinishDeleteResponse

+ func (m *BatchResponseItem) GetSegmentList() *SegmentListResponse

+ func (m *BatchResponseItem) GetSegmentMakeInline() *SegmentMakeInlineResponse

+ func (m *BatchResponseItem) Reset()

+ func (m *BatchResponseItem) String() string

+ func (m *BatchResponseItem) XXX_DiscardUnknown()

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

+ func (m *BatchResponseItem) XXX_Merge(src proto.Message)

+ func (m *BatchResponseItem) XXX_Size() int

+ func (m *BatchResponseItem) XXX_Unmarshal(b []byte) error

+ type BatchResponseItem_BucketCreate struct

+ BucketCreate *BucketCreateResponse

+ type BatchResponseItem_BucketDelete struct

+ BucketDelete *BucketDeleteResponse

+ type BatchResponseItem_BucketGet struct

+ BucketGet *BucketGetResponse

+ type BatchResponseItem_BucketList struct

+ BucketList *BucketListResponse

+ type BatchResponseItem_BucketSetAttribution struct

+ BucketSetAttribution *BucketSetAttributionResponse

+ type BatchResponseItem_ObjectBegin struct

+ ObjectBegin *ObjectBeginResponse

+ type BatchResponseItem_ObjectBeginDelete struct

+ ObjectBeginDelete *ObjectBeginDeleteResponse

+ type BatchResponseItem_ObjectCommit struct

+ ObjectCommit *ObjectCommitResponse

+ type BatchResponseItem_ObjectFinishDelete struct

+ ObjectFinishDelete *ObjectFinishDeleteResponse

+ type BatchResponseItem_ObjectGet struct

+ ObjectGet *ObjectGetResponse

+ type BatchResponseItem_ObjectList struct

+ ObjectList *ObjectListResponse

+ type BatchResponseItem_SegmentBegin struct

+ SegmentBegin *SegmentBeginResponse

+ type BatchResponseItem_SegmentBeginDelete struct

+ SegmentBeginDelete *SegmentBeginDeleteResponse

+ type BatchResponseItem_SegmentCommit struct

+ SegmentCommit *SegmentCommitResponse

+ type BatchResponseItem_SegmentDownload struct

+ SegmentDownload *SegmentDownloadResponse

+ type BatchResponseItem_SegmentFinishDelete struct

+ SegmentFinishDelete *SegmentFinishDeleteResponse

+ type BatchResponseItem_SegmentList struct

+ SegmentList *SegmentListResponse

+ type BatchResponseItem_SegmentMakeInline struct

+ SegmentMakeInline *SegmentMakeInlineResponse

type BucketSetAttributionRequest

+ PartnerId []byte

+ func (m *BucketSetAttributionRequest) GetPartnerId() []byte

type MetainfoClient

+ Batch func(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)

type MetainfoServer

+ Batch func(context.Context, *BatchRequest) (*BatchResponse, error)

type ObjectCommitRequest

+ EncryptedMetadata []byte

+ EncryptedMetadataNonce Nonce

+ func (m *ObjectCommitRequest) GetEncryptedMetadata() []byte

type ObjectListRequest

+ Recursive bool

+ func (m *ObjectListRequest) GetRecursive() bool

type SegmentBeginDeleteResponse

+ PrivateKey PiecePrivateKey

type SegmentDownloadResponse

+ EncryptedKey []byte

+ EncryptedKeyNonce Nonce

+ PrivateKey PiecePrivateKey

+ SegmentSize int64

+ func (m *SegmentDownloadResponse) GetEncryptedKey() []byte

+ func (m *SegmentDownloadResponse) GetSegmentSize() int64

Aug 2, 2019

Changes in this version

+ var Object_Status_name = map[int32]string

+ var Object_Status_value = map[string]int32

type Bucket

+ PartnerId []byte

+ func (m *Bucket) GetPartnerId() []byte

type BucketCreateRequest

+ PartnerId []byte

+ func (m *BucketCreateRequest) GetPartnerId() []byte

type ListIrreparableSegmentsRequest

+ LastSeenSegmentPath []byte

+ func (m *ListIrreparableSegmentsRequest) GetLastSeenSegmentPath() []byte

type MetainfoClient

+ BeginDeleteObject func(ctx context.Context, in *ObjectBeginDeleteRequest, opts ...grpc.CallOption) (*ObjectBeginDeleteResponse, error)

+ BeginDeleteSegment func(ctx context.Context, in *SegmentBeginDeleteRequest, opts ...grpc.CallOption) (*SegmentBeginDeleteResponse, error)

+ BeginObject func(ctx context.Context, in *ObjectBeginRequest, opts ...grpc.CallOption) (*ObjectBeginResponse, error)

+ BeginSegment func(ctx context.Context, in *SegmentBeginRequest, opts ...grpc.CallOption) (*SegmentBeginResponse, error)

+ CommitObject func(ctx context.Context, in *ObjectCommitRequest, opts ...grpc.CallOption) (*ObjectCommitResponse, error)

+ FinishDeleteObject func(ctx context.Context, in *ObjectFinishDeleteRequest, opts ...grpc.CallOption) (*ObjectFinishDeleteResponse, error)

+ FinishDeleteSegment func(ctx context.Context, in *SegmentFinishDeleteRequest, opts ...grpc.CallOption) (*SegmentFinishDeleteResponse, error)

+ GetObject func(ctx context.Context, in *ObjectGetRequest, opts ...grpc.CallOption) (*ObjectGetResponse, error)

+ ListObjects func(ctx context.Context, in *ObjectListRequest, opts ...grpc.CallOption) (*ObjectListResponse, error)

+ MakeInlineSegment func(ctx context.Context, in *SegmentMakeInlineRequest, opts ...grpc.CallOption) (*SegmentMakeInlineResponse, error)

type MetainfoServer

+ BeginDeleteObject func(context.Context, *ObjectBeginDeleteRequest) (*ObjectBeginDeleteResponse, error)

+ BeginDeleteSegment func(context.Context, *SegmentBeginDeleteRequest) (*SegmentBeginDeleteResponse, error)

+ BeginObject func(context.Context, *ObjectBeginRequest) (*ObjectBeginResponse, error)

+ BeginSegment func(context.Context, *SegmentBeginRequest) (*SegmentBeginResponse, error)

+ CommitObject func(context.Context, *ObjectCommitRequest) (*ObjectCommitResponse, error)

+ FinishDeleteObject func(context.Context, *ObjectFinishDeleteRequest) (*ObjectFinishDeleteResponse, error)

+ FinishDeleteSegment func(context.Context, *SegmentFinishDeleteRequest) (*SegmentFinishDeleteResponse, error)

+ GetObject func(context.Context, *ObjectGetRequest) (*ObjectGetResponse, error)

+ ListObjects func(context.Context, *ObjectListRequest) (*ObjectListResponse, error)

+ MakeInlineSegment func(context.Context, *SegmentMakeInlineRequest) (*SegmentMakeInlineResponse, error)

+ type Nonce = storj.Nonce

+ type Object struct

+ Bucket []byte

+ CreatedAt time.Time

+ EncryptedMetadata []byte

+ EncryptedMetadataNonce Nonce

+ EncryptedPath []byte

+ EncryptionParameters *EncryptionParameters

+ ExpiresAt time.Time

+ FixedSegmentSize int64

+ InlineSize int64

+ RedundancyScheme *RedundancyScheme

+ RemoteSize int64

+ Status Object_Status

+ StatusAt time.Time

+ StreamId StreamID

+ TotalSize int64

+ Version int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Object) Descriptor() ([]byte, []int)

+ func (*Object) ProtoMessage()

+ func (m *Object) GetBucket() []byte

+ func (m *Object) GetCreatedAt() time.Time

+ func (m *Object) GetEncryptedMetadata() []byte

+ func (m *Object) GetEncryptedPath() []byte

+ func (m *Object) GetEncryptionParameters() *EncryptionParameters

+ func (m *Object) GetExpiresAt() time.Time

+ func (m *Object) GetFixedSegmentSize() int64

+ func (m *Object) GetInlineSize() int64

+ func (m *Object) GetRedundancyScheme() *RedundancyScheme

+ func (m *Object) GetRemoteSize() int64

+ func (m *Object) GetStatus() Object_Status

+ func (m *Object) GetStatusAt() time.Time

+ func (m *Object) GetTotalSize() int64

+ func (m *Object) GetVersion() int32

+ func (m *Object) Reset()

+ func (m *Object) String() string

+ func (m *Object) XXX_DiscardUnknown()

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

+ func (m *Object) XXX_Merge(src proto.Message)

+ func (m *Object) XXX_Size() int

+ func (m *Object) XXX_Unmarshal(b []byte) error

+ type ObjectBeginDeleteRequest struct

+ Bucket []byte

+ EncryptedPath []byte

+ Version int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectBeginDeleteRequest) Descriptor() ([]byte, []int)

+ func (*ObjectBeginDeleteRequest) ProtoMessage()

+ func (m *ObjectBeginDeleteRequest) GetBucket() []byte

+ func (m *ObjectBeginDeleteRequest) GetEncryptedPath() []byte

+ func (m *ObjectBeginDeleteRequest) GetVersion() int32

+ func (m *ObjectBeginDeleteRequest) Reset()

+ func (m *ObjectBeginDeleteRequest) String() string

+ func (m *ObjectBeginDeleteRequest) XXX_DiscardUnknown()

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

+ func (m *ObjectBeginDeleteRequest) XXX_Merge(src proto.Message)

+ func (m *ObjectBeginDeleteRequest) XXX_Size() int

+ func (m *ObjectBeginDeleteRequest) XXX_Unmarshal(b []byte) error

+ type ObjectBeginDeleteResponse struct

+ StreamId StreamID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectBeginDeleteResponse) Descriptor() ([]byte, []int)

+ func (*ObjectBeginDeleteResponse) ProtoMessage()

+ func (m *ObjectBeginDeleteResponse) Reset()

+ func (m *ObjectBeginDeleteResponse) String() string

+ func (m *ObjectBeginDeleteResponse) XXX_DiscardUnknown()

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

+ func (m *ObjectBeginDeleteResponse) XXX_Merge(src proto.Message)

+ func (m *ObjectBeginDeleteResponse) XXX_Size() int

+ func (m *ObjectBeginDeleteResponse) XXX_Unmarshal(b []byte) error

+ type ObjectBeginRequest struct

+ Bucket []byte

+ EncryptedMetadata []byte

+ EncryptedMetadataNonce Nonce

+ EncryptedPath []byte

+ EncryptionParameters *EncryptionParameters

+ ExpiresAt time.Time

+ RedundancyScheme *RedundancyScheme

+ Version int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectBeginRequest) Descriptor() ([]byte, []int)

+ func (*ObjectBeginRequest) ProtoMessage()

+ func (m *ObjectBeginRequest) GetBucket() []byte

+ func (m *ObjectBeginRequest) GetEncryptedMetadata() []byte

+ func (m *ObjectBeginRequest) GetEncryptedPath() []byte

+ func (m *ObjectBeginRequest) GetEncryptionParameters() *EncryptionParameters

+ func (m *ObjectBeginRequest) GetExpiresAt() time.Time

+ func (m *ObjectBeginRequest) GetRedundancyScheme() *RedundancyScheme

+ func (m *ObjectBeginRequest) GetVersion() int32

+ func (m *ObjectBeginRequest) Reset()

+ func (m *ObjectBeginRequest) String() string

+ func (m *ObjectBeginRequest) XXX_DiscardUnknown()

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

+ func (m *ObjectBeginRequest) XXX_Merge(src proto.Message)

+ func (m *ObjectBeginRequest) XXX_Size() int

+ func (m *ObjectBeginRequest) XXX_Unmarshal(b []byte) error

+ type ObjectBeginResponse struct

+ Bucket []byte

+ EncryptedPath []byte

+ EncryptionParameters *EncryptionParameters

+ RedundancyScheme *RedundancyScheme

+ StreamId StreamID

+ Version int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectBeginResponse) Descriptor() ([]byte, []int)

+ func (*ObjectBeginResponse) ProtoMessage()

+ func (m *ObjectBeginResponse) GetBucket() []byte

+ func (m *ObjectBeginResponse) GetEncryptedPath() []byte

+ func (m *ObjectBeginResponse) GetEncryptionParameters() *EncryptionParameters

+ func (m *ObjectBeginResponse) GetRedundancyScheme() *RedundancyScheme

+ func (m *ObjectBeginResponse) GetVersion() int32

+ func (m *ObjectBeginResponse) Reset()

+ func (m *ObjectBeginResponse) String() string

+ func (m *ObjectBeginResponse) XXX_DiscardUnknown()

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

+ func (m *ObjectBeginResponse) XXX_Merge(src proto.Message)

+ func (m *ObjectBeginResponse) XXX_Size() int

+ func (m *ObjectBeginResponse) XXX_Unmarshal(b []byte) error

+ type ObjectCommitRequest struct

+ StreamId StreamID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectCommitRequest) Descriptor() ([]byte, []int)

+ func (*ObjectCommitRequest) ProtoMessage()

+ func (m *ObjectCommitRequest) Reset()

+ func (m *ObjectCommitRequest) String() string

+ func (m *ObjectCommitRequest) XXX_DiscardUnknown()

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

+ func (m *ObjectCommitRequest) XXX_Merge(src proto.Message)

+ func (m *ObjectCommitRequest) XXX_Size() int

+ func (m *ObjectCommitRequest) XXX_Unmarshal(b []byte) error

+ type ObjectCommitResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectCommitResponse) Descriptor() ([]byte, []int)

+ func (*ObjectCommitResponse) ProtoMessage()

+ func (m *ObjectCommitResponse) Reset()

+ func (m *ObjectCommitResponse) String() string

+ func (m *ObjectCommitResponse) XXX_DiscardUnknown()

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

+ func (m *ObjectCommitResponse) XXX_Merge(src proto.Message)

+ func (m *ObjectCommitResponse) XXX_Size() int

+ func (m *ObjectCommitResponse) XXX_Unmarshal(b []byte) error

+ type ObjectFinishDeleteRequest struct

+ StreamId StreamID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectFinishDeleteRequest) Descriptor() ([]byte, []int)

+ func (*ObjectFinishDeleteRequest) ProtoMessage()

+ func (m *ObjectFinishDeleteRequest) Reset()

+ func (m *ObjectFinishDeleteRequest) String() string

+ func (m *ObjectFinishDeleteRequest) XXX_DiscardUnknown()

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

+ func (m *ObjectFinishDeleteRequest) XXX_Merge(src proto.Message)

+ func (m *ObjectFinishDeleteRequest) XXX_Size() int

+ func (m *ObjectFinishDeleteRequest) XXX_Unmarshal(b []byte) error

+ type ObjectFinishDeleteResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectFinishDeleteResponse) Descriptor() ([]byte, []int)

+ func (*ObjectFinishDeleteResponse) ProtoMessage()

+ func (m *ObjectFinishDeleteResponse) Reset()

+ func (m *ObjectFinishDeleteResponse) String() string

+ func (m *ObjectFinishDeleteResponse) XXX_DiscardUnknown()

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

+ func (m *ObjectFinishDeleteResponse) XXX_Merge(src proto.Message)

+ func (m *ObjectFinishDeleteResponse) XXX_Size() int

+ func (m *ObjectFinishDeleteResponse) XXX_Unmarshal(b []byte) error

+ type ObjectGetRequest struct

+ Bucket []byte

+ EncryptedPath []byte

+ Version int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectGetRequest) Descriptor() ([]byte, []int)

+ func (*ObjectGetRequest) ProtoMessage()

+ func (m *ObjectGetRequest) GetBucket() []byte

+ func (m *ObjectGetRequest) GetEncryptedPath() []byte

+ func (m *ObjectGetRequest) GetVersion() int32

+ func (m *ObjectGetRequest) Reset()

+ func (m *ObjectGetRequest) String() string

+ func (m *ObjectGetRequest) XXX_DiscardUnknown()

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

+ func (m *ObjectGetRequest) XXX_Merge(src proto.Message)

+ func (m *ObjectGetRequest) XXX_Size() int

+ func (m *ObjectGetRequest) XXX_Unmarshal(b []byte) error

+ type ObjectGetResponse struct

+ Object *Object

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectGetResponse) Descriptor() ([]byte, []int)

+ func (*ObjectGetResponse) ProtoMessage()

+ func (m *ObjectGetResponse) GetObject() *Object

+ func (m *ObjectGetResponse) Reset()

+ func (m *ObjectGetResponse) String() string

+ func (m *ObjectGetResponse) XXX_DiscardUnknown()

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

+ func (m *ObjectGetResponse) XXX_Merge(src proto.Message)

+ func (m *ObjectGetResponse) XXX_Size() int

+ func (m *ObjectGetResponse) XXX_Unmarshal(b []byte) error

+ type ObjectListItem struct

+ CreatedAt time.Time

+ EncryptedMetadata []byte

+ EncryptedMetadataNonce Nonce

+ EncryptedPath []byte

+ ExpiresAt time.Time

+ Status Object_Status

+ StatusAt time.Time

+ Version int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectListItem) Descriptor() ([]byte, []int)

+ func (*ObjectListItem) ProtoMessage()

+ func (m *ObjectListItem) GetCreatedAt() time.Time

+ func (m *ObjectListItem) GetEncryptedMetadata() []byte

+ func (m *ObjectListItem) GetEncryptedPath() []byte

+ func (m *ObjectListItem) GetExpiresAt() time.Time

+ func (m *ObjectListItem) GetStatus() Object_Status

+ func (m *ObjectListItem) GetStatusAt() time.Time

+ func (m *ObjectListItem) GetVersion() int32

+ func (m *ObjectListItem) Reset()

+ func (m *ObjectListItem) String() string

+ func (m *ObjectListItem) XXX_DiscardUnknown()

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

+ func (m *ObjectListItem) XXX_Merge(src proto.Message)

+ func (m *ObjectListItem) XXX_Size() int

+ func (m *ObjectListItem) XXX_Unmarshal(b []byte) error

+ type ObjectListItemIncludes struct

+ Metadata bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectListItemIncludes) Descriptor() ([]byte, []int)

+ func (*ObjectListItemIncludes) ProtoMessage()

+ func (m *ObjectListItemIncludes) GetMetadata() bool

+ func (m *ObjectListItemIncludes) Reset()

+ func (m *ObjectListItemIncludes) String() string

+ func (m *ObjectListItemIncludes) XXX_DiscardUnknown()

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

+ func (m *ObjectListItemIncludes) XXX_Merge(src proto.Message)

+ func (m *ObjectListItemIncludes) XXX_Size() int

+ func (m *ObjectListItemIncludes) XXX_Unmarshal(b []byte) error

+ type ObjectListRequest struct

+ Bucket []byte

+ EncryptedCursor []byte

+ EncryptedPrefix []byte

+ Limit int32

+ ObjectIncludes *ObjectListItemIncludes

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectListRequest) Descriptor() ([]byte, []int)

+ func (*ObjectListRequest) ProtoMessage()

+ func (m *ObjectListRequest) GetBucket() []byte

+ func (m *ObjectListRequest) GetEncryptedCursor() []byte

+ func (m *ObjectListRequest) GetEncryptedPrefix() []byte

+ func (m *ObjectListRequest) GetLimit() int32

+ func (m *ObjectListRequest) GetObjectIncludes() *ObjectListItemIncludes

+ func (m *ObjectListRequest) Reset()

+ func (m *ObjectListRequest) String() string

+ func (m *ObjectListRequest) XXX_DiscardUnknown()

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

+ func (m *ObjectListRequest) XXX_Merge(src proto.Message)

+ func (m *ObjectListRequest) XXX_Size() int

+ func (m *ObjectListRequest) XXX_Unmarshal(b []byte) error

+ type ObjectListResponse struct

+ Items []*ObjectListItem

+ More bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectListResponse) Descriptor() ([]byte, []int)

+ func (*ObjectListResponse) ProtoMessage()

+ func (m *ObjectListResponse) GetItems() []*ObjectListItem

+ func (m *ObjectListResponse) GetMore() bool

+ func (m *ObjectListResponse) Reset()

+ func (m *ObjectListResponse) String() string

+ func (m *ObjectListResponse) XXX_DiscardUnknown()

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

+ func (m *ObjectListResponse) XXX_Merge(src proto.Message)

+ func (m *ObjectListResponse) XXX_Size() int

+ func (m *ObjectListResponse) XXX_Unmarshal(b []byte) error

+ type Object_Status int32

+ const Object_COMMITTED

+ const Object_COMMITTING

+ const Object_DELETING

+ const Object_INVALID

+ const Object_UPLOADING

+ func (Object_Status) EnumDescriptor() ([]byte, []int)

+ func (x Object_Status) String() string

+ type Piece struct

+ Node NodeID

+ PieceNum int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Piece) Descriptor() ([]byte, []int)

+ func (*Piece) ProtoMessage()

+ func (m *Piece) GetPieceNum() int32

+ func (m *Piece) Reset()

+ func (m *Piece) String() string

+ func (m *Piece) XXX_DiscardUnknown()

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

+ func (m *Piece) XXX_Merge(src proto.Message)

+ func (m *Piece) XXX_Size() int

+ func (m *Piece) XXX_Unmarshal(b []byte) error

+ type SatSegmentID struct

+ CreationDate time.Time

+ Index int32

+ OriginalOrderLimits []*AddressedOrderLimit

+ PartNumber int32

+ RootPieceId PieceID

+ SatelliteSignature []byte

+ StreamId *SatStreamID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SatSegmentID) Descriptor() ([]byte, []int)

+ func (*SatSegmentID) ProtoMessage()

+ func (m *SatSegmentID) GetCreationDate() time.Time

+ func (m *SatSegmentID) GetIndex() int32

+ func (m *SatSegmentID) GetOriginalOrderLimits() []*AddressedOrderLimit

+ func (m *SatSegmentID) GetPartNumber() int32

+ func (m *SatSegmentID) GetSatelliteSignature() []byte

+ func (m *SatSegmentID) GetStreamId() *SatStreamID

+ func (m *SatSegmentID) Reset()

+ func (m *SatSegmentID) String() string

+ func (m *SatSegmentID) XXX_DiscardUnknown()

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

+ func (m *SatSegmentID) XXX_Merge(src proto.Message)

+ func (m *SatSegmentID) XXX_Size() int

+ func (m *SatSegmentID) XXX_Unmarshal(b []byte) error

+ type SatStreamID struct

+ Bucket []byte

+ CreationDate time.Time

+ EncryptedMetadata []byte

+ EncryptedMetadataNonce Nonce

+ EncryptedPath []byte

+ ExpirationDate time.Time

+ Redundancy *RedundancyScheme

+ SatelliteSignature []byte

+ Version int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SatStreamID) Descriptor() ([]byte, []int)

+ func (*SatStreamID) ProtoMessage()

+ func (m *SatStreamID) GetBucket() []byte

+ func (m *SatStreamID) GetCreationDate() time.Time

+ func (m *SatStreamID) GetEncryptedMetadata() []byte

+ func (m *SatStreamID) GetEncryptedPath() []byte

+ func (m *SatStreamID) GetExpirationDate() time.Time

+ func (m *SatStreamID) GetRedundancy() *RedundancyScheme

+ func (m *SatStreamID) GetSatelliteSignature() []byte

+ func (m *SatStreamID) GetVersion() int32

+ func (m *SatStreamID) Reset()

+ func (m *SatStreamID) String() string

+ func (m *SatStreamID) XXX_DiscardUnknown()

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

+ func (m *SatStreamID) XXX_Merge(src proto.Message)

+ func (m *SatStreamID) XXX_Size() int

+ func (m *SatStreamID) XXX_Unmarshal(b []byte) error

+ type Segment struct

+ EncryptedInlineData []byte

+ EncryptedKey []byte

+ EncryptedKeyNonce Nonce

+ Pieces []*Piece

+ Position *SegmentPosition

+ SizeEncryptedData int64

+ StreamId StreamID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Segment) Descriptor() ([]byte, []int)

+ func (*Segment) ProtoMessage()

+ func (m *Segment) GetEncryptedInlineData() []byte

+ func (m *Segment) GetEncryptedKey() []byte

+ func (m *Segment) GetPieces() []*Piece

+ func (m *Segment) GetPosition() *SegmentPosition

+ func (m *Segment) GetSizeEncryptedData() int64

+ func (m *Segment) Reset()

+ func (m *Segment) String() string

+ func (m *Segment) XXX_DiscardUnknown()

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

+ func (m *Segment) XXX_Merge(src proto.Message)

+ func (m *Segment) XXX_Size() int

+ func (m *Segment) XXX_Unmarshal(b []byte) error

+ type SegmentBeginDeleteRequest struct

+ Position *SegmentPosition

+ StreamId []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentBeginDeleteRequest) Descriptor() ([]byte, []int)

+ func (*SegmentBeginDeleteRequest) ProtoMessage()

+ func (m *SegmentBeginDeleteRequest) GetPosition() *SegmentPosition

+ func (m *SegmentBeginDeleteRequest) GetStreamId() []byte

+ func (m *SegmentBeginDeleteRequest) Reset()

+ func (m *SegmentBeginDeleteRequest) String() string

+ func (m *SegmentBeginDeleteRequest) XXX_DiscardUnknown()

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

+ func (m *SegmentBeginDeleteRequest) XXX_Merge(src proto.Message)

+ func (m *SegmentBeginDeleteRequest) XXX_Size() int

+ func (m *SegmentBeginDeleteRequest) XXX_Unmarshal(b []byte) error

+ type SegmentBeginDeleteResponse struct

+ AddressedLimits []*AddressedOrderLimit

+ SegmentId SegmentID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentBeginDeleteResponse) Descriptor() ([]byte, []int)

+ func (*SegmentBeginDeleteResponse) ProtoMessage()

+ func (m *SegmentBeginDeleteResponse) GetAddressedLimits() []*AddressedOrderLimit

+ func (m *SegmentBeginDeleteResponse) Reset()

+ func (m *SegmentBeginDeleteResponse) String() string

+ func (m *SegmentBeginDeleteResponse) XXX_DiscardUnknown()

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

+ func (m *SegmentBeginDeleteResponse) XXX_Merge(src proto.Message)

+ func (m *SegmentBeginDeleteResponse) XXX_Size() int

+ func (m *SegmentBeginDeleteResponse) XXX_Unmarshal(b []byte) error

+ type SegmentBeginRequest struct

+ MaxOrderLimit int64

+ Position *SegmentPosition

+ StreamId StreamID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentBeginRequest) Descriptor() ([]byte, []int)

+ func (*SegmentBeginRequest) ProtoMessage()

+ func (m *SegmentBeginRequest) GetMaxOrderLimit() int64

+ func (m *SegmentBeginRequest) GetPosition() *SegmentPosition

+ func (m *SegmentBeginRequest) Reset()

+ func (m *SegmentBeginRequest) String() string

+ func (m *SegmentBeginRequest) XXX_DiscardUnknown()

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

+ func (m *SegmentBeginRequest) XXX_Merge(src proto.Message)

+ func (m *SegmentBeginRequest) XXX_Size() int

+ func (m *SegmentBeginRequest) XXX_Unmarshal(b []byte) error

+ type SegmentBeginResponse struct

+ AddressedLimits []*AddressedOrderLimit

+ PrivateKey PiecePrivateKey

+ SegmentId SegmentID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentBeginResponse) Descriptor() ([]byte, []int)

+ func (*SegmentBeginResponse) ProtoMessage()

+ func (m *SegmentBeginResponse) GetAddressedLimits() []*AddressedOrderLimit

+ func (m *SegmentBeginResponse) Reset()

+ func (m *SegmentBeginResponse) String() string

+ func (m *SegmentBeginResponse) XXX_DiscardUnknown()

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

+ func (m *SegmentBeginResponse) XXX_Merge(src proto.Message)

+ func (m *SegmentBeginResponse) XXX_Size() int

+ func (m *SegmentBeginResponse) XXX_Unmarshal(b []byte) error

type SegmentCommitRequest

+ EncryptedKey []byte

+ EncryptedKeyNonce Nonce

+ SegmentId SegmentID

+ SizeEncryptedData int64

+ UploadResult []*SegmentPieceUploadResult

+ func (m *SegmentCommitRequest) GetEncryptedKey() []byte

+ func (m *SegmentCommitRequest) GetSizeEncryptedData() int64

+ func (m *SegmentCommitRequest) GetUploadResult() []*SegmentPieceUploadResult

type SegmentDownloadRequest

+ CursorPosition *SegmentPosition

+ StreamId StreamID

+ func (m *SegmentDownloadRequest) GetCursorPosition() *SegmentPosition

type SegmentDownloadResponse

+ EncryptedInlineData []byte

+ Next *SegmentPosition

+ SegmentId SegmentID

+ func (m *SegmentDownloadResponse) GetEncryptedInlineData() []byte

+ func (m *SegmentDownloadResponse) GetNext() *SegmentPosition

+ type SegmentFinishDeleteRequest struct

+ Results []*SegmentPieceDeleteResult

+ SegmentId SegmentID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentFinishDeleteRequest) Descriptor() ([]byte, []int)

+ func (*SegmentFinishDeleteRequest) ProtoMessage()

+ func (m *SegmentFinishDeleteRequest) GetResults() []*SegmentPieceDeleteResult

+ func (m *SegmentFinishDeleteRequest) Reset()

+ func (m *SegmentFinishDeleteRequest) String() string

+ func (m *SegmentFinishDeleteRequest) XXX_DiscardUnknown()

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

+ func (m *SegmentFinishDeleteRequest) XXX_Merge(src proto.Message)

+ func (m *SegmentFinishDeleteRequest) XXX_Size() int

+ func (m *SegmentFinishDeleteRequest) XXX_Unmarshal(b []byte) error

+ type SegmentFinishDeleteResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentFinishDeleteResponse) Descriptor() ([]byte, []int)

+ func (*SegmentFinishDeleteResponse) ProtoMessage()

+ func (m *SegmentFinishDeleteResponse) Reset()

+ func (m *SegmentFinishDeleteResponse) String() string

+ func (m *SegmentFinishDeleteResponse) XXX_DiscardUnknown()

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

+ func (m *SegmentFinishDeleteResponse) XXX_Merge(src proto.Message)

+ func (m *SegmentFinishDeleteResponse) XXX_Size() int

+ func (m *SegmentFinishDeleteResponse) XXX_Unmarshal(b []byte) error

+ type SegmentID = storj.SegmentID

+ type SegmentListItem struct

+ Position *SegmentPosition

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentListItem) Descriptor() ([]byte, []int)

+ func (*SegmentListItem) ProtoMessage()

+ func (m *SegmentListItem) GetPosition() *SegmentPosition

+ func (m *SegmentListItem) Reset()

+ func (m *SegmentListItem) String() string

+ func (m *SegmentListItem) XXX_DiscardUnknown()

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

+ func (m *SegmentListItem) XXX_Merge(src proto.Message)

+ func (m *SegmentListItem) XXX_Size() int

+ func (m *SegmentListItem) XXX_Unmarshal(b []byte) error

+ type SegmentListRequest struct

+ CursorPosition *SegmentPosition

+ Limit int32

+ StreamId []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentListRequest) Descriptor() ([]byte, []int)

+ func (*SegmentListRequest) ProtoMessage()

+ func (m *SegmentListRequest) GetCursorPosition() *SegmentPosition

+ func (m *SegmentListRequest) GetLimit() int32

+ func (m *SegmentListRequest) GetStreamId() []byte

+ func (m *SegmentListRequest) Reset()

+ func (m *SegmentListRequest) String() string

+ func (m *SegmentListRequest) XXX_DiscardUnknown()

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

+ func (m *SegmentListRequest) XXX_Merge(src proto.Message)

+ func (m *SegmentListRequest) XXX_Size() int

+ func (m *SegmentListRequest) XXX_Unmarshal(b []byte) error

+ type SegmentListResponse struct

+ Items []*SegmentListItem

+ More bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentListResponse) Descriptor() ([]byte, []int)

+ func (*SegmentListResponse) ProtoMessage()

+ func (m *SegmentListResponse) GetItems() []*SegmentListItem

+ func (m *SegmentListResponse) GetMore() bool

+ func (m *SegmentListResponse) Reset()

+ func (m *SegmentListResponse) String() string

+ func (m *SegmentListResponse) XXX_DiscardUnknown()

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

+ func (m *SegmentListResponse) XXX_Merge(src proto.Message)

+ func (m *SegmentListResponse) XXX_Size() int

+ func (m *SegmentListResponse) XXX_Unmarshal(b []byte) error

+ type SegmentMakeInlineRequest struct

+ EncryptedInlineData []byte

+ EncryptedKey []byte

+ EncryptedKeyNonce Nonce

+ Position *SegmentPosition

+ StreamId StreamID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentMakeInlineRequest) Descriptor() ([]byte, []int)

+ func (*SegmentMakeInlineRequest) ProtoMessage()

+ func (m *SegmentMakeInlineRequest) GetEncryptedInlineData() []byte

+ func (m *SegmentMakeInlineRequest) GetEncryptedKey() []byte

+ func (m *SegmentMakeInlineRequest) GetPosition() *SegmentPosition

+ func (m *SegmentMakeInlineRequest) Reset()

+ func (m *SegmentMakeInlineRequest) String() string

+ func (m *SegmentMakeInlineRequest) XXX_DiscardUnknown()

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

+ func (m *SegmentMakeInlineRequest) XXX_Merge(src proto.Message)

+ func (m *SegmentMakeInlineRequest) XXX_Size() int

+ func (m *SegmentMakeInlineRequest) XXX_Unmarshal(b []byte) error

+ type SegmentMakeInlineResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentMakeInlineResponse) Descriptor() ([]byte, []int)

+ func (*SegmentMakeInlineResponse) ProtoMessage()

+ func (m *SegmentMakeInlineResponse) Reset()

+ func (m *SegmentMakeInlineResponse) String() string

+ func (m *SegmentMakeInlineResponse) XXX_DiscardUnknown()

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

+ func (m *SegmentMakeInlineResponse) XXX_Merge(src proto.Message)

+ func (m *SegmentMakeInlineResponse) XXX_Size() int

+ func (m *SegmentMakeInlineResponse) XXX_Unmarshal(b []byte) error

+ type SegmentPieceDeleteResult struct

+ Hash *PieceHash

+ NodeId NodeID

+ PieceNum int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentPieceDeleteResult) Descriptor() ([]byte, []int)

+ func (*SegmentPieceDeleteResult) ProtoMessage()

+ func (m *SegmentPieceDeleteResult) GetHash() *PieceHash

+ func (m *SegmentPieceDeleteResult) GetPieceNum() int32

+ func (m *SegmentPieceDeleteResult) Reset()

+ func (m *SegmentPieceDeleteResult) String() string

+ func (m *SegmentPieceDeleteResult) XXX_DiscardUnknown()

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

+ func (m *SegmentPieceDeleteResult) XXX_Merge(src proto.Message)

+ func (m *SegmentPieceDeleteResult) XXX_Size() int

+ func (m *SegmentPieceDeleteResult) XXX_Unmarshal(b []byte) error

+ type SegmentPieceUploadResult struct

+ Hash *PieceHash

+ NodeId NodeID

+ PieceNum int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentPieceUploadResult) Descriptor() ([]byte, []int)

+ func (*SegmentPieceUploadResult) ProtoMessage()

+ func (m *SegmentPieceUploadResult) GetHash() *PieceHash

+ func (m *SegmentPieceUploadResult) GetPieceNum() int32

+ func (m *SegmentPieceUploadResult) Reset()

+ func (m *SegmentPieceUploadResult) String() string

+ func (m *SegmentPieceUploadResult) XXX_DiscardUnknown()

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

+ func (m *SegmentPieceUploadResult) XXX_Merge(src proto.Message)

+ func (m *SegmentPieceUploadResult) XXX_Size() int

+ func (m *SegmentPieceUploadResult) XXX_Unmarshal(b []byte) error

+ type SegmentPosition struct

+ Index int32

+ PartNumber int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentPosition) Descriptor() ([]byte, []int)

+ func (*SegmentPosition) ProtoMessage()

+ func (m *SegmentPosition) GetIndex() int32

+ func (m *SegmentPosition) GetPartNumber() int32

+ func (m *SegmentPosition) Reset()

+ func (m *SegmentPosition) String() string

+ func (m *SegmentPosition) XXX_DiscardUnknown()

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

+ func (m *SegmentPosition) XXX_Merge(src proto.Message)

+ func (m *SegmentPosition) XXX_Size() int

+ func (m *SegmentPosition) XXX_Unmarshal(b []byte) error

Jul 16, 2019

Changes in this version

+ var CipherSuite_name = map[int32]string

+ var CipherSuite_value = map[string]int32

+ func RegisterNodeStatsServer(s *grpc.Server, srv NodeStatsServer)

type Bucket

+ CreatedAt time.Time

+ DefaultEncryptionParameters *EncryptionParameters

+ DefaultRedundancyScheme *RedundancyScheme

+ DefaultSegmentSize int64

+ Name []byte

+ PathCipher CipherSuite

+ func (m *Bucket) GetCreatedAt() time.Time

+ func (m *Bucket) GetDefaultEncryptionParameters() *EncryptionParameters

+ func (m *Bucket) GetDefaultRedundancyScheme() *RedundancyScheme

+ func (m *Bucket) GetDefaultSegmentSize() int64

+ func (m *Bucket) GetName() []byte

+ func (m *Bucket) GetPathCipher() CipherSuite

+ type BucketCreateRequest struct

+ DefaultEncryptionParameters *EncryptionParameters

+ DefaultRedundancyScheme *RedundancyScheme

+ DefaultSegmentSize int64

+ Name []byte

+ PathCipher CipherSuite

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BucketCreateRequest) Descriptor() ([]byte, []int)

+ func (*BucketCreateRequest) ProtoMessage()

+ func (m *BucketCreateRequest) GetDefaultEncryptionParameters() *EncryptionParameters

+ func (m *BucketCreateRequest) GetDefaultRedundancyScheme() *RedundancyScheme

+ func (m *BucketCreateRequest) GetDefaultSegmentSize() int64

+ func (m *BucketCreateRequest) GetName() []byte

+ func (m *BucketCreateRequest) GetPathCipher() CipherSuite

+ func (m *BucketCreateRequest) Reset()

+ func (m *BucketCreateRequest) String() string

+ func (m *BucketCreateRequest) XXX_DiscardUnknown()

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

+ func (m *BucketCreateRequest) XXX_Merge(src proto.Message)

+ func (m *BucketCreateRequest) XXX_Size() int

+ func (m *BucketCreateRequest) XXX_Unmarshal(b []byte) error

+ type BucketCreateResponse struct

+ Bucket *Bucket

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BucketCreateResponse) Descriptor() ([]byte, []int)

+ func (*BucketCreateResponse) ProtoMessage()

+ func (m *BucketCreateResponse) GetBucket() *Bucket

+ func (m *BucketCreateResponse) Reset()

+ func (m *BucketCreateResponse) String() string

+ func (m *BucketCreateResponse) XXX_DiscardUnknown()

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

+ func (m *BucketCreateResponse) XXX_Merge(src proto.Message)

+ func (m *BucketCreateResponse) XXX_Size() int

+ func (m *BucketCreateResponse) XXX_Unmarshal(b []byte) error

+ type BucketDeleteRequest struct

+ Name []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BucketDeleteRequest) Descriptor() ([]byte, []int)

+ func (*BucketDeleteRequest) ProtoMessage()

+ func (m *BucketDeleteRequest) GetName() []byte

+ func (m *BucketDeleteRequest) Reset()

+ func (m *BucketDeleteRequest) String() string

+ func (m *BucketDeleteRequest) XXX_DiscardUnknown()

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

+ func (m *BucketDeleteRequest) XXX_Merge(src proto.Message)

+ func (m *BucketDeleteRequest) XXX_Size() int

+ func (m *BucketDeleteRequest) XXX_Unmarshal(b []byte) error

+ type BucketDeleteResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BucketDeleteResponse) Descriptor() ([]byte, []int)

+ func (*BucketDeleteResponse) ProtoMessage()

+ func (m *BucketDeleteResponse) Reset()

+ func (m *BucketDeleteResponse) String() string

+ func (m *BucketDeleteResponse) XXX_DiscardUnknown()

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

+ func (m *BucketDeleteResponse) XXX_Merge(src proto.Message)

+ func (m *BucketDeleteResponse) XXX_Size() int

+ func (m *BucketDeleteResponse) XXX_Unmarshal(b []byte) error

+ type BucketGetRequest struct

+ Name []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BucketGetRequest) Descriptor() ([]byte, []int)

+ func (*BucketGetRequest) ProtoMessage()

+ func (m *BucketGetRequest) GetName() []byte

+ func (m *BucketGetRequest) Reset()

+ func (m *BucketGetRequest) String() string

+ func (m *BucketGetRequest) XXX_DiscardUnknown()

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

+ func (m *BucketGetRequest) XXX_Merge(src proto.Message)

+ func (m *BucketGetRequest) XXX_Size() int

+ func (m *BucketGetRequest) XXX_Unmarshal(b []byte) error

+ type BucketGetResponse struct

+ Bucket *Bucket

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BucketGetResponse) Descriptor() ([]byte, []int)

+ func (*BucketGetResponse) ProtoMessage()

+ func (m *BucketGetResponse) GetBucket() *Bucket

+ func (m *BucketGetResponse) Reset()

+ func (m *BucketGetResponse) String() string

+ func (m *BucketGetResponse) XXX_DiscardUnknown()

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

+ func (m *BucketGetResponse) XXX_Merge(src proto.Message)

+ func (m *BucketGetResponse) XXX_Size() int

+ func (m *BucketGetResponse) XXX_Unmarshal(b []byte) error

+ type BucketListItem struct

+ CreatedAt time.Time

+ Name []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BucketListItem) Descriptor() ([]byte, []int)

+ func (*BucketListItem) ProtoMessage()

+ func (m *BucketListItem) GetCreatedAt() time.Time

+ func (m *BucketListItem) GetName() []byte

+ func (m *BucketListItem) Reset()

+ func (m *BucketListItem) String() string

+ func (m *BucketListItem) XXX_DiscardUnknown()

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

+ func (m *BucketListItem) XXX_Merge(src proto.Message)

+ func (m *BucketListItem) XXX_Size() int

+ func (m *BucketListItem) XXX_Unmarshal(b []byte) error

+ type BucketListRequest struct

+ Cursor []byte

+ Direction int32

+ Limit int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BucketListRequest) Descriptor() ([]byte, []int)

+ func (*BucketListRequest) ProtoMessage()

+ func (m *BucketListRequest) GetCursor() []byte

+ func (m *BucketListRequest) GetDirection() int32

+ func (m *BucketListRequest) GetLimit() int32

+ func (m *BucketListRequest) Reset()

+ func (m *BucketListRequest) String() string

+ func (m *BucketListRequest) XXX_DiscardUnknown()

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

+ func (m *BucketListRequest) XXX_Merge(src proto.Message)

+ func (m *BucketListRequest) XXX_Size() int

+ func (m *BucketListRequest) XXX_Unmarshal(b []byte) error

+ type BucketListResponse struct

+ Items []*BucketListItem

+ More bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BucketListResponse) Descriptor() ([]byte, []int)

+ func (*BucketListResponse) ProtoMessage()

+ func (m *BucketListResponse) GetItems() []*BucketListItem

+ func (m *BucketListResponse) GetMore() bool

+ func (m *BucketListResponse) Reset()

+ func (m *BucketListResponse) String() string

+ func (m *BucketListResponse) XXX_DiscardUnknown()

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

+ func (m *BucketListResponse) XXX_Merge(src proto.Message)

+ func (m *BucketListResponse) XXX_Size() int

+ func (m *BucketListResponse) XXX_Unmarshal(b []byte) error

+ type BucketSetAttributionRequest struct

+ AttributionId []byte

+ Name []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BucketSetAttributionRequest) Descriptor() ([]byte, []int)

+ func (*BucketSetAttributionRequest) ProtoMessage()

+ func (m *BucketSetAttributionRequest) GetAttributionId() []byte

+ func (m *BucketSetAttributionRequest) GetName() []byte

+ func (m *BucketSetAttributionRequest) Reset()

+ func (m *BucketSetAttributionRequest) String() string

+ func (m *BucketSetAttributionRequest) XXX_DiscardUnknown()

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

+ func (m *BucketSetAttributionRequest) XXX_Merge(src proto.Message)

+ func (m *BucketSetAttributionRequest) XXX_Size() int

+ func (m *BucketSetAttributionRequest) XXX_Unmarshal(b []byte) error

+ type BucketSetAttributionResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BucketSetAttributionResponse) Descriptor() ([]byte, []int)

+ func (*BucketSetAttributionResponse) ProtoMessage()

+ func (m *BucketSetAttributionResponse) Reset()

+ func (m *BucketSetAttributionResponse) String() string

+ func (m *BucketSetAttributionResponse) XXX_DiscardUnknown()

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

+ func (m *BucketSetAttributionResponse) XXX_Merge(src proto.Message)

+ func (m *BucketSetAttributionResponse) XXX_Size() int

+ func (m *BucketSetAttributionResponse) XXX_Unmarshal(b []byte) error

+ type CipherSuite int32

+ const CipherSuite_ENC_AESGCM

+ const CipherSuite_ENC_NULL

+ const CipherSuite_ENC_SECRETBOX

+ const CipherSuite_ENC_UNSPECIFIED

+ func (CipherSuite) EnumDescriptor() ([]byte, []int)

+ func (x CipherSuite) String() string

+ type DailyStorageUsageRequest struct

+ From time.Time

+ To time.Time

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DailyStorageUsageRequest) Descriptor() ([]byte, []int)

+ func (*DailyStorageUsageRequest) ProtoMessage()

+ func (m *DailyStorageUsageRequest) GetFrom() time.Time

+ func (m *DailyStorageUsageRequest) GetTo() time.Time

+ func (m *DailyStorageUsageRequest) Reset()

+ func (m *DailyStorageUsageRequest) String() string

+ func (m *DailyStorageUsageRequest) XXX_DiscardUnknown()

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

+ func (m *DailyStorageUsageRequest) XXX_Merge(src proto.Message)

+ func (m *DailyStorageUsageRequest) XXX_Size() int

+ func (m *DailyStorageUsageRequest) XXX_Unmarshal(b []byte) error

+ type DailyStorageUsageResponse struct

+ DailyStorageUsage []*DailyStorageUsageResponse_StorageUsage

+ NodeId NodeID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DailyStorageUsageResponse) Descriptor() ([]byte, []int)

+ func (*DailyStorageUsageResponse) ProtoMessage()

+ func (m *DailyStorageUsageResponse) GetDailyStorageUsage() []*DailyStorageUsageResponse_StorageUsage

+ func (m *DailyStorageUsageResponse) Reset()

+ func (m *DailyStorageUsageResponse) String() string

+ func (m *DailyStorageUsageResponse) XXX_DiscardUnknown()

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

+ func (m *DailyStorageUsageResponse) XXX_Merge(src proto.Message)

+ func (m *DailyStorageUsageResponse) XXX_Size() int

+ func (m *DailyStorageUsageResponse) XXX_Unmarshal(b []byte) error

+ type DailyStorageUsageResponse_StorageUsage struct

+ AtRestTotal float64

+ TimeStamp time.Time

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DailyStorageUsageResponse_StorageUsage) Descriptor() ([]byte, []int)

+ func (*DailyStorageUsageResponse_StorageUsage) ProtoMessage()

+ func (m *DailyStorageUsageResponse_StorageUsage) GetAtRestTotal() float64

+ func (m *DailyStorageUsageResponse_StorageUsage) GetTimeStamp() time.Time

+ func (m *DailyStorageUsageResponse_StorageUsage) Reset()

+ func (m *DailyStorageUsageResponse_StorageUsage) String() string

+ func (m *DailyStorageUsageResponse_StorageUsage) XXX_DiscardUnknown()

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

+ func (m *DailyStorageUsageResponse_StorageUsage) XXX_Merge(src proto.Message)

+ func (m *DailyStorageUsageResponse_StorageUsage) XXX_Size() int

+ func (m *DailyStorageUsageResponse_StorageUsage) XXX_Unmarshal(b []byte) error

type DashboardResponse

+ DashboardAddress string

+ func (m *DashboardResponse) GetDashboardAddress() string

+ type EncryptionParameters struct

+ BlockSize int64

+ CipherSuite CipherSuite

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EncryptionParameters) Descriptor() ([]byte, []int)

+ func (*EncryptionParameters) ProtoMessage()

+ func (m *EncryptionParameters) GetBlockSize() int64

+ func (m *EncryptionParameters) GetCipherSuite() CipherSuite

+ func (m *EncryptionParameters) Reset()

+ func (m *EncryptionParameters) String() string

+ func (m *EncryptionParameters) XXX_DiscardUnknown()

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

+ func (m *EncryptionParameters) XXX_Merge(src proto.Message)

+ func (m *EncryptionParameters) XXX_Size() int

+ func (m *EncryptionParameters) XXX_Unmarshal(b []byte) error

type GetStatsResponse

+ AuditCheck *ReputationStats

+ UptimeCheck *ReputationStats

+ func (m *GetStatsResponse) GetAuditCheck() *ReputationStats

+ func (m *GetStatsResponse) GetUptimeCheck() *ReputationStats

+ type ListSegmentsRequestOld struct

+ Bucket []byte

+ EndBefore []byte

+ Limit int32

+ MetaFlags uint32

+ Prefix []byte

+ Recursive bool

+ StartAfter []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListSegmentsRequestOld) Descriptor() ([]byte, []int)

+ func (*ListSegmentsRequestOld) ProtoMessage()

+ func (m *ListSegmentsRequestOld) GetBucket() []byte

+ func (m *ListSegmentsRequestOld) GetEndBefore() []byte

+ func (m *ListSegmentsRequestOld) GetLimit() int32

+ func (m *ListSegmentsRequestOld) GetMetaFlags() uint32

+ func (m *ListSegmentsRequestOld) GetPrefix() []byte

+ func (m *ListSegmentsRequestOld) GetRecursive() bool

+ func (m *ListSegmentsRequestOld) GetStartAfter() []byte

+ func (m *ListSegmentsRequestOld) Reset()

+ func (m *ListSegmentsRequestOld) String() string

+ func (m *ListSegmentsRequestOld) XXX_DiscardUnknown()

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

+ func (m *ListSegmentsRequestOld) XXX_Merge(src proto.Message)

+ func (m *ListSegmentsRequestOld) XXX_Size() int

+ func (m *ListSegmentsRequestOld) XXX_Unmarshal(b []byte) error

+ type ListSegmentsResponseOld struct

+ Items []*ListSegmentsResponseOld_Item

+ More bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListSegmentsResponseOld) Descriptor() ([]byte, []int)

+ func (*ListSegmentsResponseOld) ProtoMessage()

+ func (m *ListSegmentsResponseOld) GetItems() []*ListSegmentsResponseOld_Item

+ func (m *ListSegmentsResponseOld) GetMore() bool

+ func (m *ListSegmentsResponseOld) Reset()

+ func (m *ListSegmentsResponseOld) String() string

+ func (m *ListSegmentsResponseOld) XXX_DiscardUnknown()

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

+ func (m *ListSegmentsResponseOld) XXX_Merge(src proto.Message)

+ func (m *ListSegmentsResponseOld) XXX_Size() int

+ func (m *ListSegmentsResponseOld) XXX_Unmarshal(b []byte) error

+ type ListSegmentsResponseOld_Item struct

+ IsPrefix bool

+ Path []byte

+ Pointer *Pointer

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListSegmentsResponseOld_Item) Descriptor() ([]byte, []int)

+ func (*ListSegmentsResponseOld_Item) ProtoMessage()

+ func (m *ListSegmentsResponseOld_Item) GetIsPrefix() bool

+ func (m *ListSegmentsResponseOld_Item) GetPath() []byte

+ func (m *ListSegmentsResponseOld_Item) GetPointer() *Pointer

+ func (m *ListSegmentsResponseOld_Item) Reset()

+ func (m *ListSegmentsResponseOld_Item) String() string

+ func (m *ListSegmentsResponseOld_Item) XXX_DiscardUnknown()

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

+ func (m *ListSegmentsResponseOld_Item) XXX_Merge(src proto.Message)

+ func (m *ListSegmentsResponseOld_Item) XXX_Size() int

+ func (m *ListSegmentsResponseOld_Item) XXX_Unmarshal(b []byte) error

type MetainfoClient

+ CommitSegmentOld func(ctx context.Context, in *SegmentCommitRequestOld, opts ...grpc.CallOption) (*SegmentCommitResponseOld, error)

+ CreateBucket func(ctx context.Context, in *BucketCreateRequest, opts ...grpc.CallOption) (*BucketCreateResponse, error)

+ CreateSegmentOld func(ctx context.Context, in *SegmentWriteRequestOld, opts ...grpc.CallOption) (*SegmentWriteResponseOld, error)

+ DeleteBucket func(ctx context.Context, in *BucketDeleteRequest, opts ...grpc.CallOption) (*BucketDeleteResponse, error)

+ DeleteSegmentOld func(ctx context.Context, in *SegmentDeleteRequestOld, opts ...grpc.CallOption) (*SegmentDeleteResponseOld, error)

+ DownloadSegmentOld func(ctx context.Context, in *SegmentDownloadRequestOld, opts ...grpc.CallOption) (*SegmentDownloadResponseOld, error)

+ GetBucket func(ctx context.Context, in *BucketGetRequest, opts ...grpc.CallOption) (*BucketGetResponse, error)

+ ListBuckets func(ctx context.Context, in *BucketListRequest, opts ...grpc.CallOption) (*BucketListResponse, error)

+ ListSegmentsOld func(ctx context.Context, in *ListSegmentsRequestOld, opts ...grpc.CallOption) (*ListSegmentsResponseOld, error)

+ SegmentInfoOld func(ctx context.Context, in *SegmentInfoRequestOld, opts ...grpc.CallOption) (*SegmentInfoResponseOld, error)

+ SetAttributionOld func(ctx context.Context, in *SetAttributionRequestOld, opts ...grpc.CallOption) (*SetAttributionResponseOld, error)

+ SetBucketAttribution func(ctx context.Context, in *BucketSetAttributionRequest, opts ...grpc.CallOption) (*BucketSetAttributionResponse, error)

type MetainfoServer

+ CommitSegmentOld func(context.Context, *SegmentCommitRequestOld) (*SegmentCommitResponseOld, error)

+ CreateBucket func(context.Context, *BucketCreateRequest) (*BucketCreateResponse, error)

+ CreateSegmentOld func(context.Context, *SegmentWriteRequestOld) (*SegmentWriteResponseOld, error)

+ DeleteBucket func(context.Context, *BucketDeleteRequest) (*BucketDeleteResponse, error)

+ DeleteSegmentOld func(context.Context, *SegmentDeleteRequestOld) (*SegmentDeleteResponseOld, error)

+ DownloadSegmentOld func(context.Context, *SegmentDownloadRequestOld) (*SegmentDownloadResponseOld, error)

+ GetBucket func(context.Context, *BucketGetRequest) (*BucketGetResponse, error)

+ ListBuckets func(context.Context, *BucketListRequest) (*BucketListResponse, error)

+ ListSegmentsOld func(context.Context, *ListSegmentsRequestOld) (*ListSegmentsResponseOld, error)

+ SegmentInfoOld func(context.Context, *SegmentInfoRequestOld) (*SegmentInfoResponseOld, error)

+ SetAttributionOld func(context.Context, *SetAttributionRequestOld) (*SetAttributionResponseOld, error)

+ SetBucketAttribution func(context.Context, *BucketSetAttributionRequest) (*BucketSetAttributionResponse, error)

+ type NodeStatsClient interface

+ DailyStorageUsage func(ctx context.Context, in *DailyStorageUsageRequest, opts ...grpc.CallOption) (*DailyStorageUsageResponse, error)

+ GetStats func(ctx context.Context, in *GetStatsRequest, opts ...grpc.CallOption) (*GetStatsResponse, error)

+ func NewNodeStatsClient(cc *grpc.ClientConn) NodeStatsClient

+ type NodeStatsServer interface

+ DailyStorageUsage func(context.Context, *DailyStorageUsageRequest) (*DailyStorageUsageResponse, error)

+ GetStats func(context.Context, *GetStatsRequest) (*GetStatsResponse, error)

type Order

+ Amount int64

+ SerialNumber SerialNumber

+ UplinkSignature []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Order) Descriptor() ([]byte, []int)

+ func (*Order) ProtoMessage()

+ func (m *Order) GetAmount() int64

+ func (m *Order) GetUplinkSignature() []byte

+ func (m *Order) Reset()

+ func (m *Order) String() string

+ func (m *Order) XXX_DiscardUnknown()

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

+ func (m *Order) XXX_Merge(src proto.Message)

+ func (m *Order) XXX_Size() int

+ func (m *Order) XXX_Unmarshal(b []byte) error

type OrderLimit

+ Action PieceAction

+ DeprecatedUplinkId *NodeID

+ Limit int64

+ OrderCreation time.Time

+ OrderExpiration time.Time

+ PieceExpiration time.Time

+ PieceId PieceID

+ SatelliteAddress *NodeAddress

+ SatelliteId NodeID

+ SatelliteSignature []byte

+ SerialNumber SerialNumber

+ StorageNodeId NodeID

+ UplinkPublicKey PiecePublicKey

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OrderLimit) Descriptor() ([]byte, []int)

+ func (*OrderLimit) ProtoMessage()

+ func (m *OrderLimit) GetAction() PieceAction

+ func (m *OrderLimit) GetLimit() int64

+ func (m *OrderLimit) GetOrderCreation() time.Time

+ func (m *OrderLimit) GetOrderExpiration() time.Time

+ func (m *OrderLimit) GetPieceExpiration() time.Time

+ func (m *OrderLimit) GetSatelliteAddress() *NodeAddress

+ func (m *OrderLimit) GetSatelliteSignature() []byte

+ func (m *OrderLimit) Reset()

+ func (m *OrderLimit) String() string

+ func (m *OrderLimit) XXX_DiscardUnknown()

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

+ func (m *OrderLimit) XXX_Merge(src proto.Message)

+ func (m *OrderLimit) XXX_Size() int

+ func (m *OrderLimit) XXX_Unmarshal(b []byte) error

+ type OrderLimitSigning struct

+ Action PieceAction

+ DeprecatedUplinkId *NodeID

+ Limit int64

+ OrderCreation *time.Time

+ OrderExpiration *time.Time

+ PieceExpiration *time.Time

+ PieceId PieceID

+ SatelliteAddress *NodeAddress

+ SatelliteId NodeID

+ SatelliteSignature []byte

+ SerialNumber SerialNumber

+ StorageNodeId NodeID

+ UplinkPublicKey *PiecePublicKey

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OrderLimitSigning) Descriptor() ([]byte, []int)

+ func (*OrderLimitSigning) ProtoMessage()

+ func (m *OrderLimitSigning) GetAction() PieceAction

+ func (m *OrderLimitSigning) GetLimit() int64

+ func (m *OrderLimitSigning) GetOrderCreation() *time.Time

+ func (m *OrderLimitSigning) GetOrderExpiration() *time.Time

+ func (m *OrderLimitSigning) GetPieceExpiration() *time.Time

+ func (m *OrderLimitSigning) GetSatelliteAddress() *NodeAddress

+ func (m *OrderLimitSigning) GetSatelliteSignature() []byte

+ func (m *OrderLimitSigning) Reset()

+ func (m *OrderLimitSigning) String() string

+ func (m *OrderLimitSigning) XXX_DiscardUnknown()

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

+ func (m *OrderLimitSigning) XXX_Merge(src proto.Message)

+ func (m *OrderLimitSigning) XXX_Size() int

+ func (m *OrderLimitSigning) XXX_Unmarshal(b []byte) error

+ type OrderSigning struct

+ Amount int64

+ SerialNumber SerialNumber

+ UplinkSignature []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OrderSigning) Descriptor() ([]byte, []int)

+ func (*OrderSigning) ProtoMessage()

+ func (m *OrderSigning) GetAmount() int64

+ func (m *OrderSigning) GetUplinkSignature() []byte

+ func (m *OrderSigning) Reset()

+ func (m *OrderSigning) String() string

+ func (m *OrderSigning) XXX_DiscardUnknown()

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

+ func (m *OrderSigning) XXX_Merge(src proto.Message)

+ func (m *OrderSigning) XXX_Size() int

+ func (m *OrderSigning) XXX_Unmarshal(b []byte) error

type PieceHash

+ PieceSize int64

+ Timestamp time.Time

+ func (m *PieceHash) GetPieceSize() int64

+ func (m *PieceHash) GetTimestamp() time.Time

+ type PieceHashSigning struct

+ Hash []byte

+ PieceId PieceID

+ PieceSize int64

+ Signature []byte

+ Timestamp *time.Time

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceHashSigning) Descriptor() ([]byte, []int)

+ func (*PieceHashSigning) ProtoMessage()

+ func (m *PieceHashSigning) GetHash() []byte

+ func (m *PieceHashSigning) GetPieceSize() int64

+ func (m *PieceHashSigning) GetSignature() []byte

+ func (m *PieceHashSigning) GetTimestamp() *time.Time

+ func (m *PieceHashSigning) Reset()

+ func (m *PieceHashSigning) String() string

+ func (m *PieceHashSigning) XXX_DiscardUnknown()

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

+ func (m *PieceHashSigning) XXX_Merge(src proto.Message)

+ func (m *PieceHashSigning) XXX_Size() int

+ func (m *PieceHashSigning) XXX_Unmarshal(b []byte) error

+ type PiecePrivateKey = storj.PiecePrivateKey

+ type PiecePublicKey = storj.PiecePublicKey

type PiecestoreClient

+ Retain func(ctx context.Context, in *RetainRequest, opts ...grpc.CallOption) (*RetainResponse, error)

type PiecestoreServer

+ Retain func(context.Context, *RetainRequest) (*RetainResponse, error)

type QueryRequest

+ Vouchers []*Voucher

+ func (m *QueryRequest) GetVouchers() []*Voucher

type RedundancyScheme_SchemeType

+ const RedundancyScheme_INVALID

+ type ReputationStats struct

+ ReputationAlpha float64

+ ReputationBeta float64

+ ReputationScore float64

+ SuccessCount int64

+ TotalCount int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ReputationStats) Descriptor() ([]byte, []int)

+ func (*ReputationStats) ProtoMessage()

+ func (m *ReputationStats) GetReputationAlpha() float64

+ func (m *ReputationStats) GetReputationBeta() float64

+ func (m *ReputationStats) GetReputationScore() float64

+ func (m *ReputationStats) GetSuccessCount() int64

+ func (m *ReputationStats) GetTotalCount() int64

+ func (m *ReputationStats) Reset()

+ func (m *ReputationStats) String() string

+ func (m *ReputationStats) XXX_DiscardUnknown()

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

+ func (m *ReputationStats) XXX_Merge(src proto.Message)

+ func (m *ReputationStats) XXX_Size() int

+ func (m *ReputationStats) XXX_Unmarshal(b []byte) error

+ type Scope struct

+ ApiKey []byte

+ EncryptionAccess *EncryptionAccess

+ SatelliteAddr string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Scope) Descriptor() ([]byte, []int)

+ func (*Scope) ProtoMessage()

+ func (m *Scope) GetApiKey() []byte

+ func (m *Scope) GetEncryptionAccess() *EncryptionAccess

+ func (m *Scope) GetSatelliteAddr() string

+ func (m *Scope) Reset()

+ func (m *Scope) String() string

+ func (m *Scope) XXX_DiscardUnknown()

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

+ func (m *Scope) XXX_Merge(src proto.Message)

+ func (m *Scope) XXX_Size() int

+ func (m *Scope) XXX_Unmarshal(b []byte) error

+ type SegmentCommitRequestOld struct

+ Bucket []byte

+ OriginalLimits []*OrderLimit

+ Path []byte

+ Pointer *Pointer

+ Segment int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentCommitRequestOld) Descriptor() ([]byte, []int)

+ func (*SegmentCommitRequestOld) ProtoMessage()

+ func (m *SegmentCommitRequestOld) GetBucket() []byte

+ func (m *SegmentCommitRequestOld) GetOriginalLimits() []*OrderLimit

+ func (m *SegmentCommitRequestOld) GetPath() []byte

+ func (m *SegmentCommitRequestOld) GetPointer() *Pointer

+ func (m *SegmentCommitRequestOld) GetSegment() int64

+ func (m *SegmentCommitRequestOld) Reset()

+ func (m *SegmentCommitRequestOld) String() string

+ func (m *SegmentCommitRequestOld) XXX_DiscardUnknown()

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

+ func (m *SegmentCommitRequestOld) XXX_Merge(src proto.Message)

+ func (m *SegmentCommitRequestOld) XXX_Size() int

+ func (m *SegmentCommitRequestOld) XXX_Unmarshal(b []byte) error

+ type SegmentCommitResponseOld struct

+ Pointer *Pointer

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentCommitResponseOld) Descriptor() ([]byte, []int)

+ func (*SegmentCommitResponseOld) ProtoMessage()

+ func (m *SegmentCommitResponseOld) GetPointer() *Pointer

+ func (m *SegmentCommitResponseOld) Reset()

+ func (m *SegmentCommitResponseOld) String() string

+ func (m *SegmentCommitResponseOld) XXX_DiscardUnknown()

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

+ func (m *SegmentCommitResponseOld) XXX_Merge(src proto.Message)

+ func (m *SegmentCommitResponseOld) XXX_Size() int

+ func (m *SegmentCommitResponseOld) XXX_Unmarshal(b []byte) error

+ type SegmentDeleteRequestOld struct

+ Bucket []byte

+ Path []byte

+ Segment int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentDeleteRequestOld) Descriptor() ([]byte, []int)

+ func (*SegmentDeleteRequestOld) ProtoMessage()

+ func (m *SegmentDeleteRequestOld) GetBucket() []byte

+ func (m *SegmentDeleteRequestOld) GetPath() []byte

+ func (m *SegmentDeleteRequestOld) GetSegment() int64

+ func (m *SegmentDeleteRequestOld) Reset()

+ func (m *SegmentDeleteRequestOld) String() string

+ func (m *SegmentDeleteRequestOld) XXX_DiscardUnknown()

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

+ func (m *SegmentDeleteRequestOld) XXX_Merge(src proto.Message)

+ func (m *SegmentDeleteRequestOld) XXX_Size() int

+ func (m *SegmentDeleteRequestOld) XXX_Unmarshal(b []byte) error

+ type SegmentDeleteResponseOld struct

+ AddressedLimits []*AddressedOrderLimit

+ PrivateKey PiecePrivateKey

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentDeleteResponseOld) Descriptor() ([]byte, []int)

+ func (*SegmentDeleteResponseOld) ProtoMessage()

+ func (m *SegmentDeleteResponseOld) GetAddressedLimits() []*AddressedOrderLimit

+ func (m *SegmentDeleteResponseOld) Reset()

+ func (m *SegmentDeleteResponseOld) String() string

+ func (m *SegmentDeleteResponseOld) XXX_DiscardUnknown()

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

+ func (m *SegmentDeleteResponseOld) XXX_Merge(src proto.Message)

+ func (m *SegmentDeleteResponseOld) XXX_Size() int

+ func (m *SegmentDeleteResponseOld) XXX_Unmarshal(b []byte) error

+ type SegmentDownloadRequestOld struct

+ Bucket []byte

+ Path []byte

+ Segment int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentDownloadRequestOld) Descriptor() ([]byte, []int)

+ func (*SegmentDownloadRequestOld) ProtoMessage()

+ func (m *SegmentDownloadRequestOld) GetBucket() []byte

+ func (m *SegmentDownloadRequestOld) GetPath() []byte

+ func (m *SegmentDownloadRequestOld) GetSegment() int64

+ func (m *SegmentDownloadRequestOld) Reset()

+ func (m *SegmentDownloadRequestOld) String() string

+ func (m *SegmentDownloadRequestOld) XXX_DiscardUnknown()

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

+ func (m *SegmentDownloadRequestOld) XXX_Merge(src proto.Message)

+ func (m *SegmentDownloadRequestOld) XXX_Size() int

+ func (m *SegmentDownloadRequestOld) XXX_Unmarshal(b []byte) error

+ type SegmentDownloadResponseOld struct

+ AddressedLimits []*AddressedOrderLimit

+ Pointer *Pointer

+ PrivateKey PiecePrivateKey

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentDownloadResponseOld) Descriptor() ([]byte, []int)

+ func (*SegmentDownloadResponseOld) ProtoMessage()

+ func (m *SegmentDownloadResponseOld) GetAddressedLimits() []*AddressedOrderLimit

+ func (m *SegmentDownloadResponseOld) GetPointer() *Pointer

+ func (m *SegmentDownloadResponseOld) Reset()

+ func (m *SegmentDownloadResponseOld) String() string

+ func (m *SegmentDownloadResponseOld) XXX_DiscardUnknown()

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

+ func (m *SegmentDownloadResponseOld) XXX_Merge(src proto.Message)

+ func (m *SegmentDownloadResponseOld) XXX_Size() int

+ func (m *SegmentDownloadResponseOld) XXX_Unmarshal(b []byte) error

+ type SegmentInfoRequestOld struct

+ Bucket []byte

+ Path []byte

+ Segment int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentInfoRequestOld) Descriptor() ([]byte, []int)

+ func (*SegmentInfoRequestOld) ProtoMessage()

+ func (m *SegmentInfoRequestOld) GetBucket() []byte

+ func (m *SegmentInfoRequestOld) GetPath() []byte

+ func (m *SegmentInfoRequestOld) GetSegment() int64

+ func (m *SegmentInfoRequestOld) Reset()

+ func (m *SegmentInfoRequestOld) String() string

+ func (m *SegmentInfoRequestOld) XXX_DiscardUnknown()

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

+ func (m *SegmentInfoRequestOld) XXX_Merge(src proto.Message)

+ func (m *SegmentInfoRequestOld) XXX_Size() int

+ func (m *SegmentInfoRequestOld) XXX_Unmarshal(b []byte) error

+ type SegmentInfoResponseOld struct

+ Pointer *Pointer

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentInfoResponseOld) Descriptor() ([]byte, []int)

+ func (*SegmentInfoResponseOld) ProtoMessage()

+ func (m *SegmentInfoResponseOld) GetPointer() *Pointer

+ func (m *SegmentInfoResponseOld) Reset()

+ func (m *SegmentInfoResponseOld) String() string

+ func (m *SegmentInfoResponseOld) XXX_DiscardUnknown()

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

+ func (m *SegmentInfoResponseOld) XXX_Merge(src proto.Message)

+ func (m *SegmentInfoResponseOld) XXX_Size() int

+ func (m *SegmentInfoResponseOld) XXX_Unmarshal(b []byte) error

+ type SegmentWriteRequestOld struct

+ Bucket []byte

+ Expiration time.Time

+ MaxEncryptedSegmentSize int64

+ Path []byte

+ Redundancy *RedundancyScheme

+ Segment int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentWriteRequestOld) Descriptor() ([]byte, []int)

+ func (*SegmentWriteRequestOld) ProtoMessage()

+ func (m *SegmentWriteRequestOld) GetBucket() []byte

+ func (m *SegmentWriteRequestOld) GetExpiration() time.Time

+ func (m *SegmentWriteRequestOld) GetMaxEncryptedSegmentSize() int64

+ func (m *SegmentWriteRequestOld) GetPath() []byte

+ func (m *SegmentWriteRequestOld) GetRedundancy() *RedundancyScheme

+ func (m *SegmentWriteRequestOld) GetSegment() int64

+ func (m *SegmentWriteRequestOld) Reset()

+ func (m *SegmentWriteRequestOld) String() string

+ func (m *SegmentWriteRequestOld) XXX_DiscardUnknown()

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

+ func (m *SegmentWriteRequestOld) XXX_Merge(src proto.Message)

+ func (m *SegmentWriteRequestOld) XXX_Size() int

+ func (m *SegmentWriteRequestOld) XXX_Unmarshal(b []byte) error

+ type SegmentWriteResponseOld struct

+ AddressedLimits []*AddressedOrderLimit

+ PrivateKey PiecePrivateKey

+ RootPieceId PieceID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentWriteResponseOld) Descriptor() ([]byte, []int)

+ func (*SegmentWriteResponseOld) ProtoMessage()

+ func (m *SegmentWriteResponseOld) GetAddressedLimits() []*AddressedOrderLimit

+ func (m *SegmentWriteResponseOld) Reset()

+ func (m *SegmentWriteResponseOld) String() string

+ func (m *SegmentWriteResponseOld) XXX_DiscardUnknown()

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

+ func (m *SegmentWriteResponseOld) XXX_Merge(src proto.Message)

+ func (m *SegmentWriteResponseOld) XXX_Size() int

+ func (m *SegmentWriteResponseOld) XXX_Unmarshal(b []byte) error

+ type SetAttributionRequestOld struct

+ BucketName []byte

+ PartnerId []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetAttributionRequestOld) Descriptor() ([]byte, []int)

+ func (*SetAttributionRequestOld) ProtoMessage()

+ func (m *SetAttributionRequestOld) GetBucketName() []byte

+ func (m *SetAttributionRequestOld) GetPartnerId() []byte

+ func (m *SetAttributionRequestOld) Reset()

+ func (m *SetAttributionRequestOld) String() string

+ func (m *SetAttributionRequestOld) XXX_DiscardUnknown()

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

+ func (m *SetAttributionRequestOld) XXX_Merge(src proto.Message)

+ func (m *SetAttributionRequestOld) XXX_Size() int

+ func (m *SetAttributionRequestOld) XXX_Unmarshal(b []byte) error

+ type SetAttributionResponseOld struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetAttributionResponseOld) Descriptor() ([]byte, []int)

+ func (*SetAttributionResponseOld) ProtoMessage()

+ func (m *SetAttributionResponseOld) Reset()

+ func (m *SetAttributionResponseOld) String() string

+ func (m *SetAttributionResponseOld) XXX_DiscardUnknown()

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

+ func (m *SetAttributionResponseOld) XXX_Merge(src proto.Message)

+ func (m *SetAttributionResponseOld) XXX_Size() int

+ func (m *SetAttributionResponseOld) XXX_Unmarshal(b []byte) error

+ type StreamID = storj.StreamID

Jul 12, 2019

Changes in this version

type InjuredSegment

+ InsertedTime time.Time

+ func (m *InjuredSegment) GetInsertedTime() time.Time

Jun 28, 2019

Changes in this version

+ type EncryptionAccess struct

+ DefaultKey []byte

+ StoreEntries []*EncryptionAccess_StoreEntry

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EncryptionAccess) Descriptor() ([]byte, []int)

+ func (*EncryptionAccess) ProtoMessage()

+ func (m *EncryptionAccess) GetDefaultKey() []byte

+ func (m *EncryptionAccess) GetStoreEntries() []*EncryptionAccess_StoreEntry

+ func (m *EncryptionAccess) Reset()

+ func (m *EncryptionAccess) String() string

+ func (m *EncryptionAccess) XXX_DiscardUnknown()

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

+ func (m *EncryptionAccess) XXX_Merge(src proto.Message)

+ func (m *EncryptionAccess) XXX_Size() int

+ func (m *EncryptionAccess) XXX_Unmarshal(b []byte) error

+ type EncryptionAccess_StoreEntry struct

+ Bucket []byte

+ EncryptedPath []byte

+ Key []byte

+ UnencryptedPath []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EncryptionAccess_StoreEntry) Descriptor() ([]byte, []int)

+ func (*EncryptionAccess_StoreEntry) ProtoMessage()

+ func (m *EncryptionAccess_StoreEntry) GetBucket() []byte

+ func (m *EncryptionAccess_StoreEntry) GetEncryptedPath() []byte

+ func (m *EncryptionAccess_StoreEntry) GetKey() []byte

+ func (m *EncryptionAccess_StoreEntry) GetUnencryptedPath() []byte

+ func (m *EncryptionAccess_StoreEntry) Reset()

+ func (m *EncryptionAccess_StoreEntry) String() string

+ func (m *EncryptionAccess_StoreEntry) XXX_DiscardUnknown()

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

+ func (m *EncryptionAccess_StoreEntry) XXX_Merge(src proto.Message)

+ func (m *EncryptionAccess_StoreEntry) XXX_Size() int

+ func (m *EncryptionAccess_StoreEntry) XXX_Unmarshal(b []byte) error

Jun 27, 2019

Changes in this version

+ type EncryptionCtx struct

+ DefaultKey []byte

+ StoreEntries []*EncryptionCtx_StoreEntry

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EncryptionCtx) Descriptor() ([]byte, []int)

+ func (*EncryptionCtx) ProtoMessage()

+ func (m *EncryptionCtx) GetDefaultKey() []byte

+ func (m *EncryptionCtx) GetStoreEntries() []*EncryptionCtx_StoreEntry

+ func (m *EncryptionCtx) Reset()

+ func (m *EncryptionCtx) String() string

+ func (m *EncryptionCtx) XXX_DiscardUnknown()

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

+ func (m *EncryptionCtx) XXX_Merge(src proto.Message)

+ func (m *EncryptionCtx) XXX_Size() int

+ func (m *EncryptionCtx) XXX_Unmarshal(b []byte) error

+ type EncryptionCtx_StoreEntry struct

+ Bucket []byte

+ EncryptedPath []byte

+ Key []byte

+ UnencryptedPath []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*EncryptionCtx_StoreEntry) Descriptor() ([]byte, []int)

+ func (*EncryptionCtx_StoreEntry) ProtoMessage()

+ func (m *EncryptionCtx_StoreEntry) GetBucket() []byte

+ func (m *EncryptionCtx_StoreEntry) GetEncryptedPath() []byte

+ func (m *EncryptionCtx_StoreEntry) GetKey() []byte

+ func (m *EncryptionCtx_StoreEntry) GetUnencryptedPath() []byte

+ func (m *EncryptionCtx_StoreEntry) Reset()

+ func (m *EncryptionCtx_StoreEntry) String() string

+ func (m *EncryptionCtx_StoreEntry) XXX_DiscardUnknown()

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

+ func (m *EncryptionCtx_StoreEntry) XXX_Merge(src proto.Message)

+ func (m *EncryptionCtx_StoreEntry) XXX_Size() int

+ func (m *EncryptionCtx_StoreEntry) XXX_Unmarshal(b []byte) error

Jun 24, 2019

Changes in this version

+ var VoucherResponse_Status_name = map[int32]string

+ var VoucherResponse_Status_value = map[string]int32

+ func RegisterGarbageCollectionServer(s *grpc.Server, srv GarbageCollectionServer)

+ type GarbageCollectionClient interface

+ Retain func(ctx context.Context, in *RetainRequest, opts ...grpc.CallOption) (*RetainResponse, error)

+ func NewGarbageCollectionClient(cc *grpc.ClientConn) GarbageCollectionClient

+ type GarbageCollectionServer interface

+ Retain func(context.Context, *RetainRequest) (*RetainResponse, error)

type MetainfoClient

+ ProjectInfo func(ctx context.Context, in *ProjectInfoRequest, opts ...grpc.CallOption) (*ProjectInfoResponse, error)

+ SetAttribution func(ctx context.Context, in *SetAttributionRequest, opts ...grpc.CallOption) (*SetAttributionResponse, error)

type MetainfoServer

+ ProjectInfo func(context.Context, *ProjectInfoRequest) (*ProjectInfoResponse, error)

+ SetAttribution func(context.Context, *SetAttributionRequest) (*SetAttributionResponse, error)

type OrderLimit2

+ SatelliteAddress *NodeAddress

+ func (m *OrderLimit2) GetSatelliteAddress() *NodeAddress

+ type ProjectInfoRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ProjectInfoRequest) Descriptor() ([]byte, []int)

+ func (*ProjectInfoRequest) ProtoMessage()

+ func (m *ProjectInfoRequest) Reset()

+ func (m *ProjectInfoRequest) String() string

+ func (m *ProjectInfoRequest) XXX_DiscardUnknown()

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

+ func (m *ProjectInfoRequest) XXX_Merge(src proto.Message)

+ func (m *ProjectInfoRequest) XXX_Size() int

+ func (m *ProjectInfoRequest) XXX_Unmarshal(b []byte) error

+ type ProjectInfoResponse struct

+ ProjectSalt []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ProjectInfoResponse) Descriptor() ([]byte, []int)

+ func (*ProjectInfoResponse) ProtoMessage()

+ func (m *ProjectInfoResponse) GetProjectSalt() []byte

+ func (m *ProjectInfoResponse) Reset()

+ func (m *ProjectInfoResponse) String() string

+ func (m *ProjectInfoResponse) XXX_DiscardUnknown()

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

+ func (m *ProjectInfoResponse) XXX_Merge(src proto.Message)

+ func (m *ProjectInfoResponse) XXX_Size() int

+ func (m *ProjectInfoResponse) XXX_Unmarshal(b []byte) error

+ type RetainRequest struct

+ CreationDate time.Time

+ Filter []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RetainRequest) Descriptor() ([]byte, []int)

+ func (*RetainRequest) ProtoMessage()

+ func (m *RetainRequest) GetCreationDate() time.Time

+ func (m *RetainRequest) GetFilter() []byte

+ func (m *RetainRequest) Reset()

+ func (m *RetainRequest) String() string

+ func (m *RetainRequest) XXX_DiscardUnknown()

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

+ func (m *RetainRequest) XXX_Merge(src proto.Message)

+ func (m *RetainRequest) XXX_Size() int

+ func (m *RetainRequest) XXX_Unmarshal(b []byte) error

+ type RetainResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RetainResponse) Descriptor() ([]byte, []int)

+ func (*RetainResponse) ProtoMessage()

+ func (m *RetainResponse) Reset()

+ func (m *RetainResponse) String() string

+ func (m *RetainResponse) XXX_DiscardUnknown()

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

+ func (m *RetainResponse) XXX_Merge(src proto.Message)

+ func (m *RetainResponse) XXX_Size() int

+ func (m *RetainResponse) XXX_Unmarshal(b []byte) error

type SegmentHealth

+ HealthyIds []NodeID

+ OfflineIds []NodeID

+ UnhealthyIds []NodeID

+ type SetAttributionRequest struct

+ BucketName []byte

+ PartnerId []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetAttributionRequest) Descriptor() ([]byte, []int)

+ func (*SetAttributionRequest) ProtoMessage()

+ func (m *SetAttributionRequest) GetBucketName() []byte

+ func (m *SetAttributionRequest) GetPartnerId() []byte

+ func (m *SetAttributionRequest) Reset()

+ func (m *SetAttributionRequest) String() string

+ func (m *SetAttributionRequest) XXX_DiscardUnknown()

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

+ func (m *SetAttributionRequest) XXX_Merge(src proto.Message)

+ func (m *SetAttributionRequest) XXX_Size() int

+ func (m *SetAttributionRequest) XXX_Unmarshal(b []byte) error

+ type SetAttributionResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SetAttributionResponse) Descriptor() ([]byte, []int)

+ func (*SetAttributionResponse) ProtoMessage()

+ func (m *SetAttributionResponse) Reset()

+ func (m *SetAttributionResponse) String() string

+ func (m *SetAttributionResponse) XXX_DiscardUnknown()

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

+ func (m *SetAttributionResponse) XXX_Merge(src proto.Message)

+ func (m *SetAttributionResponse) XXX_Size() int

+ func (m *SetAttributionResponse) XXX_Unmarshal(b []byte) error

+ type VoucherResponse struct

+ Status VoucherResponse_Status

+ Voucher *Voucher

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*VoucherResponse) Descriptor() ([]byte, []int)

+ func (*VoucherResponse) ProtoMessage()

+ func (m *VoucherResponse) GetStatus() VoucherResponse_Status

+ func (m *VoucherResponse) GetVoucher() *Voucher

+ func (m *VoucherResponse) Reset()

+ func (m *VoucherResponse) String() string

+ func (m *VoucherResponse) XXX_DiscardUnknown()

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

+ func (m *VoucherResponse) XXX_Merge(src proto.Message)

+ func (m *VoucherResponse) XXX_Size() int

+ func (m *VoucherResponse) XXX_Unmarshal(b []byte) error

+ type VoucherResponse_Status int32

+ const VoucherResponse_ACCEPTED

+ const VoucherResponse_INVALID

+ const VoucherResponse_REJECTED

+ func (VoucherResponse_Status) EnumDescriptor() ([]byte, []int)

+ func (x VoucherResponse_Status) String() string

May 25, 2019

Changes in this version

+ func RegisterVouchersServer(s *grpc.Server, srv VouchersServer)

type Node

+ LastIp string

+ func (m *Node) GetLastIp() string

+ type Voucher struct

+ Expiration *timestamp.Timestamp

+ SatelliteId NodeID

+ SatelliteSignature []byte

+ StorageNodeId NodeID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Voucher) Descriptor() ([]byte, []int)

+ func (*Voucher) ProtoMessage()

+ func (m *Voucher) GetExpiration() *timestamp.Timestamp

+ func (m *Voucher) GetSatelliteSignature() []byte

+ func (m *Voucher) Reset()

+ func (m *Voucher) String() string

+ func (m *Voucher) XXX_DiscardUnknown()

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

+ func (m *Voucher) XXX_Merge(src proto.Message)

+ func (m *Voucher) XXX_Size() int

+ func (m *Voucher) XXX_Unmarshal(b []byte) error

+ type VoucherRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*VoucherRequest) Descriptor() ([]byte, []int)

+ func (*VoucherRequest) ProtoMessage()

+ func (m *VoucherRequest) Reset()

+ func (m *VoucherRequest) String() string

+ func (m *VoucherRequest) XXX_DiscardUnknown()

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

+ func (m *VoucherRequest) XXX_Merge(src proto.Message)

+ func (m *VoucherRequest) XXX_Size() int

+ func (m *VoucherRequest) XXX_Unmarshal(b []byte) error

+ type VouchersClient interface

+ Request func(ctx context.Context, in *VoucherRequest, opts ...grpc.CallOption) (*Voucher, error)

+ func NewVouchersClient(cc *grpc.ClientConn) VouchersClient

+ type VouchersServer interface

+ Request func(context.Context, *VoucherRequest) (*Voucher, error)

Apr 23, 2019

Changes in this version

+ type GetBucketListRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetBucketListRequest) Descriptor() ([]byte, []int)

+ func (*GetBucketListRequest) ProtoMessage()

+ func (m *GetBucketListRequest) Reset()

+ func (m *GetBucketListRequest) String() string

+ func (m *GetBucketListRequest) XXX_DiscardUnknown()

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

+ func (m *GetBucketListRequest) XXX_Merge(src proto.Message)

+ func (m *GetBucketListRequest) XXX_Size() int

+ func (m *GetBucketListRequest) XXX_Unmarshal(b []byte) error

+ type GetBucketListResponse struct

+ Buckets []*GetBucketListResponse_Bucket

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetBucketListResponse) Descriptor() ([]byte, []int)

+ func (*GetBucketListResponse) ProtoMessage()

+ func (m *GetBucketListResponse) GetBuckets() []*GetBucketListResponse_Bucket

+ func (m *GetBucketListResponse) Reset()

+ func (m *GetBucketListResponse) String() string

+ func (m *GetBucketListResponse) XXX_DiscardUnknown()

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

+ func (m *GetBucketListResponse) XXX_Merge(src proto.Message)

+ func (m *GetBucketListResponse) XXX_Size() int

+ func (m *GetBucketListResponse) XXX_Unmarshal(b []byte) error

+ type GetBucketListResponse_Bucket struct

+ BucketId NodeID

+ CachedNodes []*Node

+ RoutingNodes []*Node

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetBucketListResponse_Bucket) Descriptor() ([]byte, []int)

+ func (*GetBucketListResponse_Bucket) ProtoMessage()

+ func (m *GetBucketListResponse_Bucket) GetCachedNodes() []*Node

+ func (m *GetBucketListResponse_Bucket) GetRoutingNodes() []*Node

+ func (m *GetBucketListResponse_Bucket) Reset()

+ func (m *GetBucketListResponse_Bucket) String() string

+ func (m *GetBucketListResponse_Bucket) XXX_DiscardUnknown()

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

+ func (m *GetBucketListResponse_Bucket) XXX_Merge(src proto.Message)

+ func (m *GetBucketListResponse_Bucket) XXX_Size() int

+ func (m *GetBucketListResponse_Bucket) XXX_Unmarshal(b []byte) error

+ type GraphRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GraphRequest) Descriptor() ([]byte, []int)

+ func (*GraphRequest) ProtoMessage()

+ func (m *GraphRequest) Reset()

+ func (m *GraphRequest) String() string

+ func (m *GraphRequest) XXX_DiscardUnknown()

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

+ func (m *GraphRequest) XXX_Merge(src proto.Message)

+ func (m *GraphRequest) XXX_Size() int

+ func (m *GraphRequest) XXX_Unmarshal(b []byte) error

+ type GraphResponse struct

+ Graph [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GraphResponse) Descriptor() ([]byte, []int)

+ func (*GraphResponse) ProtoMessage()

+ func (m *GraphResponse) GetGraph() [][]byte

+ func (m *GraphResponse) Reset()

+ func (m *GraphResponse) String() string

+ func (m *GraphResponse) XXX_DiscardUnknown()

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

+ func (m *GraphResponse) XXX_Merge(src proto.Message)

+ func (m *GraphResponse) XXX_Size() int

+ func (m *GraphResponse) XXX_Unmarshal(b []byte) error

type KadInspectorClient

+ GetBucketList func(ctx context.Context, in *GetBucketListRequest, opts ...grpc.CallOption) (*GetBucketListResponse, error)

type KadInspectorServer

+ GetBucketList func(context.Context, *GetBucketListRequest) (*GetBucketListResponse, error)

Apr 10, 2019

Changes in this version

type NodeInfoResponse

+ Version *NodeVersion

+ func (m *NodeInfoResponse) GetVersion() *NodeVersion

type NodeStats

+ LastContactFailure *timestamp.Timestamp

+ LastContactSuccess *timestamp.Timestamp

+ func (m *NodeStats) GetLastContactFailure() *timestamp.Timestamp

+ func (m *NodeStats) GetLastContactSuccess() *timestamp.Timestamp

Apr 4, 2019

Changes in this version

type InfoResponse

+ Version *NodeVersion

+ func (m *InfoResponse) GetVersion() *NodeVersion

type Node

+ Version *NodeVersion

+ func (m *Node) GetVersion() *NodeVersion

+ type NodeVersion struct

+ CommitHash string

+ Release bool

+ Timestamp *timestamp.Timestamp

+ Version string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeVersion) Descriptor() ([]byte, []int)

+ func (*NodeVersion) ProtoMessage()

+ func (m *NodeVersion) GetCommitHash() string

+ func (m *NodeVersion) GetRelease() bool

+ func (m *NodeVersion) GetTimestamp() *timestamp.Timestamp

+ func (m *NodeVersion) GetVersion() string

+ func (m *NodeVersion) Reset()

+ func (m *NodeVersion) String() string

+ func (m *NodeVersion) XXX_DiscardUnknown()

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

+ func (m *NodeVersion) XXX_Merge(src proto.Message)

+ func (m *NodeVersion) XXX_Size() int

+ func (m *NodeVersion) XXX_Unmarshal(b []byte) error

Apr 3, 2019

Changes in this version

+ var AgreementsSummary_Status_name = map[int32]string

+ var AgreementsSummary_Status_value = map[string]int32

+ var BandwidthAction_name = map[int32]string

+ var BandwidthAction_value = map[string]int32

+ var ErrPayer = errs.Class("Payer agreement")

+ var ErrRenter = errs.Class("Renter agreement")

+ var NodeTransport_name = map[int32]string

+ var NodeTransport_value = map[string]int32

+ var NodeType_name = map[int32]string

+ var NodeType_value = map[string]int32

+ var PieceAction_name = map[int32]string

+ var PieceAction_value = map[string]int32

+ var Pointer_DataType_name = map[int32]string

+ var Pointer_DataType_value = map[string]int32

+ var RedundancyScheme_SchemeType_name = map[int32]string

+ var RedundancyScheme_SchemeType_value = map[string]int32

+ var Restriction_Operand_name = map[int32]string

+ var Restriction_Operand_value = map[string]int32

+ var Restriction_Operator_name = map[int32]string

+ var Restriction_Operator_value = map[string]int32

+ var SettlementResponse_Status_name = map[int32]string

+ var SettlementResponse_Status_value = map[string]int32

+ func AddressEqual(a1, a2 *NodeAddress) bool

+ func Equal(msg1, msg2 proto.Message) bool

+ func NodesToIDs(nodes []*Node) storj.NodeIDList

+ func RegisterBandwidthServer(s *grpc.Server, srv BandwidthServer)

+ func RegisterCertificatesServer(s *grpc.Server, srv CertificatesServer)

+ func RegisterHealthInspectorServer(s *grpc.Server, srv HealthInspectorServer)

+ func RegisterIrreparableInspectorServer(s *grpc.Server, srv IrreparableInspectorServer)

+ func RegisterKadInspectorServer(s *grpc.Server, srv KadInspectorServer)

+ func RegisterMetainfoServer(s *grpc.Server, srv MetainfoServer)

+ func RegisterNodesServer(s *grpc.Server, srv NodesServer)

+ func RegisterOrdersServer(s *grpc.Server, srv OrdersServer)

+ func RegisterOverlayInspectorServer(s *grpc.Server, srv OverlayInspectorServer)

+ func RegisterPieceStoreInspectorServer(s *grpc.Server, srv PieceStoreInspectorServer)

+ func RegisterPiecestoreServer(s *grpc.Server, srv PiecestoreServer)

+ type AddressedOrderLimit struct

+ Limit *OrderLimit2

+ StorageNodeAddress *NodeAddress

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AddressedOrderLimit) Descriptor() ([]byte, []int)

+ func (*AddressedOrderLimit) ProtoMessage()

+ func (m *AddressedOrderLimit) GetLimit() *OrderLimit2

+ func (m *AddressedOrderLimit) GetStorageNodeAddress() *NodeAddress

+ func (m *AddressedOrderLimit) Reset()

+ func (m *AddressedOrderLimit) String() string

+ func (m *AddressedOrderLimit) XXX_DiscardUnknown()

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

+ func (m *AddressedOrderLimit) XXX_Merge(src proto.Message)

+ func (m *AddressedOrderLimit) XXX_Size() int

+ func (m *AddressedOrderLimit) XXX_Unmarshal(b []byte) error

+ type AgreementsSummary struct

+ Status AgreementsSummary_Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AgreementsSummary) Descriptor() ([]byte, []int)

+ func (*AgreementsSummary) ProtoMessage()

+ func (m *AgreementsSummary) GetStatus() AgreementsSummary_Status

+ func (m *AgreementsSummary) Reset()

+ func (m *AgreementsSummary) String() string

+ func (m *AgreementsSummary) XXX_DiscardUnknown()

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

+ func (m *AgreementsSummary) XXX_Merge(src proto.Message)

+ func (m *AgreementsSummary) XXX_Size() int

+ func (m *AgreementsSummary) XXX_Unmarshal(b []byte) error

+ type AgreementsSummary_Status int32

+ const AgreementsSummary_FAIL

+ const AgreementsSummary_OK

+ const AgreementsSummary_REJECTED

+ func (AgreementsSummary_Status) EnumDescriptor() ([]byte, []int)

+ func (x AgreementsSummary_Status) String() string

+ type BandwidthAction int32

+ const BandwidthAction_GET

+ const BandwidthAction_GET_AUDIT

+ const BandwidthAction_GET_REPAIR

+ const BandwidthAction_PUT

+ const BandwidthAction_PUT_REPAIR

+ func (BandwidthAction) EnumDescriptor() ([]byte, []int)

+ func (x BandwidthAction) String() string

+ type BandwidthClient interface

+ BandwidthAgreements func(ctx context.Context, in *RenterBandwidthAllocation, opts ...grpc.CallOption) (*AgreementsSummary, error)

+ Settlement func(ctx context.Context, opts ...grpc.CallOption) (Bandwidth_SettlementClient, error)

+ func NewBandwidthClient(cc *grpc.ClientConn) BandwidthClient

+ type BandwidthServer interface

+ BandwidthAgreements func(context.Context, *RenterBandwidthAllocation) (*AgreementsSummary, error)

+ Settlement func(Bandwidth_SettlementServer) error

+ type BandwidthSettlementRequest struct

+ Allocation *RenterBandwidthAllocation

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BandwidthSettlementRequest) Descriptor() ([]byte, []int)

+ func (*BandwidthSettlementRequest) ProtoMessage()

+ func (m *BandwidthSettlementRequest) GetAllocation() *RenterBandwidthAllocation

+ func (m *BandwidthSettlementRequest) Reset()

+ func (m *BandwidthSettlementRequest) String() string

+ func (m *BandwidthSettlementRequest) XXX_DiscardUnknown()

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

+ func (m *BandwidthSettlementRequest) XXX_Merge(src proto.Message)

+ func (m *BandwidthSettlementRequest) XXX_Size() int

+ func (m *BandwidthSettlementRequest) XXX_Unmarshal(b []byte) error

+ type BandwidthSettlementResponse struct

+ SerialNumber string

+ Status AgreementsSummary_Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BandwidthSettlementResponse) Descriptor() ([]byte, []int)

+ func (*BandwidthSettlementResponse) ProtoMessage()

+ func (m *BandwidthSettlementResponse) GetSerialNumber() string

+ func (m *BandwidthSettlementResponse) GetStatus() AgreementsSummary_Status

+ func (m *BandwidthSettlementResponse) Reset()

+ func (m *BandwidthSettlementResponse) String() string

+ func (m *BandwidthSettlementResponse) XXX_DiscardUnknown()

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

+ func (m *BandwidthSettlementResponse) XXX_Merge(src proto.Message)

+ func (m *BandwidthSettlementResponse) XXX_Size() int

+ func (m *BandwidthSettlementResponse) XXX_Unmarshal(b []byte) error

+ type Bandwidth_SettlementClient interface

+ Recv func() (*BandwidthSettlementResponse, error)

+ Send func(*BandwidthSettlementRequest) error

+ type Bandwidth_SettlementServer interface

+ Recv func() (*BandwidthSettlementRequest, error)

+ Send func(*BandwidthSettlementResponse) error

+ type Bucket struct

+ Nodes []*Node

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Bucket) Descriptor() ([]byte, []int)

+ func (*Bucket) ProtoMessage()

+ func (m *Bucket) GetNodes() []*Node

+ func (m *Bucket) Reset()

+ func (m *Bucket) String() string

+ func (m *Bucket) XXX_DiscardUnknown()

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

+ func (m *Bucket) XXX_Merge(src proto.Message)

+ func (m *Bucket) XXX_Size() int

+ func (m *Bucket) XXX_Unmarshal(b []byte) error

+ type BucketList struct

+ Nodes []*Node

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*BucketList) Descriptor() ([]byte, []int)

+ func (*BucketList) ProtoMessage()

+ func (m *BucketList) GetNodes() []*Node

+ func (m *BucketList) Reset()

+ func (m *BucketList) String() string

+ func (m *BucketList) XXX_DiscardUnknown()

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

+ func (m *BucketList) XXX_Merge(src proto.Message)

+ func (m *BucketList) XXX_Size() int

+ func (m *BucketList) XXX_Unmarshal(b []byte) error

+ type CertificatesClient interface

+ Sign func(ctx context.Context, in *SigningRequest, opts ...grpc.CallOption) (*SigningResponse, error)

+ func NewCertificatesClient(cc *grpc.ClientConn) CertificatesClient

+ type CertificatesServer interface

+ Sign func(context.Context, *SigningRequest) (*SigningResponse, error)

+ type CountNodesRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 struct

+ Count int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CountNodesResponse) Descriptor() ([]byte, []int)

+ func (*CountNodesResponse) ProtoMessage()

+ func (m *CountNodesResponse) GetCount() int64

+ 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 CreateStatsRequest struct

+ AuditCount int64

+ AuditSuccessCount int64

+ NodeId NodeID

+ UptimeCount int64

+ UptimeSuccessCount int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateStatsRequest) Descriptor() ([]byte, []int)

+ func (*CreateStatsRequest) ProtoMessage()

+ func (m *CreateStatsRequest) GetAuditCount() int64

+ func (m *CreateStatsRequest) GetAuditSuccessCount() int64

+ func (m *CreateStatsRequest) GetUptimeCount() int64

+ func (m *CreateStatsRequest) GetUptimeSuccessCount() int64

+ func (m *CreateStatsRequest) Reset()

+ func (m *CreateStatsRequest) String() string

+ func (m *CreateStatsRequest) XXX_DiscardUnknown()

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

+ func (m *CreateStatsRequest) XXX_Merge(src proto.Message)

+ func (m *CreateStatsRequest) XXX_Size() int

+ func (m *CreateStatsRequest) XXX_Unmarshal(b []byte) error

+ type CreateStatsResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*CreateStatsResponse) Descriptor() ([]byte, []int)

+ func (*CreateStatsResponse) ProtoMessage()

+ func (m *CreateStatsResponse) Reset()

+ func (m *CreateStatsResponse) String() string

+ func (m *CreateStatsResponse) XXX_DiscardUnknown()

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

+ func (m *CreateStatsResponse) XXX_Merge(src proto.Message)

+ func (m *CreateStatsResponse) XXX_Size() int

+ func (m *CreateStatsResponse) XXX_Unmarshal(b []byte) error

+ type DashboardRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DashboardRequest) Descriptor() ([]byte, []int)

+ func (*DashboardRequest) ProtoMessage()

+ func (m *DashboardRequest) Reset()

+ func (m *DashboardRequest) String() string

+ func (m *DashboardRequest) XXX_DiscardUnknown()

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

+ func (m *DashboardRequest) XXX_Merge(src proto.Message)

+ func (m *DashboardRequest) XXX_Size() int

+ func (m *DashboardRequest) XXX_Unmarshal(b []byte) error

+ type DashboardResponse struct

+ BootstrapAddress string

+ ExternalAddress string

+ InternalAddress string

+ LastPinged *timestamp.Timestamp

+ LastQueried *timestamp.Timestamp

+ NodeConnections int64

+ NodeId NodeID

+ Stats *StatSummaryResponse

+ Uptime *duration.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DashboardResponse) Descriptor() ([]byte, []int)

+ func (*DashboardResponse) ProtoMessage()

+ func (m *DashboardResponse) GetBootstrapAddress() string

+ func (m *DashboardResponse) GetExternalAddress() string

+ func (m *DashboardResponse) GetInternalAddress() string

+ func (m *DashboardResponse) GetLastPinged() *timestamp.Timestamp

+ func (m *DashboardResponse) GetLastQueried() *timestamp.Timestamp

+ func (m *DashboardResponse) GetNodeConnections() int64

+ func (m *DashboardResponse) GetStats() *StatSummaryResponse

+ func (m *DashboardResponse) GetUptime() *duration.Duration

+ func (m *DashboardResponse) Reset()

+ func (m *DashboardResponse) String() string

+ func (m *DashboardResponse) XXX_DiscardUnknown()

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

+ func (m *DashboardResponse) XXX_Merge(src proto.Message)

+ func (m *DashboardResponse) XXX_Size() int

+ func (m *DashboardResponse) XXX_Unmarshal(b []byte) error

+ type DumpNodesRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ 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 struct

+ Nodes []*Node

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DumpNodesResponse) Descriptor() ([]byte, []int)

+ func (*DumpNodesResponse) ProtoMessage()

+ func (m *DumpNodesResponse) GetNodes() []*Node

+ 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 FindNearRequest struct

+ Id NodeID

+ Limit int64

+ Start NodeID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FindNearRequest) Descriptor() ([]byte, []int)

+ func (*FindNearRequest) ProtoMessage()

+ func (m *FindNearRequest) GetLimit() int64

+ func (m *FindNearRequest) Reset()

+ func (m *FindNearRequest) String() string

+ func (m *FindNearRequest) XXX_DiscardUnknown()

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

+ func (m *FindNearRequest) XXX_Merge(src proto.Message)

+ func (m *FindNearRequest) XXX_Size() int

+ func (m *FindNearRequest) XXX_Unmarshal(b []byte) error

+ type FindNearResponse struct

+ Nodes []*Node

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FindNearResponse) Descriptor() ([]byte, []int)

+ func (*FindNearResponse) ProtoMessage()

+ func (m *FindNearResponse) GetNodes() []*Node

+ func (m *FindNearResponse) Reset()

+ func (m *FindNearResponse) String() string

+ func (m *FindNearResponse) XXX_DiscardUnknown()

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

+ func (m *FindNearResponse) XXX_Merge(src proto.Message)

+ func (m *FindNearResponse) XXX_Size() int

+ func (m *FindNearResponse) XXX_Unmarshal(b []byte) error

+ type GetBucketRequest struct

+ Id NodeID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetBucketRequest) Descriptor() ([]byte, []int)

+ func (*GetBucketRequest) ProtoMessage()

+ func (m *GetBucketRequest) Reset()

+ func (m *GetBucketRequest) String() string

+ func (m *GetBucketRequest) XXX_DiscardUnknown()

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

+ func (m *GetBucketRequest) XXX_Merge(src proto.Message)

+ func (m *GetBucketRequest) XXX_Size() int

+ func (m *GetBucketRequest) XXX_Unmarshal(b []byte) error

+ type GetBucketResponse struct

+ Id NodeID

+ Nodes []*Node

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetBucketResponse) Descriptor() ([]byte, []int)

+ func (*GetBucketResponse) ProtoMessage()

+ func (m *GetBucketResponse) GetNodes() []*Node

+ func (m *GetBucketResponse) Reset()

+ func (m *GetBucketResponse) String() string

+ func (m *GetBucketResponse) XXX_DiscardUnknown()

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

+ func (m *GetBucketResponse) XXX_Merge(src proto.Message)

+ func (m *GetBucketResponse) XXX_Size() int

+ func (m *GetBucketResponse) XXX_Unmarshal(b []byte) error

+ type GetBucketsRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetBucketsRequest) Descriptor() ([]byte, []int)

+ func (*GetBucketsRequest) ProtoMessage()

+ func (m *GetBucketsRequest) Reset()

+ func (m *GetBucketsRequest) String() string

+ func (m *GetBucketsRequest) XXX_DiscardUnknown()

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

+ func (m *GetBucketsRequest) XXX_Merge(src proto.Message)

+ func (m *GetBucketsRequest) XXX_Size() int

+ func (m *GetBucketsRequest) XXX_Unmarshal(b []byte) error

+ type GetBucketsResponse struct

+ Ids []NodeID

+ Total int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetBucketsResponse) Descriptor() ([]byte, []int)

+ func (*GetBucketsResponse) ProtoMessage()

+ func (m *GetBucketsResponse) GetTotal() int64

+ func (m *GetBucketsResponse) Reset()

+ func (m *GetBucketsResponse) String() string

+ func (m *GetBucketsResponse) XXX_DiscardUnknown()

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

+ func (m *GetBucketsResponse) XXX_Merge(src proto.Message)

+ func (m *GetBucketsResponse) XXX_Size() int

+ func (m *GetBucketsResponse) XXX_Unmarshal(b []byte) error

+ type GetStatsRequest struct

+ NodeId NodeID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetStatsRequest) Descriptor() ([]byte, []int)

+ func (*GetStatsRequest) ProtoMessage()

+ func (m *GetStatsRequest) Reset()

+ func (m *GetStatsRequest) String() string

+ func (m *GetStatsRequest) XXX_DiscardUnknown()

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

+ func (m *GetStatsRequest) XXX_Merge(src proto.Message)

+ func (m *GetStatsRequest) XXX_Size() int

+ func (m *GetStatsRequest) XXX_Unmarshal(b []byte) error

+ type GetStatsResponse struct

+ AuditCount int64

+ AuditRatio float64

+ UptimeCount int64

+ UptimeRatio float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GetStatsResponse) Descriptor() ([]byte, []int)

+ func (*GetStatsResponse) ProtoMessage()

+ func (m *GetStatsResponse) GetAuditCount() int64

+ func (m *GetStatsResponse) GetAuditRatio() float64

+ func (m *GetStatsResponse) GetUptimeCount() int64

+ func (m *GetStatsResponse) GetUptimeRatio() float64

+ func (m *GetStatsResponse) Reset()

+ func (m *GetStatsResponse) String() string

+ func (m *GetStatsResponse) XXX_DiscardUnknown()

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

+ func (m *GetStatsResponse) XXX_Merge(src proto.Message)

+ func (m *GetStatsResponse) XXX_Size() int

+ func (m *GetStatsResponse) XXX_Unmarshal(b []byte) error

+ type HealthInspectorClient interface

+ ObjectHealth func(ctx context.Context, in *ObjectHealthRequest, opts ...grpc.CallOption) (*ObjectHealthResponse, error)

+ SegmentHealth func(ctx context.Context, in *SegmentHealthRequest, opts ...grpc.CallOption) (*SegmentHealthResponse, error)

+ func NewHealthInspectorClient(cc *grpc.ClientConn) HealthInspectorClient

+ type HealthInspectorServer interface

+ ObjectHealth func(context.Context, *ObjectHealthRequest) (*ObjectHealthResponse, error)

+ SegmentHealth func(context.Context, *SegmentHealthRequest) (*SegmentHealthResponse, error)

+ type InfoRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*InfoRequest) Descriptor() ([]byte, []int)

+ func (*InfoRequest) ProtoMessage()

+ func (m *InfoRequest) Reset()

+ func (m *InfoRequest) String() string

+ func (m *InfoRequest) XXX_DiscardUnknown()

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

+ func (m *InfoRequest) XXX_Merge(src proto.Message)

+ func (m *InfoRequest) XXX_Size() int

+ func (m *InfoRequest) XXX_Unmarshal(b []byte) error

+ type InfoResponse struct

+ Capacity *NodeCapacity

+ Operator *NodeOperator

+ Type NodeType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*InfoResponse) Descriptor() ([]byte, []int)

+ func (*InfoResponse) ProtoMessage()

+ func (m *InfoResponse) GetCapacity() *NodeCapacity

+ func (m *InfoResponse) GetOperator() *NodeOperator

+ func (m *InfoResponse) GetType() NodeType

+ func (m *InfoResponse) Reset()

+ func (m *InfoResponse) String() string

+ func (m *InfoResponse) XXX_DiscardUnknown()

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

+ func (m *InfoResponse) XXX_Merge(src proto.Message)

+ func (m *InfoResponse) XXX_Size() int

+ func (m *InfoResponse) XXX_Unmarshal(b []byte) error

+ type InjuredSegment struct

+ LostPieces []int32

+ Path string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*InjuredSegment) Descriptor() ([]byte, []int)

+ func (*InjuredSegment) ProtoMessage()

+ func (m *InjuredSegment) GetLostPieces() []int32

+ func (m *InjuredSegment) GetPath() string

+ func (m *InjuredSegment) Reset()

+ func (m *InjuredSegment) String() string

+ 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

+ func (n *InjuredSegment) Scan(value interface{}) error

+ func (n InjuredSegment) Value() (driver.Value, error)

+ type IrreparableInspectorClient interface

+ ListIrreparableSegments func(ctx context.Context, in *ListIrreparableSegmentsRequest, ...) (*ListIrreparableSegmentsResponse, error)

+ func NewIrreparableInspectorClient(cc *grpc.ClientConn) IrreparableInspectorClient

+ type IrreparableInspectorServer interface

+ ListIrreparableSegments func(context.Context, *ListIrreparableSegmentsRequest) (*ListIrreparableSegmentsResponse, error)

+ type IrreparableSegment struct

+ LastRepairAttempt int64

+ LostPieces int32

+ Path []byte

+ RepairAttemptCount int64

+ SegmentDetail *Pointer

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IrreparableSegment) Descriptor() ([]byte, []int)

+ func (*IrreparableSegment) ProtoMessage()

+ func (m *IrreparableSegment) GetLastRepairAttempt() int64

+ func (m *IrreparableSegment) GetLostPieces() int32

+ func (m *IrreparableSegment) GetPath() []byte

+ func (m *IrreparableSegment) GetRepairAttemptCount() int64

+ func (m *IrreparableSegment) GetSegmentDetail() *Pointer

+ 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 KadInspectorClient interface

+ CountNodes func(ctx context.Context, in *CountNodesRequest, opts ...grpc.CallOption) (*CountNodesResponse, error)

+ DumpNodes func(ctx context.Context, in *DumpNodesRequest, opts ...grpc.CallOption) (*DumpNodesResponse, error)

+ FindNear func(ctx context.Context, in *FindNearRequest, opts ...grpc.CallOption) (*FindNearResponse, error)

+ LookupNode func(ctx context.Context, in *LookupNodeRequest, opts ...grpc.CallOption) (*LookupNodeResponse, error)

+ NodeInfo func(ctx context.Context, in *NodeInfoRequest, opts ...grpc.CallOption) (*NodeInfoResponse, error)

+ PingNode func(ctx context.Context, in *PingNodeRequest, opts ...grpc.CallOption) (*PingNodeResponse, error)

+ func NewKadInspectorClient(cc *grpc.ClientConn) KadInspectorClient

+ type KadInspectorServer interface

+ CountNodes func(context.Context, *CountNodesRequest) (*CountNodesResponse, error)

+ DumpNodes func(context.Context, *DumpNodesRequest) (*DumpNodesResponse, error)

+ FindNear func(context.Context, *FindNearRequest) (*FindNearResponse, error)

+ LookupNode func(context.Context, *LookupNodeRequest) (*LookupNodeResponse, error)

+ NodeInfo func(context.Context, *NodeInfoRequest) (*NodeInfoResponse, error)

+ PingNode func(context.Context, *PingNodeRequest) (*PingNodeResponse, error)

+ type ListIrreparableSegmentsRequest struct

+ Limit int32

+ Offset int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListIrreparableSegmentsRequest) Descriptor() ([]byte, []int)

+ func (*ListIrreparableSegmentsRequest) ProtoMessage()

+ func (m *ListIrreparableSegmentsRequest) GetLimit() int32

+ func (m *ListIrreparableSegmentsRequest) GetOffset() int32

+ 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 struct

+ Segments []*IrreparableSegment

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListIrreparableSegmentsResponse) Descriptor() ([]byte, []int)

+ func (*ListIrreparableSegmentsResponse) ProtoMessage()

+ func (m *ListIrreparableSegmentsResponse) GetSegments() []*IrreparableSegment

+ 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 ListResponse struct

+ Items []*ListResponse_Item

+ More bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListResponse) Descriptor() ([]byte, []int)

+ func (*ListResponse) ProtoMessage()

+ func (m *ListResponse) GetItems() []*ListResponse_Item

+ func (m *ListResponse) GetMore() bool

+ func (m *ListResponse) Reset()

+ func (m *ListResponse) String() string

+ func (m *ListResponse) XXX_DiscardUnknown()

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

+ func (m *ListResponse) XXX_Merge(src proto.Message)

+ func (m *ListResponse) XXX_Size() int

+ func (m *ListResponse) XXX_Unmarshal(b []byte) error

+ type ListResponse_Item struct

+ IsPrefix bool

+ Path string

+ Pointer *Pointer

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListResponse_Item) Descriptor() ([]byte, []int)

+ func (*ListResponse_Item) ProtoMessage()

+ func (m *ListResponse_Item) GetIsPrefix() bool

+ func (m *ListResponse_Item) GetPath() string

+ func (m *ListResponse_Item) GetPointer() *Pointer

+ func (m *ListResponse_Item) Reset()

+ func (m *ListResponse_Item) String() string

+ func (m *ListResponse_Item) XXX_DiscardUnknown()

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

+ func (m *ListResponse_Item) XXX_Merge(src proto.Message)

+ func (m *ListResponse_Item) XXX_Size() int

+ func (m *ListResponse_Item) XXX_Unmarshal(b []byte) error

+ type ListSegmentsRequest struct

+ Bucket []byte

+ EndBefore []byte

+ Limit int32

+ MetaFlags uint32

+ Prefix []byte

+ Recursive bool

+ StartAfter []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListSegmentsRequest) Descriptor() ([]byte, []int)

+ func (*ListSegmentsRequest) ProtoMessage()

+ func (m *ListSegmentsRequest) GetBucket() []byte

+ func (m *ListSegmentsRequest) GetEndBefore() []byte

+ func (m *ListSegmentsRequest) GetLimit() int32

+ func (m *ListSegmentsRequest) GetMetaFlags() uint32

+ func (m *ListSegmentsRequest) GetPrefix() []byte

+ func (m *ListSegmentsRequest) GetRecursive() bool

+ func (m *ListSegmentsRequest) GetStartAfter() []byte

+ func (m *ListSegmentsRequest) Reset()

+ func (m *ListSegmentsRequest) String() string

+ func (m *ListSegmentsRequest) XXX_DiscardUnknown()

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

+ func (m *ListSegmentsRequest) XXX_Merge(src proto.Message)

+ func (m *ListSegmentsRequest) XXX_Size() int

+ func (m *ListSegmentsRequest) XXX_Unmarshal(b []byte) error

+ type ListSegmentsResponse struct

+ Items []*ListSegmentsResponse_Item

+ More bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListSegmentsResponse) Descriptor() ([]byte, []int)

+ func (*ListSegmentsResponse) ProtoMessage()

+ func (m *ListSegmentsResponse) GetItems() []*ListSegmentsResponse_Item

+ func (m *ListSegmentsResponse) GetMore() bool

+ func (m *ListSegmentsResponse) Reset()

+ func (m *ListSegmentsResponse) String() string

+ func (m *ListSegmentsResponse) XXX_DiscardUnknown()

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

+ func (m *ListSegmentsResponse) XXX_Merge(src proto.Message)

+ func (m *ListSegmentsResponse) XXX_Size() int

+ func (m *ListSegmentsResponse) XXX_Unmarshal(b []byte) error

+ type ListSegmentsResponse_Item struct

+ IsPrefix bool

+ Path []byte

+ Pointer *Pointer

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ListSegmentsResponse_Item) Descriptor() ([]byte, []int)

+ func (*ListSegmentsResponse_Item) ProtoMessage()

+ func (m *ListSegmentsResponse_Item) GetIsPrefix() bool

+ func (m *ListSegmentsResponse_Item) GetPath() []byte

+ func (m *ListSegmentsResponse_Item) GetPointer() *Pointer

+ func (m *ListSegmentsResponse_Item) Reset()

+ func (m *ListSegmentsResponse_Item) String() string

+ func (m *ListSegmentsResponse_Item) XXX_DiscardUnknown()

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

+ func (m *ListSegmentsResponse_Item) XXX_Merge(src proto.Message)

+ func (m *ListSegmentsResponse_Item) XXX_Size() int

+ func (m *ListSegmentsResponse_Item) XXX_Unmarshal(b []byte) error

+ type LookupNodeRequest struct

+ Address string

+ Id string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LookupNodeRequest) Descriptor() ([]byte, []int)

+ func (*LookupNodeRequest) ProtoMessage()

+ func (m *LookupNodeRequest) GetAddress() string

+ func (m *LookupNodeRequest) GetId() string

+ func (m *LookupNodeRequest) Reset()

+ func (m *LookupNodeRequest) String() string

+ func (m *LookupNodeRequest) XXX_DiscardUnknown()

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

+ func (m *LookupNodeRequest) XXX_Merge(src proto.Message)

+ func (m *LookupNodeRequest) XXX_Size() int

+ func (m *LookupNodeRequest) XXX_Unmarshal(b []byte) error

+ type LookupNodeResponse struct

+ Meta *NodeMetadata

+ Node *Node

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LookupNodeResponse) Descriptor() ([]byte, []int)

+ func (*LookupNodeResponse) ProtoMessage()

+ func (m *LookupNodeResponse) GetMeta() *NodeMetadata

+ func (m *LookupNodeResponse) GetNode() *Node

+ func (m *LookupNodeResponse) Reset()

+ func (m *LookupNodeResponse) String() string

+ func (m *LookupNodeResponse) XXX_DiscardUnknown()

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

+ func (m *LookupNodeResponse) XXX_Merge(src proto.Message)

+ func (m *LookupNodeResponse) XXX_Size() int

+ func (m *LookupNodeResponse) XXX_Unmarshal(b []byte) error

+ type MetainfoClient interface

+ CommitSegment func(ctx context.Context, in *SegmentCommitRequest, opts ...grpc.CallOption) (*SegmentCommitResponse, error)

+ CreateSegment func(ctx context.Context, in *SegmentWriteRequest, opts ...grpc.CallOption) (*SegmentWriteResponse, error)

+ DeleteSegment func(ctx context.Context, in *SegmentDeleteRequest, opts ...grpc.CallOption) (*SegmentDeleteResponse, error)

+ DownloadSegment func(ctx context.Context, in *SegmentDownloadRequest, opts ...grpc.CallOption) (*SegmentDownloadResponse, error)

+ ListSegments func(ctx context.Context, in *ListSegmentsRequest, opts ...grpc.CallOption) (*ListSegmentsResponse, error)

+ SegmentInfo func(ctx context.Context, in *SegmentInfoRequest, opts ...grpc.CallOption) (*SegmentInfoResponse, error)

+ func NewMetainfoClient(cc *grpc.ClientConn) MetainfoClient

+ type MetainfoServer interface

+ CommitSegment func(context.Context, *SegmentCommitRequest) (*SegmentCommitResponse, error)

+ CreateSegment func(context.Context, *SegmentWriteRequest) (*SegmentWriteResponse, error)

+ DeleteSegment func(context.Context, *SegmentDeleteRequest) (*SegmentDeleteResponse, error)

+ DownloadSegment func(context.Context, *SegmentDownloadRequest) (*SegmentDownloadResponse, error)

+ ListSegments func(context.Context, *ListSegmentsRequest) (*ListSegmentsResponse, error)

+ SegmentInfo func(context.Context, *SegmentInfoRequest) (*SegmentInfoResponse, error)

+ type Node struct

+ Address *NodeAddress

+ AuditSuccess bool

+ Id NodeID

+ IsUp bool

+ LatencyList []int64

+ Metadata *NodeMetadata

+ Reputation *NodeStats

+ Restrictions *NodeRestrictions

+ Type NodeType

+ UpdateAuditSuccess bool

+ UpdateLatency bool

+ UpdateUptime bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func CopyNode(src *Node) (dst *Node)

+ func (*Node) Descriptor() ([]byte, []int)

+ func (*Node) ProtoMessage()

+ func (m *Node) GetAddress() *NodeAddress

+ func (m *Node) GetAuditSuccess() bool

+ func (m *Node) GetIsUp() bool

+ func (m *Node) GetLatencyList() []int64

+ func (m *Node) GetMetadata() *NodeMetadata

+ func (m *Node) GetReputation() *NodeStats

+ func (m *Node) GetRestrictions() *NodeRestrictions

+ func (m *Node) GetType() NodeType

+ func (m *Node) GetUpdateAuditSuccess() bool

+ func (m *Node) GetUpdateLatency() bool

+ func (m *Node) GetUpdateUptime() bool

+ func (m *Node) Reset()

+ func (m *Node) String() string

+ func (m *Node) XXX_DiscardUnknown()

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

+ func (m *Node) XXX_Merge(src proto.Message)

+ func (m *Node) XXX_Size() int

+ func (m *Node) XXX_Unmarshal(b []byte) error

+ type NodeAddress struct

+ Address string

+ Transport NodeTransport

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeAddress) Descriptor() ([]byte, []int)

+ func (*NodeAddress) ProtoMessage()

+ func (m *NodeAddress) GetAddress() string

+ func (m *NodeAddress) GetTransport() NodeTransport

+ func (m *NodeAddress) Reset()

+ func (m *NodeAddress) String() string

+ func (m *NodeAddress) XXX_DiscardUnknown()

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

+ func (m *NodeAddress) XXX_Merge(src proto.Message)

+ func (m *NodeAddress) XXX_Size() int

+ func (m *NodeAddress) XXX_Unmarshal(b []byte) error

+ type NodeCapacity struct

+ FreeBandwidth int64

+ FreeDisk int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeCapacity) Descriptor() ([]byte, []int)

+ func (*NodeCapacity) ProtoMessage()

+ func (m *NodeCapacity) GetFreeBandwidth() int64

+ func (m *NodeCapacity) GetFreeDisk() int64

+ func (m *NodeCapacity) Reset()

+ func (m *NodeCapacity) String() string

+ func (m *NodeCapacity) XXX_DiscardUnknown()

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

+ func (m *NodeCapacity) XXX_Merge(src proto.Message)

+ func (m *NodeCapacity) XXX_Size() int

+ func (m *NodeCapacity) XXX_Unmarshal(b []byte) error

+ type NodeID = storj.NodeID

+ type NodeIDList = storj.NodeIDList

+ type NodeInfoRequest struct

+ Address *NodeAddress

+ Id NodeID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeInfoRequest) Descriptor() ([]byte, []int)

+ func (*NodeInfoRequest) ProtoMessage()

+ func (m *NodeInfoRequest) GetAddress() *NodeAddress

+ func (m *NodeInfoRequest) Reset()

+ func (m *NodeInfoRequest) String() string

+ func (m *NodeInfoRequest) XXX_DiscardUnknown()

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

+ func (m *NodeInfoRequest) XXX_Merge(src proto.Message)

+ func (m *NodeInfoRequest) XXX_Size() int

+ func (m *NodeInfoRequest) XXX_Unmarshal(b []byte) error

+ type NodeInfoResponse struct

+ Capacity *NodeCapacity

+ Operator *NodeOperator

+ Type NodeType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeInfoResponse) Descriptor() ([]byte, []int)

+ func (*NodeInfoResponse) ProtoMessage()

+ func (m *NodeInfoResponse) GetCapacity() *NodeCapacity

+ func (m *NodeInfoResponse) GetOperator() *NodeOperator

+ func (m *NodeInfoResponse) GetType() NodeType

+ func (m *NodeInfoResponse) Reset()

+ func (m *NodeInfoResponse) String() string

+ func (m *NodeInfoResponse) XXX_DiscardUnknown()

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

+ func (m *NodeInfoResponse) XXX_Merge(src proto.Message)

+ func (m *NodeInfoResponse) XXX_Size() int

+ func (m *NodeInfoResponse) XXX_Unmarshal(b []byte) error

+ type NodeMetadata struct

+ Email string

+ Wallet string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeMetadata) Descriptor() ([]byte, []int)

+ func (*NodeMetadata) ProtoMessage()

+ func (m *NodeMetadata) GetEmail() string

+ func (m *NodeMetadata) GetWallet() string

+ func (m *NodeMetadata) Reset()

+ func (m *NodeMetadata) String() string

+ func (m *NodeMetadata) XXX_DiscardUnknown()

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

+ func (m *NodeMetadata) XXX_Merge(src proto.Message)

+ func (m *NodeMetadata) XXX_Size() int

+ func (m *NodeMetadata) XXX_Unmarshal(b []byte) error

+ type NodeOperator struct

+ Email string

+ Wallet string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeOperator) Descriptor() ([]byte, []int)

+ func (*NodeOperator) ProtoMessage()

+ func (m *NodeOperator) GetEmail() string

+ func (m *NodeOperator) GetWallet() string

+ func (m *NodeOperator) Reset()

+ func (m *NodeOperator) String() string

+ func (m *NodeOperator) XXX_DiscardUnknown()

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

+ func (m *NodeOperator) XXX_Merge(src proto.Message)

+ func (m *NodeOperator) XXX_Size() int

+ func (m *NodeOperator) XXX_Unmarshal(b []byte) error

+ type NodeRestrictions struct

+ FreeBandwidth int64

+ FreeDisk int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeRestrictions) Descriptor() ([]byte, []int)

+ func (*NodeRestrictions) ProtoMessage()

+ func (m *NodeRestrictions) GetFreeBandwidth() int64

+ func (m *NodeRestrictions) GetFreeDisk() int64

+ func (m *NodeRestrictions) Reset()

+ func (m *NodeRestrictions) String() string

+ func (m *NodeRestrictions) XXX_DiscardUnknown()

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

+ func (m *NodeRestrictions) XXX_Merge(src proto.Message)

+ func (m *NodeRestrictions) XXX_Size() int

+ func (m *NodeRestrictions) XXX_Unmarshal(b []byte) error

+ type NodeStats struct

+ AuditCount int64

+ AuditSuccessCount int64

+ AuditSuccessRatio float64

+ Latency_90 int64

+ NodeId NodeID

+ UptimeCount int64

+ UptimeRatio float64

+ UptimeSuccessCount int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*NodeStats) Descriptor() ([]byte, []int)

+ func (*NodeStats) ProtoMessage()

+ func (m *NodeStats) GetAuditCount() int64

+ func (m *NodeStats) GetAuditSuccessCount() int64

+ func (m *NodeStats) GetAuditSuccessRatio() float64

+ func (m *NodeStats) GetLatency_90() int64

+ func (m *NodeStats) GetUptimeCount() int64

+ func (m *NodeStats) GetUptimeRatio() float64

+ func (m *NodeStats) GetUptimeSuccessCount() int64

+ func (m *NodeStats) Reset()

+ func (m *NodeStats) String() string

+ func (m *NodeStats) XXX_DiscardUnknown()

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

+ func (m *NodeStats) XXX_Merge(src proto.Message)

+ func (m *NodeStats) XXX_Size() int

+ func (m *NodeStats) XXX_Unmarshal(b []byte) error

+ type NodeTransport int32

+ const NodeTransport_TCP_TLS_GRPC

+ func (NodeTransport) EnumDescriptor() ([]byte, []int)

+ func (x NodeTransport) String() string

+ type NodeType int32

+ const NodeType_BOOTSTRAP

+ const NodeType_INVALID

+ const NodeType_SATELLITE

+ const NodeType_STORAGE

+ const NodeType_UPLINK

+ func (NodeType) EnumDescriptor() ([]byte, []int)

+ func (nt NodeType) DPanicOnInvalid(from string)

+ func (x NodeType) String() string

+ type NodesClient interface

+ Ping func(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)

+ Query func(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)

+ RequestInfo func(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)

+ func NewNodesClient(cc *grpc.ClientConn) NodesClient

+ type NodesServer interface

+ Ping func(context.Context, *PingRequest) (*PingResponse, error)

+ Query func(context.Context, *QueryRequest) (*QueryResponse, error)

+ RequestInfo func(context.Context, *InfoRequest) (*InfoResponse, error)

+ type ObjectHealthRequest struct

+ Bucket []byte

+ EncryptedPath []byte

+ EndBeforeSegment int64

+ Limit int32

+ ProjectId []byte

+ StartAfterSegment int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectHealthRequest) Descriptor() ([]byte, []int)

+ func (*ObjectHealthRequest) ProtoMessage()

+ 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 (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 struct

+ Redundancy *RedundancyScheme

+ Segments []*SegmentHealth

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ObjectHealthResponse) Descriptor() ([]byte, []int)

+ func (*ObjectHealthResponse) ProtoMessage()

+ func (m *ObjectHealthResponse) GetRedundancy() *RedundancyScheme

+ func (m *ObjectHealthResponse) GetSegments() []*SegmentHealth

+ 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 Order = RenterBandwidthAllocation

+ func (m *Order) SetCerts(certs [][]byte)

+ func (m *Order) SetSignature(signature []byte)

+ func (n *Order) Scan(value interface{}) error

+ func (n Order) Value() (driver.Value, error)

+ type Order2 struct

+ Amount int64

+ SerialNumber SerialNumber

+ UplinkSignature []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Order2) Descriptor() ([]byte, []int)

+ func (*Order2) ProtoMessage()

+ func (m *Order2) GetAmount() int64

+ func (m *Order2) GetUplinkSignature() []byte

+ func (m *Order2) Reset()

+ func (m *Order2) String() string

+ func (m *Order2) XXX_DiscardUnknown()

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

+ func (m *Order2) XXX_Merge(src proto.Message)

+ func (m *Order2) XXX_Size() int

+ func (m *Order2) XXX_Unmarshal(b []byte) error

+ type OrderLimit = PayerBandwidthAllocation

+ func (m *OrderLimit) Clone() (pba OrderLimit)

+ func (m *OrderLimit) SetCerts(certs [][]byte)

+ func (m *OrderLimit) SetSignature(signature []byte)

+ type OrderLimit2 struct

+ Action PieceAction

+ Limit int64

+ OrderExpiration *timestamp.Timestamp

+ PieceExpiration *timestamp.Timestamp

+ PieceId PieceID

+ SatelliteId NodeID

+ SatelliteSignature []byte

+ SerialNumber SerialNumber

+ StorageNodeId NodeID

+ UplinkId NodeID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*OrderLimit2) Descriptor() ([]byte, []int)

+ func (*OrderLimit2) ProtoMessage()

+ func (m *OrderLimit2) GetAction() PieceAction

+ func (m *OrderLimit2) GetLimit() int64

+ func (m *OrderLimit2) GetOrderExpiration() *timestamp.Timestamp

+ func (m *OrderLimit2) GetPieceExpiration() *timestamp.Timestamp

+ func (m *OrderLimit2) GetSatelliteSignature() []byte

+ func (m *OrderLimit2) Reset()

+ func (m *OrderLimit2) String() string

+ func (m *OrderLimit2) XXX_DiscardUnknown()

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

+ func (m *OrderLimit2) XXX_Merge(src proto.Message)

+ func (m *OrderLimit2) XXX_Size() int

+ func (m *OrderLimit2) XXX_Unmarshal(b []byte) error

+ type OrdersClient interface

+ Settlement func(ctx context.Context, opts ...grpc.CallOption) (Orders_SettlementClient, error)

+ func NewOrdersClient(cc *grpc.ClientConn) OrdersClient

+ type OrdersServer interface

+ Settlement func(Orders_SettlementServer) error

+ type Orders_SettlementClient interface

+ Recv func() (*SettlementResponse, error)

+ Send func(*SettlementRequest) error

+ type Orders_SettlementServer interface

+ Recv func() (*SettlementRequest, error)

+ Send func(*SettlementResponse) error

+ type OverlayInspectorClient interface

+ CountNodes func(ctx context.Context, in *CountNodesRequest, opts ...grpc.CallOption) (*CountNodesResponse, error)

+ CreateStats func(ctx context.Context, in *CreateStatsRequest, opts ...grpc.CallOption) (*CreateStatsResponse, error)

+ DumpNodes func(ctx context.Context, in *DumpNodesRequest, opts ...grpc.CallOption) (*DumpNodesResponse, error)

+ GetStats func(ctx context.Context, in *GetStatsRequest, opts ...grpc.CallOption) (*GetStatsResponse, error)

+ func NewOverlayInspectorClient(cc *grpc.ClientConn) OverlayInspectorClient

+ type OverlayInspectorServer interface

+ CountNodes func(context.Context, *CountNodesRequest) (*CountNodesResponse, error)

+ CreateStats func(context.Context, *CreateStatsRequest) (*CreateStatsResponse, error)

+ DumpNodes func(context.Context, *DumpNodesRequest) (*DumpNodesResponse, error)

+ GetStats func(context.Context, *GetStatsRequest) (*GetStatsResponse, error)

+ type Path = storj.Path

+ type PayerBandwidthAllocation struct

+ Action BandwidthAction

+ Certs [][]byte

+ CreatedUnixSec int64

+ ExpirationUnixSec int64

+ MaxSize int64

+ SatelliteId NodeID

+ SerialNumber string

+ Signature []byte

+ UplinkId NodeID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PayerBandwidthAllocation) Descriptor() ([]byte, []int)

+ func (*PayerBandwidthAllocation) ProtoMessage()

+ func (m *PayerBandwidthAllocation) GetAction() BandwidthAction

+ func (m *PayerBandwidthAllocation) GetCerts() [][]byte

+ func (m *PayerBandwidthAllocation) GetCreatedUnixSec() int64

+ func (m *PayerBandwidthAllocation) GetExpirationUnixSec() int64

+ func (m *PayerBandwidthAllocation) GetMaxSize() int64

+ func (m *PayerBandwidthAllocation) GetSerialNumber() string

+ func (m *PayerBandwidthAllocation) GetSignature() []byte

+ func (m *PayerBandwidthAllocation) Reset()

+ func (m *PayerBandwidthAllocation) String() string

+ func (m *PayerBandwidthAllocation) XXX_DiscardUnknown()

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

+ func (m *PayerBandwidthAllocation) XXX_Merge(src proto.Message)

+ func (m *PayerBandwidthAllocation) XXX_Size() int

+ func (m *PayerBandwidthAllocation) XXX_Unmarshal(b []byte) error

+ type PieceAction int32

+ const PieceAction_DELETE

+ const PieceAction_GET

+ const PieceAction_GET_AUDIT

+ const PieceAction_GET_REPAIR

+ const PieceAction_INVALID

+ const PieceAction_PUT

+ const PieceAction_PUT_REPAIR

+ func (PieceAction) EnumDescriptor() ([]byte, []int)

+ func (x PieceAction) String() string

+ type PieceDeleteRequest struct

+ Limit *OrderLimit2

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceDeleteRequest) Descriptor() ([]byte, []int)

+ func (*PieceDeleteRequest) ProtoMessage()

+ func (m *PieceDeleteRequest) GetLimit() *OrderLimit2

+ func (m *PieceDeleteRequest) Reset()

+ func (m *PieceDeleteRequest) String() string

+ func (m *PieceDeleteRequest) XXX_DiscardUnknown()

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

+ func (m *PieceDeleteRequest) XXX_Merge(src proto.Message)

+ func (m *PieceDeleteRequest) XXX_Size() int

+ func (m *PieceDeleteRequest) XXX_Unmarshal(b []byte) error

+ type PieceDeleteResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceDeleteResponse) Descriptor() ([]byte, []int)

+ func (*PieceDeleteResponse) ProtoMessage()

+ func (m *PieceDeleteResponse) Reset()

+ func (m *PieceDeleteResponse) String() string

+ func (m *PieceDeleteResponse) XXX_DiscardUnknown()

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

+ func (m *PieceDeleteResponse) XXX_Merge(src proto.Message)

+ func (m *PieceDeleteResponse) XXX_Size() int

+ func (m *PieceDeleteResponse) XXX_Unmarshal(b []byte) error

+ type PieceDownloadRequest struct

+ Chunk *PieceDownloadRequest_Chunk

+ Limit *OrderLimit2

+ Order *Order2

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceDownloadRequest) Descriptor() ([]byte, []int)

+ func (*PieceDownloadRequest) ProtoMessage()

+ func (m *PieceDownloadRequest) GetChunk() *PieceDownloadRequest_Chunk

+ func (m *PieceDownloadRequest) GetLimit() *OrderLimit2

+ func (m *PieceDownloadRequest) GetOrder() *Order2

+ func (m *PieceDownloadRequest) Reset()

+ func (m *PieceDownloadRequest) String() string

+ func (m *PieceDownloadRequest) XXX_DiscardUnknown()

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

+ func (m *PieceDownloadRequest) XXX_Merge(src proto.Message)

+ func (m *PieceDownloadRequest) XXX_Size() int

+ func (m *PieceDownloadRequest) XXX_Unmarshal(b []byte) error

+ type PieceDownloadRequest_Chunk struct

+ ChunkSize int64

+ Offset int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceDownloadRequest_Chunk) Descriptor() ([]byte, []int)

+ func (*PieceDownloadRequest_Chunk) ProtoMessage()

+ func (m *PieceDownloadRequest_Chunk) GetChunkSize() int64

+ func (m *PieceDownloadRequest_Chunk) GetOffset() int64

+ func (m *PieceDownloadRequest_Chunk) Reset()

+ func (m *PieceDownloadRequest_Chunk) String() string

+ func (m *PieceDownloadRequest_Chunk) XXX_DiscardUnknown()

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

+ func (m *PieceDownloadRequest_Chunk) XXX_Merge(src proto.Message)

+ func (m *PieceDownloadRequest_Chunk) XXX_Size() int

+ func (m *PieceDownloadRequest_Chunk) XXX_Unmarshal(b []byte) error

+ type PieceDownloadResponse struct

+ Chunk *PieceDownloadResponse_Chunk

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceDownloadResponse) Descriptor() ([]byte, []int)

+ func (*PieceDownloadResponse) ProtoMessage()

+ func (m *PieceDownloadResponse) GetChunk() *PieceDownloadResponse_Chunk

+ func (m *PieceDownloadResponse) Reset()

+ func (m *PieceDownloadResponse) String() string

+ func (m *PieceDownloadResponse) XXX_DiscardUnknown()

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

+ func (m *PieceDownloadResponse) XXX_Merge(src proto.Message)

+ func (m *PieceDownloadResponse) XXX_Size() int

+ func (m *PieceDownloadResponse) XXX_Unmarshal(b []byte) error

+ type PieceDownloadResponse_Chunk struct

+ Data []byte

+ Offset int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceDownloadResponse_Chunk) Descriptor() ([]byte, []int)

+ func (*PieceDownloadResponse_Chunk) ProtoMessage()

+ func (m *PieceDownloadResponse_Chunk) GetData() []byte

+ func (m *PieceDownloadResponse_Chunk) GetOffset() int64

+ func (m *PieceDownloadResponse_Chunk) Reset()

+ func (m *PieceDownloadResponse_Chunk) String() string

+ func (m *PieceDownloadResponse_Chunk) XXX_DiscardUnknown()

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

+ func (m *PieceDownloadResponse_Chunk) XXX_Merge(src proto.Message)

+ func (m *PieceDownloadResponse_Chunk) XXX_Size() int

+ func (m *PieceDownloadResponse_Chunk) XXX_Unmarshal(b []byte) error

+ type PieceHash struct

+ Hash []byte

+ PieceId PieceID

+ Signature []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceHash) Descriptor() ([]byte, []int)

+ func (*PieceHash) ProtoMessage()

+ func (m *PieceHash) GetHash() []byte

+ func (m *PieceHash) GetSignature() []byte

+ func (m *PieceHash) Reset()

+ func (m *PieceHash) String() string

+ func (m *PieceHash) XXX_DiscardUnknown()

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

+ func (m *PieceHash) XXX_Merge(src proto.Message)

+ func (m *PieceHash) XXX_Size() int

+ func (m *PieceHash) XXX_Unmarshal(b []byte) error

+ type PieceID = storj.PieceID

+ type PieceStoreInspectorClient interface

+ Dashboard func(ctx context.Context, in *DashboardRequest, opts ...grpc.CallOption) (*DashboardResponse, error)

+ Stats func(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatSummaryResponse, error)

+ func NewPieceStoreInspectorClient(cc *grpc.ClientConn) PieceStoreInspectorClient

+ type PieceStoreInspectorServer interface

+ Dashboard func(context.Context, *DashboardRequest) (*DashboardResponse, error)

+ Stats func(context.Context, *StatsRequest) (*StatSummaryResponse, error)

+ type PieceUploadRequest struct

+ Chunk *PieceUploadRequest_Chunk

+ Done *PieceHash

+ Limit *OrderLimit2

+ Order *Order2

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceUploadRequest) Descriptor() ([]byte, []int)

+ func (*PieceUploadRequest) ProtoMessage()

+ func (m *PieceUploadRequest) GetChunk() *PieceUploadRequest_Chunk

+ func (m *PieceUploadRequest) GetDone() *PieceHash

+ func (m *PieceUploadRequest) GetLimit() *OrderLimit2

+ func (m *PieceUploadRequest) GetOrder() *Order2

+ func (m *PieceUploadRequest) Reset()

+ func (m *PieceUploadRequest) String() string

+ func (m *PieceUploadRequest) XXX_DiscardUnknown()

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

+ func (m *PieceUploadRequest) XXX_Merge(src proto.Message)

+ func (m *PieceUploadRequest) XXX_Size() int

+ func (m *PieceUploadRequest) XXX_Unmarshal(b []byte) error

+ type PieceUploadRequest_Chunk struct

+ Data []byte

+ Offset int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceUploadRequest_Chunk) Descriptor() ([]byte, []int)

+ func (*PieceUploadRequest_Chunk) ProtoMessage()

+ func (m *PieceUploadRequest_Chunk) GetData() []byte

+ func (m *PieceUploadRequest_Chunk) GetOffset() int64

+ func (m *PieceUploadRequest_Chunk) Reset()

+ func (m *PieceUploadRequest_Chunk) String() string

+ func (m *PieceUploadRequest_Chunk) XXX_DiscardUnknown()

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

+ func (m *PieceUploadRequest_Chunk) XXX_Merge(src proto.Message)

+ func (m *PieceUploadRequest_Chunk) XXX_Size() int

+ func (m *PieceUploadRequest_Chunk) XXX_Unmarshal(b []byte) error

+ type PieceUploadResponse struct

+ Done *PieceHash

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PieceUploadResponse) Descriptor() ([]byte, []int)

+ func (*PieceUploadResponse) ProtoMessage()

+ func (m *PieceUploadResponse) GetDone() *PieceHash

+ func (m *PieceUploadResponse) Reset()

+ func (m *PieceUploadResponse) String() string

+ func (m *PieceUploadResponse) XXX_DiscardUnknown()

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

+ func (m *PieceUploadResponse) XXX_Merge(src proto.Message)

+ func (m *PieceUploadResponse) XXX_Size() int

+ func (m *PieceUploadResponse) XXX_Unmarshal(b []byte) error

+ type PiecestoreClient interface

+ Delete func(ctx context.Context, in *PieceDeleteRequest, opts ...grpc.CallOption) (*PieceDeleteResponse, error)

+ Download func(ctx context.Context, opts ...grpc.CallOption) (Piecestore_DownloadClient, error)

+ Upload func(ctx context.Context, opts ...grpc.CallOption) (Piecestore_UploadClient, error)

+ func NewPiecestoreClient(cc *grpc.ClientConn) PiecestoreClient

+ type PiecestoreServer interface

+ Delete func(context.Context, *PieceDeleteRequest) (*PieceDeleteResponse, error)

+ Download func(Piecestore_DownloadServer) error

+ Upload func(Piecestore_UploadServer) error

+ type Piecestore_DownloadClient interface

+ Recv func() (*PieceDownloadResponse, error)

+ Send func(*PieceDownloadRequest) error

+ type Piecestore_DownloadServer interface

+ Recv func() (*PieceDownloadRequest, error)

+ Send func(*PieceDownloadResponse) error

+ type Piecestore_UploadClient interface

+ CloseAndRecv func() (*PieceUploadResponse, error)

+ Send func(*PieceUploadRequest) error

+ type Piecestore_UploadServer interface

+ Recv func() (*PieceUploadRequest, error)

+ SendAndClose func(*PieceUploadResponse) error

+ type PingNodeRequest struct

+ Address string

+ Id NodeID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PingNodeRequest) Descriptor() ([]byte, []int)

+ func (*PingNodeRequest) ProtoMessage()

+ func (m *PingNodeRequest) GetAddress() string

+ func (m *PingNodeRequest) Reset()

+ func (m *PingNodeRequest) String() string

+ func (m *PingNodeRequest) XXX_DiscardUnknown()

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

+ func (m *PingNodeRequest) XXX_Merge(src proto.Message)

+ func (m *PingNodeRequest) XXX_Size() int

+ func (m *PingNodeRequest) XXX_Unmarshal(b []byte) error

+ type PingNodeResponse struct

+ Ok bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PingNodeResponse) Descriptor() ([]byte, []int)

+ func (*PingNodeResponse) ProtoMessage()

+ func (m *PingNodeResponse) GetOk() bool

+ func (m *PingNodeResponse) Reset()

+ func (m *PingNodeResponse) String() string

+ func (m *PingNodeResponse) XXX_DiscardUnknown()

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

+ func (m *PingNodeResponse) XXX_Merge(src proto.Message)

+ func (m *PingNodeResponse) XXX_Size() int

+ func (m *PingNodeResponse) XXX_Unmarshal(b []byte) error

+ type PingRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PingRequest) Descriptor() ([]byte, []int)

+ func (*PingRequest) ProtoMessage()

+ func (m *PingRequest) Reset()

+ func (m *PingRequest) String() string

+ func (m *PingRequest) XXX_DiscardUnknown()

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

+ func (m *PingRequest) XXX_Merge(src proto.Message)

+ func (m *PingRequest) XXX_Size() int

+ func (m *PingRequest) XXX_Unmarshal(b []byte) error

+ type PingResponse struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PingResponse) Descriptor() ([]byte, []int)

+ func (*PingResponse) ProtoMessage()

+ func (m *PingResponse) Reset()

+ func (m *PingResponse) String() string

+ func (m *PingResponse) XXX_DiscardUnknown()

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

+ func (m *PingResponse) XXX_Merge(src proto.Message)

+ func (m *PingResponse) XXX_Size() int

+ func (m *PingResponse) XXX_Unmarshal(b []byte) error

+ type Pointer struct

+ CreationDate *timestamp.Timestamp

+ ExpirationDate *timestamp.Timestamp

+ InlineSegment []byte

+ Metadata []byte

+ Remote *RemoteSegment

+ SegmentSize int64

+ Type Pointer_DataType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Pointer) Descriptor() ([]byte, []int)

+ func (*Pointer) ProtoMessage()

+ func (m *Pointer) GetCreationDate() *timestamp.Timestamp

+ func (m *Pointer) GetExpirationDate() *timestamp.Timestamp

+ func (m *Pointer) GetInlineSegment() []byte

+ func (m *Pointer) GetMetadata() []byte

+ func (m *Pointer) GetRemote() *RemoteSegment

+ func (m *Pointer) GetSegmentSize() int64

+ func (m *Pointer) GetType() Pointer_DataType

+ func (m *Pointer) Reset()

+ func (m *Pointer) String() string

+ func (m *Pointer) XXX_DiscardUnknown()

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

+ func (m *Pointer) XXX_Merge(src proto.Message)

+ func (m *Pointer) XXX_Size() int

+ func (m *Pointer) XXX_Unmarshal(b []byte) error

+ type Pointer_DataType int32

+ const Pointer_INLINE

+ const Pointer_REMOTE

+ func (Pointer_DataType) EnumDescriptor() ([]byte, []int)

+ func (x Pointer_DataType) String() string

+ type QueryRequest struct

+ Limit int64

+ Pingback bool

+ Sender *Node

+ Target *Node

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*QueryRequest) Descriptor() ([]byte, []int)

+ func (*QueryRequest) ProtoMessage()

+ func (m *QueryRequest) GetLimit() int64

+ func (m *QueryRequest) GetPingback() bool

+ func (m *QueryRequest) GetSender() *Node

+ func (m *QueryRequest) GetTarget() *Node

+ func (m *QueryRequest) Reset()

+ func (m *QueryRequest) String() string

+ func (m *QueryRequest) XXX_DiscardUnknown()

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

+ func (m *QueryRequest) XXX_Merge(src proto.Message)

+ func (m *QueryRequest) XXX_Size() int

+ func (m *QueryRequest) XXX_Unmarshal(b []byte) error

+ type QueryResponse struct

+ Response []*Node

+ Sender *Node

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*QueryResponse) Descriptor() ([]byte, []int)

+ func (*QueryResponse) ProtoMessage()

+ func (m *QueryResponse) GetResponse() []*Node

+ func (m *QueryResponse) GetSender() *Node

+ func (m *QueryResponse) Reset()

+ func (m *QueryResponse) String() string

+ func (m *QueryResponse) XXX_DiscardUnknown()

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

+ func (m *QueryResponse) XXX_Merge(src proto.Message)

+ func (m *QueryResponse) XXX_Size() int

+ func (m *QueryResponse) XXX_Unmarshal(b []byte) error

+ type RedundancyScheme struct

+ ErasureShareSize int32

+ MinReq int32

+ RepairThreshold int32

+ SuccessThreshold int32

+ Total int32

+ Type RedundancyScheme_SchemeType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RedundancyScheme) Descriptor() ([]byte, []int)

+ func (*RedundancyScheme) ProtoMessage()

+ func (m *RedundancyScheme) GetErasureShareSize() int32

+ func (m *RedundancyScheme) GetMinReq() int32

+ func (m *RedundancyScheme) GetRepairThreshold() int32

+ func (m *RedundancyScheme) GetSuccessThreshold() int32

+ func (m *RedundancyScheme) GetTotal() int32

+ func (m *RedundancyScheme) GetType() RedundancyScheme_SchemeType

+ func (m *RedundancyScheme) Reset()

+ func (m *RedundancyScheme) String() string

+ func (m *RedundancyScheme) XXX_DiscardUnknown()

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

+ func (m *RedundancyScheme) XXX_Merge(src proto.Message)

+ func (m *RedundancyScheme) XXX_Size() int

+ func (m *RedundancyScheme) XXX_Unmarshal(b []byte) error

+ type RedundancyScheme_SchemeType int32

+ const RedundancyScheme_RS

+ func (RedundancyScheme_SchemeType) EnumDescriptor() ([]byte, []int)

+ func (x RedundancyScheme_SchemeType) String() string

+ type RemotePiece struct

+ Hash *PieceHash

+ NodeId NodeID

+ PieceNum int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RemotePiece) Descriptor() ([]byte, []int)

+ func (*RemotePiece) ProtoMessage()

+ func (m *RemotePiece) GetHash() *PieceHash

+ func (m *RemotePiece) GetPieceNum() int32

+ func (m *RemotePiece) Reset()

+ func (m *RemotePiece) String() string

+ func (m *RemotePiece) XXX_DiscardUnknown()

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

+ func (m *RemotePiece) XXX_Merge(src proto.Message)

+ func (m *RemotePiece) XXX_Size() int

+ func (m *RemotePiece) XXX_Unmarshal(b []byte) error

+ type RemoteSegment struct

+ MerkleRoot []byte

+ Redundancy *RedundancyScheme

+ RemotePieces []*RemotePiece

+ RootPieceId PieceID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RemoteSegment) Descriptor() ([]byte, []int)

+ func (*RemoteSegment) ProtoMessage()

+ func (m *RemoteSegment) GetMerkleRoot() []byte

+ func (m *RemoteSegment) GetRedundancy() *RedundancyScheme

+ func (m *RemoteSegment) GetRemotePieces() []*RemotePiece

+ func (m *RemoteSegment) Reset()

+ func (m *RemoteSegment) String() string

+ func (m *RemoteSegment) XXX_DiscardUnknown()

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

+ func (m *RemoteSegment) XXX_Merge(src proto.Message)

+ func (m *RemoteSegment) XXX_Size() int

+ func (m *RemoteSegment) XXX_Unmarshal(b []byte) error

+ type RenterBandwidthAllocation struct

+ Certs [][]byte

+ PayerAllocation PayerBandwidthAllocation

+ Signature []byte

+ StorageNodeId NodeID

+ Total int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RenterBandwidthAllocation) Descriptor() ([]byte, []int)

+ func (*RenterBandwidthAllocation) ProtoMessage()

+ func (m *RenterBandwidthAllocation) GetCerts() [][]byte

+ func (m *RenterBandwidthAllocation) GetPayerAllocation() PayerBandwidthAllocation

+ func (m *RenterBandwidthAllocation) GetSignature() []byte

+ func (m *RenterBandwidthAllocation) GetTotal() int64

+ func (m *RenterBandwidthAllocation) Reset()

+ func (m *RenterBandwidthAllocation) String() string

+ func (m *RenterBandwidthAllocation) XXX_DiscardUnknown()

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

+ func (m *RenterBandwidthAllocation) XXX_Merge(src proto.Message)

+ func (m *RenterBandwidthAllocation) XXX_Size() int

+ func (m *RenterBandwidthAllocation) XXX_Unmarshal(b []byte) error

+ type Restriction struct

+ Operand Restriction_Operand

+ Operator Restriction_Operator

+ Value int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Restriction) Descriptor() ([]byte, []int)

+ func (*Restriction) ProtoMessage()

+ func (m *Restriction) GetOperand() Restriction_Operand

+ func (m *Restriction) GetOperator() Restriction_Operator

+ func (m *Restriction) GetValue() int64

+ func (m *Restriction) Reset()

+ func (m *Restriction) String() string

+ func (m *Restriction) XXX_DiscardUnknown()

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

+ func (m *Restriction) XXX_Merge(src proto.Message)

+ func (m *Restriction) XXX_Size() int

+ func (m *Restriction) XXX_Unmarshal(b []byte) error

+ type Restriction_Operand int32

+ const Restriction_FREE_BANDWIDTH

+ const Restriction_FREE_DISK

+ func (Restriction_Operand) EnumDescriptor() ([]byte, []int)

+ func (x Restriction_Operand) String() string

+ type Restriction_Operator int32

+ const Restriction_EQ

+ const Restriction_GT

+ const Restriction_GTE

+ const Restriction_LT

+ const Restriction_LTE

+ func (Restriction_Operator) EnumDescriptor() ([]byte, []int)

+ func (x Restriction_Operator) String() string

+ type SegmentCommitRequest struct

+ Bucket []byte

+ OriginalLimits []*OrderLimit2

+ Path []byte

+ Pointer *Pointer

+ Segment int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentCommitRequest) Descriptor() ([]byte, []int)

+ func (*SegmentCommitRequest) ProtoMessage()

+ func (m *SegmentCommitRequest) GetBucket() []byte

+ func (m *SegmentCommitRequest) GetOriginalLimits() []*OrderLimit2

+ func (m *SegmentCommitRequest) GetPath() []byte

+ func (m *SegmentCommitRequest) GetPointer() *Pointer

+ func (m *SegmentCommitRequest) GetSegment() int64

+ func (m *SegmentCommitRequest) Reset()

+ func (m *SegmentCommitRequest) String() string

+ func (m *SegmentCommitRequest) XXX_DiscardUnknown()

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

+ func (m *SegmentCommitRequest) XXX_Merge(src proto.Message)

+ func (m *SegmentCommitRequest) XXX_Size() int

+ func (m *SegmentCommitRequest) XXX_Unmarshal(b []byte) error

+ type SegmentCommitResponse struct

+ Pointer *Pointer

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentCommitResponse) Descriptor() ([]byte, []int)

+ func (*SegmentCommitResponse) ProtoMessage()

+ func (m *SegmentCommitResponse) GetPointer() *Pointer

+ func (m *SegmentCommitResponse) Reset()

+ func (m *SegmentCommitResponse) String() string

+ func (m *SegmentCommitResponse) XXX_DiscardUnknown()

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

+ func (m *SegmentCommitResponse) XXX_Merge(src proto.Message)

+ func (m *SegmentCommitResponse) XXX_Size() int

+ func (m *SegmentCommitResponse) XXX_Unmarshal(b []byte) error

+ type SegmentDeleteRequest struct

+ Bucket []byte

+ Path []byte

+ Segment int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentDeleteRequest) Descriptor() ([]byte, []int)

+ func (*SegmentDeleteRequest) ProtoMessage()

+ func (m *SegmentDeleteRequest) GetBucket() []byte

+ func (m *SegmentDeleteRequest) GetPath() []byte

+ func (m *SegmentDeleteRequest) GetSegment() int64

+ func (m *SegmentDeleteRequest) Reset()

+ func (m *SegmentDeleteRequest) String() string

+ func (m *SegmentDeleteRequest) XXX_DiscardUnknown()

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

+ func (m *SegmentDeleteRequest) XXX_Merge(src proto.Message)

+ func (m *SegmentDeleteRequest) XXX_Size() int

+ func (m *SegmentDeleteRequest) XXX_Unmarshal(b []byte) error

+ type SegmentDeleteResponse struct

+ AddressedLimits []*AddressedOrderLimit

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentDeleteResponse) Descriptor() ([]byte, []int)

+ func (*SegmentDeleteResponse) ProtoMessage()

+ func (m *SegmentDeleteResponse) GetAddressedLimits() []*AddressedOrderLimit

+ func (m *SegmentDeleteResponse) Reset()

+ func (m *SegmentDeleteResponse) String() string

+ func (m *SegmentDeleteResponse) XXX_DiscardUnknown()

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

+ func (m *SegmentDeleteResponse) XXX_Merge(src proto.Message)

+ func (m *SegmentDeleteResponse) XXX_Size() int

+ func (m *SegmentDeleteResponse) XXX_Unmarshal(b []byte) error

+ type SegmentDownloadRequest struct

+ Bucket []byte

+ Path []byte

+ Segment int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentDownloadRequest) Descriptor() ([]byte, []int)

+ func (*SegmentDownloadRequest) ProtoMessage()

+ func (m *SegmentDownloadRequest) GetBucket() []byte

+ func (m *SegmentDownloadRequest) GetPath() []byte

+ func (m *SegmentDownloadRequest) GetSegment() int64

+ func (m *SegmentDownloadRequest) Reset()

+ func (m *SegmentDownloadRequest) String() string

+ func (m *SegmentDownloadRequest) XXX_DiscardUnknown()

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

+ func (m *SegmentDownloadRequest) XXX_Merge(src proto.Message)

+ func (m *SegmentDownloadRequest) XXX_Size() int

+ func (m *SegmentDownloadRequest) XXX_Unmarshal(b []byte) error

+ type SegmentDownloadResponse struct

+ AddressedLimits []*AddressedOrderLimit

+ Pointer *Pointer

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentDownloadResponse) Descriptor() ([]byte, []int)

+ func (*SegmentDownloadResponse) ProtoMessage()

+ func (m *SegmentDownloadResponse) GetAddressedLimits() []*AddressedOrderLimit

+ func (m *SegmentDownloadResponse) GetPointer() *Pointer

+ func (m *SegmentDownloadResponse) Reset()

+ func (m *SegmentDownloadResponse) String() string

+ func (m *SegmentDownloadResponse) XXX_DiscardUnknown()

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

+ func (m *SegmentDownloadResponse) XXX_Merge(src proto.Message)

+ func (m *SegmentDownloadResponse) XXX_Size() int

+ func (m *SegmentDownloadResponse) XXX_Unmarshal(b []byte) error

+ type SegmentHealth struct

+ MinimumRequired int32

+ OnlineNodes int32

+ RepairThreshold int32

+ Segment []byte

+ SuccessThreshold int32

+ Total int32

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentHealth) Descriptor() ([]byte, []int)

+ func (*SegmentHealth) ProtoMessage()

+ func (m *SegmentHealth) GetMinimumRequired() int32

+ func (m *SegmentHealth) GetOnlineNodes() int32

+ func (m *SegmentHealth) GetRepairThreshold() int32

+ func (m *SegmentHealth) GetSegment() []byte

+ func (m *SegmentHealth) GetSuccessThreshold() int32

+ func (m *SegmentHealth) GetTotal() int32

+ 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 struct

+ Bucket []byte

+ EncryptedPath []byte

+ ProjectId []byte

+ SegmentIndex int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentHealthRequest) Descriptor() ([]byte, []int)

+ func (*SegmentHealthRequest) ProtoMessage()

+ func (m *SegmentHealthRequest) GetBucket() []byte

+ func (m *SegmentHealthRequest) GetEncryptedPath() []byte

+ func (m *SegmentHealthRequest) GetProjectId() []byte

+ func (m *SegmentHealthRequest) GetSegmentIndex() int64

+ 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 struct

+ Health *SegmentHealth

+ Redundancy *RedundancyScheme

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentHealthResponse) Descriptor() ([]byte, []int)

+ func (*SegmentHealthResponse) ProtoMessage()

+ func (m *SegmentHealthResponse) GetHealth() *SegmentHealth

+ func (m *SegmentHealthResponse) GetRedundancy() *RedundancyScheme

+ 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 SegmentInfoRequest struct

+ Bucket []byte

+ Path []byte

+ Segment int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentInfoRequest) Descriptor() ([]byte, []int)

+ func (*SegmentInfoRequest) ProtoMessage()

+ func (m *SegmentInfoRequest) GetBucket() []byte

+ func (m *SegmentInfoRequest) GetPath() []byte

+ func (m *SegmentInfoRequest) GetSegment() int64

+ func (m *SegmentInfoRequest) Reset()

+ func (m *SegmentInfoRequest) String() string

+ func (m *SegmentInfoRequest) XXX_DiscardUnknown()

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

+ func (m *SegmentInfoRequest) XXX_Merge(src proto.Message)

+ func (m *SegmentInfoRequest) XXX_Size() int

+ func (m *SegmentInfoRequest) XXX_Unmarshal(b []byte) error

+ type SegmentInfoResponse struct

+ Pointer *Pointer

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentInfoResponse) Descriptor() ([]byte, []int)

+ func (*SegmentInfoResponse) ProtoMessage()

+ func (m *SegmentInfoResponse) GetPointer() *Pointer

+ func (m *SegmentInfoResponse) Reset()

+ func (m *SegmentInfoResponse) String() string

+ func (m *SegmentInfoResponse) XXX_DiscardUnknown()

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

+ func (m *SegmentInfoResponse) XXX_Merge(src proto.Message)

+ func (m *SegmentInfoResponse) XXX_Size() int

+ func (m *SegmentInfoResponse) XXX_Unmarshal(b []byte) error

+ type SegmentMeta struct

+ EncryptedKey []byte

+ KeyNonce []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentMeta) Descriptor() ([]byte, []int)

+ func (*SegmentMeta) ProtoMessage()

+ func (m *SegmentMeta) GetEncryptedKey() []byte

+ func (m *SegmentMeta) GetKeyNonce() []byte

+ func (m *SegmentMeta) Reset()

+ func (m *SegmentMeta) String() string

+ func (m *SegmentMeta) XXX_DiscardUnknown()

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

+ func (m *SegmentMeta) XXX_Merge(src proto.Message)

+ func (m *SegmentMeta) XXX_Size() int

+ func (m *SegmentMeta) XXX_Unmarshal(b []byte) error

+ type SegmentWriteRequest struct

+ Bucket []byte

+ Expiration *timestamp.Timestamp

+ MaxEncryptedSegmentSize int64

+ Path []byte

+ Redundancy *RedundancyScheme

+ Segment int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentWriteRequest) Descriptor() ([]byte, []int)

+ func (*SegmentWriteRequest) ProtoMessage()

+ func (m *SegmentWriteRequest) GetBucket() []byte

+ func (m *SegmentWriteRequest) GetExpiration() *timestamp.Timestamp

+ func (m *SegmentWriteRequest) GetMaxEncryptedSegmentSize() int64

+ func (m *SegmentWriteRequest) GetPath() []byte

+ func (m *SegmentWriteRequest) GetRedundancy() *RedundancyScheme

+ func (m *SegmentWriteRequest) GetSegment() int64

+ func (m *SegmentWriteRequest) Reset()

+ func (m *SegmentWriteRequest) String() string

+ func (m *SegmentWriteRequest) XXX_DiscardUnknown()

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

+ func (m *SegmentWriteRequest) XXX_Merge(src proto.Message)

+ func (m *SegmentWriteRequest) XXX_Size() int

+ func (m *SegmentWriteRequest) XXX_Unmarshal(b []byte) error

+ type SegmentWriteResponse struct

+ AddressedLimits []*AddressedOrderLimit

+ RootPieceId PieceID

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SegmentWriteResponse) Descriptor() ([]byte, []int)

+ func (*SegmentWriteResponse) ProtoMessage()

+ func (m *SegmentWriteResponse) GetAddressedLimits() []*AddressedOrderLimit

+ func (m *SegmentWriteResponse) Reset()

+ func (m *SegmentWriteResponse) String() string

+ func (m *SegmentWriteResponse) XXX_DiscardUnknown()

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

+ func (m *SegmentWriteResponse) XXX_Merge(src proto.Message)

+ func (m *SegmentWriteResponse) XXX_Size() int

+ func (m *SegmentWriteResponse) XXX_Unmarshal(b []byte) error

+ type SerialNumber = storj.SerialNumber

+ type SerializableMeta struct

+ ContentType string

+ UserDefined map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SerializableMeta) Descriptor() ([]byte, []int)

+ func (*SerializableMeta) ProtoMessage()

+ func (m *SerializableMeta) GetContentType() string

+ func (m *SerializableMeta) GetUserDefined() map[string]string

+ func (m *SerializableMeta) Reset()

+ func (m *SerializableMeta) String() string

+ func (m *SerializableMeta) XXX_DiscardUnknown()

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

+ func (m *SerializableMeta) XXX_Merge(src proto.Message)

+ func (m *SerializableMeta) XXX_Size() int

+ func (m *SerializableMeta) XXX_Unmarshal(b []byte) error

+ type SettlementRequest struct

+ Limit *OrderLimit2

+ Order *Order2

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SettlementRequest) Descriptor() ([]byte, []int)

+ func (*SettlementRequest) ProtoMessage()

+ func (m *SettlementRequest) GetLimit() *OrderLimit2

+ func (m *SettlementRequest) GetOrder() *Order2

+ func (m *SettlementRequest) Reset()

+ func (m *SettlementRequest) String() string

+ func (m *SettlementRequest) XXX_DiscardUnknown()

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

+ func (m *SettlementRequest) XXX_Merge(src proto.Message)

+ func (m *SettlementRequest) XXX_Size() int

+ func (m *SettlementRequest) XXX_Unmarshal(b []byte) error

+ type SettlementResponse struct

+ SerialNumber SerialNumber

+ Status SettlementResponse_Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SettlementResponse) Descriptor() ([]byte, []int)

+ func (*SettlementResponse) ProtoMessage()

+ func (m *SettlementResponse) GetStatus() SettlementResponse_Status

+ func (m *SettlementResponse) Reset()

+ func (m *SettlementResponse) String() string

+ func (m *SettlementResponse) XXX_DiscardUnknown()

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

+ func (m *SettlementResponse) XXX_Merge(src proto.Message)

+ func (m *SettlementResponse) XXX_Size() int

+ func (m *SettlementResponse) XXX_Unmarshal(b []byte) error

+ type SettlementResponse_Status int32

+ const SettlementResponse_ACCEPTED

+ const SettlementResponse_INVALID

+ const SettlementResponse_REJECTED

+ func (SettlementResponse_Status) EnumDescriptor() ([]byte, []int)

+ func (x SettlementResponse_Status) String() string

+ type SignedHash struct

+ Certs [][]byte

+ Hash []byte

+ Signature []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SignedHash) Descriptor() ([]byte, []int)

+ func (*SignedHash) ProtoMessage()

+ func (m *SignedHash) GetCerts() [][]byte

+ func (m *SignedHash) GetHash() []byte

+ func (m *SignedHash) GetSignature() []byte

+ func (m *SignedHash) Reset()

+ func (m *SignedHash) SetCerts(certs [][]byte)

+ func (m *SignedHash) SetSignature(signature []byte)

+ func (m *SignedHash) String() string

+ func (m *SignedHash) XXX_DiscardUnknown()

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

+ func (m *SignedHash) XXX_Merge(src proto.Message)

+ func (m *SignedHash) XXX_Size() int

+ func (m *SignedHash) XXX_Unmarshal(b []byte) error

+ type SignedMessage struct

+ Data []byte

+ PublicKey []byte

+ Signature []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SignedMessage) Descriptor() ([]byte, []int)

+ func (*SignedMessage) ProtoMessage()

+ func (m *SignedMessage) GetData() []byte

+ func (m *SignedMessage) GetPublicKey() []byte

+ func (m *SignedMessage) GetSignature() []byte

+ func (m *SignedMessage) Reset()

+ func (m *SignedMessage) String() string

+ func (m *SignedMessage) XXX_DiscardUnknown()

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

+ func (m *SignedMessage) XXX_Merge(src proto.Message)

+ func (m *SignedMessage) XXX_Size() int

+ func (m *SignedMessage) XXX_Unmarshal(b []byte) error

+ type SigningRequest struct

+ AuthToken string

+ Timestamp int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SigningRequest) Descriptor() ([]byte, []int)

+ func (*SigningRequest) ProtoMessage()

+ func (m *SigningRequest) GetAuthToken() string

+ func (m *SigningRequest) GetTimestamp() int64

+ func (m *SigningRequest) Reset()

+ func (m *SigningRequest) String() string

+ func (m *SigningRequest) XXX_DiscardUnknown()

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

+ func (m *SigningRequest) XXX_Merge(src proto.Message)

+ func (m *SigningRequest) XXX_Size() int

+ func (m *SigningRequest) XXX_Unmarshal(b []byte) error

+ type SigningResponse struct

+ Chain [][]byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SigningResponse) Descriptor() ([]byte, []int)

+ func (*SigningResponse) ProtoMessage()

+ func (m *SigningResponse) GetChain() [][]byte

+ func (m *SigningResponse) Reset()

+ func (m *SigningResponse) String() string

+ func (m *SigningResponse) XXX_DiscardUnknown()

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

+ func (m *SigningResponse) XXX_Merge(src proto.Message)

+ func (m *SigningResponse) XXX_Size() int

+ func (m *SigningResponse) XXX_Unmarshal(b []byte) error

+ type StatSummaryResponse struct

+ AvailableBandwidth int64

+ AvailableSpace int64

+ UsedBandwidth int64

+ UsedEgress int64

+ UsedIngress int64

+ UsedSpace int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StatSummaryResponse) Descriptor() ([]byte, []int)

+ func (*StatSummaryResponse) ProtoMessage()

+ func (m *StatSummaryResponse) GetAvailableBandwidth() int64

+ func (m *StatSummaryResponse) GetAvailableSpace() int64

+ func (m *StatSummaryResponse) GetUsedBandwidth() int64

+ func (m *StatSummaryResponse) GetUsedEgress() int64

+ func (m *StatSummaryResponse) GetUsedIngress() int64

+ func (m *StatSummaryResponse) GetUsedSpace() int64

+ func (m *StatSummaryResponse) Reset()

+ func (m *StatSummaryResponse) String() string

+ func (m *StatSummaryResponse) XXX_DiscardUnknown()

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

+ func (m *StatSummaryResponse) XXX_Merge(src proto.Message)

+ func (m *StatSummaryResponse) XXX_Size() int

+ func (m *StatSummaryResponse) XXX_Unmarshal(b []byte) error

+ type StatsRequest struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StatsRequest) Descriptor() ([]byte, []int)

+ func (*StatsRequest) ProtoMessage()

+ func (m *StatsRequest) Reset()

+ func (m *StatsRequest) String() string

+ func (m *StatsRequest) XXX_DiscardUnknown()

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

+ func (m *StatsRequest) XXX_Merge(src proto.Message)

+ func (m *StatsRequest) XXX_Size() int

+ func (m *StatsRequest) XXX_Unmarshal(b []byte) error

+ type StreamInfo struct

+ LastSegmentSize int64

+ Metadata []byte

+ NumberOfSegments int64

+ SegmentsSize int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamInfo) Descriptor() ([]byte, []int)

+ func (*StreamInfo) ProtoMessage()

+ func (m *StreamInfo) GetLastSegmentSize() int64

+ func (m *StreamInfo) GetMetadata() []byte

+ func (m *StreamInfo) GetNumberOfSegments() int64

+ func (m *StreamInfo) GetSegmentsSize() int64

+ func (m *StreamInfo) Reset()

+ func (m *StreamInfo) String() string

+ func (m *StreamInfo) XXX_DiscardUnknown()

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

+ func (m *StreamInfo) XXX_Merge(src proto.Message)

+ func (m *StreamInfo) XXX_Size() int

+ func (m *StreamInfo) XXX_Unmarshal(b []byte) error

+ type StreamMeta struct

+ EncryptedStreamInfo []byte

+ EncryptionBlockSize int32

+ EncryptionType int32

+ LastSegmentMeta *SegmentMeta

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*StreamMeta) Descriptor() ([]byte, []int)

+ func (*StreamMeta) ProtoMessage()

+ func (m *StreamMeta) GetEncryptedStreamInfo() []byte

+ func (m *StreamMeta) GetEncryptionBlockSize() int32

+ func (m *StreamMeta) GetEncryptionType() int32

+ func (m *StreamMeta) GetLastSegmentMeta() *SegmentMeta

+ func (m *StreamMeta) Reset()

+ func (m *StreamMeta) String() string

+ func (m *StreamMeta) XXX_DiscardUnknown()

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

+ func (m *StreamMeta) XXX_Merge(src proto.Message)

+ func (m *StreamMeta) XXX_Size() int

+ func (m *StreamMeta) XXX_Unmarshal(b []byte) error