Documentation ¶
Index ¶
- Variables
- func BuildListDealRecordsOptions(conf *ListDealRecordsConfig) []deals.ListDealRecordsOption
- func RegisterRPCServiceServer(s *grpc.Server, srv RPCServiceServer)
- type FetchRequest
- func (*FetchRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FetchRequest) GetAddress() string
- func (x *FetchRequest) GetCid() string
- func (*FetchRequest) ProtoMessage()
- func (x *FetchRequest) ProtoReflect() protoreflect.Message
- func (x *FetchRequest) Reset()
- func (x *FetchRequest) String() string
- type FetchResponse
- type GetDealStatusRequest
- func (*GetDealStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDealStatusRequest) GetProposalCid() string
- func (*GetDealStatusRequest) ProtoMessage()
- func (x *GetDealStatusRequest) ProtoReflect() protoreflect.Message
- func (x *GetDealStatusRequest) Reset()
- func (x *GetDealStatusRequest) String() string
- type GetDealStatusResponse
- func (*GetDealStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDealStatusResponse) GetSlashed() bool
- func (x *GetDealStatusResponse) GetStatus() StorageDealStatus
- func (*GetDealStatusResponse) ProtoMessage()
- func (x *GetDealStatusResponse) ProtoReflect() protoreflect.Message
- func (x *GetDealStatusResponse) Reset()
- func (x *GetDealStatusResponse) String() string
- type ImportParams
- type ImportRequest
- func (*ImportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ImportRequest) GetChunk() []byte
- func (x *ImportRequest) GetImportParams() *ImportParams
- func (m *ImportRequest) GetPayload() isImportRequest_Payload
- func (*ImportRequest) ProtoMessage()
- func (x *ImportRequest) ProtoReflect() protoreflect.Message
- func (x *ImportRequest) Reset()
- func (x *ImportRequest) String() string
- type ImportRequest_Chunk
- type ImportRequest_ImportParams
- type ImportResponse
- func (*ImportResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ImportResponse) GetDataCid() string
- func (x *ImportResponse) GetSize() int64
- func (*ImportResponse) ProtoMessage()
- func (x *ImportResponse) ProtoReflect() protoreflect.Message
- func (x *ImportResponse) Reset()
- func (x *ImportResponse) String() string
- type ListDealRecordsConfig
- func (*ListDealRecordsConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ListDealRecordsConfig) GetAscending() bool
- func (x *ListDealRecordsConfig) GetDataCids() []string
- func (x *ListDealRecordsConfig) GetFromAddrs() []string
- func (x *ListDealRecordsConfig) GetIncludeFinal() bool
- func (x *ListDealRecordsConfig) GetIncludePending() bool
- func (*ListDealRecordsConfig) ProtoMessage()
- func (x *ListDealRecordsConfig) ProtoReflect() protoreflect.Message
- func (x *ListDealRecordsConfig) Reset()
- func (x *ListDealRecordsConfig) String() string
- type ListRetrievalDealRecordsRequest
- func (*ListRetrievalDealRecordsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListRetrievalDealRecordsRequest) GetConfig() *ListDealRecordsConfig
- func (*ListRetrievalDealRecordsRequest) ProtoMessage()
- func (x *ListRetrievalDealRecordsRequest) ProtoReflect() protoreflect.Message
- func (x *ListRetrievalDealRecordsRequest) Reset()
- func (x *ListRetrievalDealRecordsRequest) String() string
- type ListRetrievalDealRecordsResponse
- func (*ListRetrievalDealRecordsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListRetrievalDealRecordsResponse) GetRecords() []*RetrievalDealRecord
- func (*ListRetrievalDealRecordsResponse) ProtoMessage()
- func (x *ListRetrievalDealRecordsResponse) ProtoReflect() protoreflect.Message
- func (x *ListRetrievalDealRecordsResponse) Reset()
- func (x *ListRetrievalDealRecordsResponse) String() string
- type ListStorageDealRecordsRequest
- func (*ListStorageDealRecordsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListStorageDealRecordsRequest) GetConfig() *ListDealRecordsConfig
- func (*ListStorageDealRecordsRequest) ProtoMessage()
- func (x *ListStorageDealRecordsRequest) ProtoReflect() protoreflect.Message
- func (x *ListStorageDealRecordsRequest) Reset()
- func (x *ListStorageDealRecordsRequest) String() string
- type ListStorageDealRecordsResponse
- func (*ListStorageDealRecordsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListStorageDealRecordsResponse) GetRecords() []*StorageDealRecord
- func (*ListStorageDealRecordsResponse) ProtoMessage()
- func (x *ListStorageDealRecordsResponse) ProtoReflect() protoreflect.Message
- func (x *ListStorageDealRecordsResponse) Reset()
- func (x *ListStorageDealRecordsResponse) String() string
- type Module
- type RPC
- func (s *RPC) Fetch(ctx context.Context, req *FetchRequest) (*FetchResponse, error)
- func (s *RPC) GetDealStatus(ctx context.Context, req *GetDealStatusRequest) (*GetDealStatusResponse, error)
- func (s *RPC) Import(srv RPCService_ImportServer) error
- func (s *RPC) ListRetrievalDealRecords(ctx context.Context, req *ListRetrievalDealRecordsRequest) (*ListRetrievalDealRecordsResponse, error)
- func (s *RPC) ListStorageDealRecords(ctx context.Context, req *ListStorageDealRecordsRequest) (*ListStorageDealRecordsResponse, error)
- func (s *RPC) Retrieve(req *RetrieveRequest, srv RPCService_RetrieveServer) error
- func (s *RPC) Store(ctx context.Context, req *StoreRequest) (*StoreResponse, error)
- func (s *RPC) Watch(req *WatchRequest, srv RPCService_WatchServer) error
- type RPCServiceClient
- type RPCServiceServer
- type RPCService_ImportClient
- type RPCService_ImportServer
- type RPCService_RetrieveClient
- type RPCService_RetrieveServer
- type RPCService_WatchClient
- type RPCService_WatchServer
- type RetrievalDealInfo
- func (*RetrievalDealInfo) Descriptor() ([]byte, []int)deprecated
- func (x *RetrievalDealInfo) GetMinPrice() uint64
- func (x *RetrievalDealInfo) GetMiner() string
- func (x *RetrievalDealInfo) GetMinerPeerId() string
- func (x *RetrievalDealInfo) GetPaymentInterval() uint64
- func (x *RetrievalDealInfo) GetPaymentIntervalIncrease() uint64
- func (x *RetrievalDealInfo) GetRootCid() string
- func (x *RetrievalDealInfo) GetSize() uint64
- func (*RetrievalDealInfo) ProtoMessage()
- func (x *RetrievalDealInfo) ProtoReflect() protoreflect.Message
- func (x *RetrievalDealInfo) Reset()
- func (x *RetrievalDealInfo) String() string
- type RetrievalDealRecord
- func (*RetrievalDealRecord) Descriptor() ([]byte, []int)deprecated
- func (x *RetrievalDealRecord) GetAddr() string
- func (x *RetrievalDealRecord) GetDealInfo() *RetrievalDealInfo
- func (x *RetrievalDealRecord) GetTime() int64
- func (*RetrievalDealRecord) ProtoMessage()
- func (x *RetrievalDealRecord) ProtoReflect() protoreflect.Message
- func (x *RetrievalDealRecord) Reset()
- func (x *RetrievalDealRecord) String() string
- type RetrieveRequest
- func (*RetrieveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RetrieveRequest) GetAddress() string
- func (x *RetrieveRequest) GetCarEncoding() bool
- func (x *RetrieveRequest) GetCid() string
- func (*RetrieveRequest) ProtoMessage()
- func (x *RetrieveRequest) ProtoReflect() protoreflect.Message
- func (x *RetrieveRequest) Reset()
- func (x *RetrieveRequest) String() string
- type RetrieveResponse
- type StorageDealConfig
- func (*StorageDealConfig) Descriptor() ([]byte, []int)deprecated
- func (x *StorageDealConfig) GetEpochPrice() uint64
- func (x *StorageDealConfig) GetMiner() string
- func (*StorageDealConfig) ProtoMessage()
- func (x *StorageDealConfig) ProtoReflect() protoreflect.Message
- func (x *StorageDealConfig) Reset()
- func (x *StorageDealConfig) String() string
- type StorageDealInfo
- func (*StorageDealInfo) Descriptor() ([]byte, []int)deprecated
- func (x *StorageDealInfo) GetActivationEpoch() int64
- func (x *StorageDealInfo) GetDealId() uint64
- func (x *StorageDealInfo) GetDuration() uint64
- func (x *StorageDealInfo) GetMiner() string
- func (x *StorageDealInfo) GetMsg() string
- func (x *StorageDealInfo) GetPieceCid() string
- func (x *StorageDealInfo) GetPricePerEpoch() uint64
- func (x *StorageDealInfo) GetProposalCid() string
- func (x *StorageDealInfo) GetSize() uint64
- func (x *StorageDealInfo) GetStartEpoch() uint64
- func (x *StorageDealInfo) GetStateId() uint64
- func (x *StorageDealInfo) GetStateName() string
- func (*StorageDealInfo) ProtoMessage()
- func (x *StorageDealInfo) ProtoReflect() protoreflect.Message
- func (x *StorageDealInfo) Reset()
- func (x *StorageDealInfo) String() string
- type StorageDealRecord
- func (*StorageDealRecord) Descriptor() ([]byte, []int)deprecated
- func (x *StorageDealRecord) GetAddr() string
- func (x *StorageDealRecord) GetDealInfo() *StorageDealInfo
- func (x *StorageDealRecord) GetPending() bool
- func (x *StorageDealRecord) GetRootCid() string
- func (x *StorageDealRecord) GetTime() int64
- func (*StorageDealRecord) ProtoMessage()
- func (x *StorageDealRecord) ProtoReflect() protoreflect.Message
- func (x *StorageDealRecord) Reset()
- func (x *StorageDealRecord) String() string
- type StorageDealStatus
- func (StorageDealStatus) Descriptor() protoreflect.EnumDescriptor
- func (x StorageDealStatus) Enum() *StorageDealStatus
- func (StorageDealStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x StorageDealStatus) Number() protoreflect.EnumNumber
- func (x StorageDealStatus) String() string
- func (StorageDealStatus) Type() protoreflect.EnumType
- type StoreRequest
- func (*StoreRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StoreRequest) GetAddress() string
- func (x *StoreRequest) GetDataCid() string
- func (x *StoreRequest) GetMinDuration() uint64
- func (x *StoreRequest) GetPieceSize() uint64
- func (x *StoreRequest) GetStorageDealConfigs() []*StorageDealConfig
- func (*StoreRequest) ProtoMessage()
- func (x *StoreRequest) ProtoReflect() protoreflect.Message
- func (x *StoreRequest) Reset()
- func (x *StoreRequest) String() string
- type StoreResponse
- type StoreResult
- func (*StoreResult) Descriptor() ([]byte, []int)deprecated
- func (x *StoreResult) GetConfig() *StorageDealConfig
- func (x *StoreResult) GetMessage() string
- func (x *StoreResult) GetProposalCid() string
- func (x *StoreResult) GetSuccess() bool
- func (*StoreResult) ProtoMessage()
- func (x *StoreResult) ProtoReflect() protoreflect.Message
- func (x *StoreResult) Reset()
- func (x *StoreResult) String() string
- type UnimplementedRPCServiceServer
- func (*UnimplementedRPCServiceServer) Fetch(context.Context, *FetchRequest) (*FetchResponse, error)
- func (*UnimplementedRPCServiceServer) GetDealStatus(context.Context, *GetDealStatusRequest) (*GetDealStatusResponse, error)
- func (*UnimplementedRPCServiceServer) Import(RPCService_ImportServer) error
- func (*UnimplementedRPCServiceServer) ListRetrievalDealRecords(context.Context, *ListRetrievalDealRecordsRequest) (*ListRetrievalDealRecordsResponse, error)
- func (*UnimplementedRPCServiceServer) ListStorageDealRecords(context.Context, *ListStorageDealRecordsRequest) (*ListStorageDealRecordsResponse, error)
- func (*UnimplementedRPCServiceServer) Retrieve(*RetrieveRequest, RPCService_RetrieveServer) error
- func (*UnimplementedRPCServiceServer) Store(context.Context, *StoreRequest) (*StoreResponse, error)
- func (*UnimplementedRPCServiceServer) Watch(*WatchRequest, RPCService_WatchServer) error
- type WatchRequest
- type WatchResponse
Constants ¶
This section is empty.
Variables ¶
var ( StorageDealStatus_name = map[int32]string{ 0: "STORAGE_DEAL_STATUS_UNSPECIFIED", 1: "STORAGE_DEAL_STATUS_PROPOSAL_NOT_FOUND", 2: "STORAGE_DEAL_STATUS_PROPOSAL_REJECTED", 3: "STORAGE_DEAL_STATUS_PROPOSAL_ACCEPTED", 4: "STORAGE_DEAL_STATUS_STAGED", 5: "STORAGE_DEAL_STATUS_SEALING", 6: "STORAGE_DEAL_STATUS_ACTIVE", 7: "STORAGE_DEAL_STATUS_FAILING", 8: "STORAGE_DEAL_STATUS_NOT_FOUND", } StorageDealStatus_value = map[string]int32{ "STORAGE_DEAL_STATUS_UNSPECIFIED": 0, "STORAGE_DEAL_STATUS_PROPOSAL_NOT_FOUND": 1, "STORAGE_DEAL_STATUS_PROPOSAL_REJECTED": 2, "STORAGE_DEAL_STATUS_PROPOSAL_ACCEPTED": 3, "STORAGE_DEAL_STATUS_STAGED": 4, "STORAGE_DEAL_STATUS_SEALING": 5, "STORAGE_DEAL_STATUS_ACTIVE": 6, "STORAGE_DEAL_STATUS_FAILING": 7, "STORAGE_DEAL_STATUS_NOT_FOUND": 8, } )
Enum value maps for StorageDealStatus.
var File_deals_rpc_rpc_proto protoreflect.FileDescriptor
Functions ¶
func BuildListDealRecordsOptions ¶
func BuildListDealRecordsOptions(conf *ListDealRecordsConfig) []deals.ListDealRecordsOption
BuildListDealRecordsOptions creates a ListDealRecordsOption from a ListDealRecordsConfig.
func RegisterRPCServiceServer ¶
func RegisterRPCServiceServer(s *grpc.Server, srv RPCServiceServer)
Types ¶
type FetchRequest ¶
type FetchRequest struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Cid string `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"` // contains filtered or unexported fields }
func (*FetchRequest) Descriptor
deprecated
func (*FetchRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchRequest.ProtoReflect.Descriptor instead.
func (*FetchRequest) GetAddress ¶
func (x *FetchRequest) GetAddress() string
func (*FetchRequest) GetCid ¶
func (x *FetchRequest) GetCid() string
func (*FetchRequest) ProtoMessage ¶
func (*FetchRequest) ProtoMessage()
func (*FetchRequest) ProtoReflect ¶
func (x *FetchRequest) ProtoReflect() protoreflect.Message
func (*FetchRequest) Reset ¶
func (x *FetchRequest) Reset()
func (*FetchRequest) String ¶
func (x *FetchRequest) String() string
type FetchResponse ¶
type FetchResponse struct {
// contains filtered or unexported fields
}
func (*FetchResponse) Descriptor
deprecated
func (*FetchResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchResponse.ProtoReflect.Descriptor instead.
func (*FetchResponse) ProtoMessage ¶
func (*FetchResponse) ProtoMessage()
func (*FetchResponse) ProtoReflect ¶
func (x *FetchResponse) ProtoReflect() protoreflect.Message
func (*FetchResponse) Reset ¶
func (x *FetchResponse) Reset()
func (*FetchResponse) String ¶
func (x *FetchResponse) String() string
type GetDealStatusRequest ¶
type GetDealStatusRequest struct { ProposalCid string `protobuf:"bytes,1,opt,name=proposal_cid,json=proposalCid,proto3" json:"proposal_cid,omitempty"` // contains filtered or unexported fields }
func (*GetDealStatusRequest) Descriptor
deprecated
func (*GetDealStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDealStatusRequest.ProtoReflect.Descriptor instead.
func (*GetDealStatusRequest) GetProposalCid ¶
func (x *GetDealStatusRequest) GetProposalCid() string
func (*GetDealStatusRequest) ProtoMessage ¶
func (*GetDealStatusRequest) ProtoMessage()
func (*GetDealStatusRequest) ProtoReflect ¶
func (x *GetDealStatusRequest) ProtoReflect() protoreflect.Message
func (*GetDealStatusRequest) Reset ¶
func (x *GetDealStatusRequest) Reset()
func (*GetDealStatusRequest) String ¶
func (x *GetDealStatusRequest) String() string
type GetDealStatusResponse ¶
type GetDealStatusResponse struct { Status StorageDealStatus `protobuf:"varint,1,opt,name=status,proto3,enum=deals.rpc.StorageDealStatus" json:"status,omitempty"` Slashed bool `protobuf:"varint,2,opt,name=slashed,proto3" json:"slashed,omitempty"` // contains filtered or unexported fields }
func (*GetDealStatusResponse) Descriptor
deprecated
func (*GetDealStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetDealStatusResponse.ProtoReflect.Descriptor instead.
func (*GetDealStatusResponse) GetSlashed ¶
func (x *GetDealStatusResponse) GetSlashed() bool
func (*GetDealStatusResponse) GetStatus ¶
func (x *GetDealStatusResponse) GetStatus() StorageDealStatus
func (*GetDealStatusResponse) ProtoMessage ¶
func (*GetDealStatusResponse) ProtoMessage()
func (*GetDealStatusResponse) ProtoReflect ¶
func (x *GetDealStatusResponse) ProtoReflect() protoreflect.Message
func (*GetDealStatusResponse) Reset ¶
func (x *GetDealStatusResponse) Reset()
func (*GetDealStatusResponse) String ¶
func (x *GetDealStatusResponse) String() string
type ImportParams ¶
type ImportParams struct { IsCar bool `protobuf:"varint,1,opt,name=is_car,json=isCar,proto3" json:"is_car,omitempty"` // contains filtered or unexported fields }
func (*ImportParams) Descriptor
deprecated
func (*ImportParams) Descriptor() ([]byte, []int)
Deprecated: Use ImportParams.ProtoReflect.Descriptor instead.
func (*ImportParams) GetIsCar ¶
func (x *ImportParams) GetIsCar() bool
func (*ImportParams) ProtoMessage ¶
func (*ImportParams) ProtoMessage()
func (*ImportParams) ProtoReflect ¶
func (x *ImportParams) ProtoReflect() protoreflect.Message
func (*ImportParams) Reset ¶
func (x *ImportParams) Reset()
func (*ImportParams) String ¶
func (x *ImportParams) String() string
type ImportRequest ¶
type ImportRequest struct { // Types that are assignable to Payload: // *ImportRequest_ImportParams // *ImportRequest_Chunk Payload isImportRequest_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
func (*ImportRequest) Descriptor
deprecated
func (*ImportRequest) Descriptor() ([]byte, []int)
Deprecated: Use ImportRequest.ProtoReflect.Descriptor instead.
func (*ImportRequest) GetChunk ¶
func (x *ImportRequest) GetChunk() []byte
func (*ImportRequest) GetImportParams ¶
func (x *ImportRequest) GetImportParams() *ImportParams
func (*ImportRequest) GetPayload ¶
func (m *ImportRequest) GetPayload() isImportRequest_Payload
func (*ImportRequest) ProtoMessage ¶
func (*ImportRequest) ProtoMessage()
func (*ImportRequest) ProtoReflect ¶
func (x *ImportRequest) ProtoReflect() protoreflect.Message
func (*ImportRequest) Reset ¶
func (x *ImportRequest) Reset()
func (*ImportRequest) String ¶
func (x *ImportRequest) String() string
type ImportRequest_Chunk ¶
type ImportRequest_Chunk struct {
Chunk []byte `protobuf:"bytes,2,opt,name=chunk,proto3,oneof"`
}
type ImportRequest_ImportParams ¶
type ImportRequest_ImportParams struct {
ImportParams *ImportParams `protobuf:"bytes,1,opt,name=import_params,json=importParams,proto3,oneof"`
}
type ImportResponse ¶
type ImportResponse struct { DataCid string `protobuf:"bytes,1,opt,name=data_cid,json=dataCid,proto3" json:"data_cid,omitempty"` Size int64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` // contains filtered or unexported fields }
func (*ImportResponse) Descriptor
deprecated
func (*ImportResponse) Descriptor() ([]byte, []int)
Deprecated: Use ImportResponse.ProtoReflect.Descriptor instead.
func (*ImportResponse) GetDataCid ¶
func (x *ImportResponse) GetDataCid() string
func (*ImportResponse) GetSize ¶
func (x *ImportResponse) GetSize() int64
func (*ImportResponse) ProtoMessage ¶
func (*ImportResponse) ProtoMessage()
func (*ImportResponse) ProtoReflect ¶
func (x *ImportResponse) ProtoReflect() protoreflect.Message
func (*ImportResponse) Reset ¶
func (x *ImportResponse) Reset()
func (*ImportResponse) String ¶
func (x *ImportResponse) String() string
type ListDealRecordsConfig ¶
type ListDealRecordsConfig struct { FromAddrs []string `protobuf:"bytes,1,rep,name=from_addrs,json=fromAddrs,proto3" json:"from_addrs,omitempty"` DataCids []string `protobuf:"bytes,2,rep,name=data_cids,json=dataCids,proto3" json:"data_cids,omitempty"` IncludePending bool `protobuf:"varint,3,opt,name=include_pending,json=includePending,proto3" json:"include_pending,omitempty"` IncludeFinal bool `protobuf:"varint,4,opt,name=include_final,json=includeFinal,proto3" json:"include_final,omitempty"` Ascending bool `protobuf:"varint,5,opt,name=ascending,proto3" json:"ascending,omitempty"` // contains filtered or unexported fields }
func (*ListDealRecordsConfig) Descriptor
deprecated
func (*ListDealRecordsConfig) Descriptor() ([]byte, []int)
Deprecated: Use ListDealRecordsConfig.ProtoReflect.Descriptor instead.
func (*ListDealRecordsConfig) GetAscending ¶
func (x *ListDealRecordsConfig) GetAscending() bool
func (*ListDealRecordsConfig) GetDataCids ¶
func (x *ListDealRecordsConfig) GetDataCids() []string
func (*ListDealRecordsConfig) GetFromAddrs ¶
func (x *ListDealRecordsConfig) GetFromAddrs() []string
func (*ListDealRecordsConfig) GetIncludeFinal ¶
func (x *ListDealRecordsConfig) GetIncludeFinal() bool
func (*ListDealRecordsConfig) GetIncludePending ¶
func (x *ListDealRecordsConfig) GetIncludePending() bool
func (*ListDealRecordsConfig) ProtoMessage ¶
func (*ListDealRecordsConfig) ProtoMessage()
func (*ListDealRecordsConfig) ProtoReflect ¶
func (x *ListDealRecordsConfig) ProtoReflect() protoreflect.Message
func (*ListDealRecordsConfig) Reset ¶
func (x *ListDealRecordsConfig) Reset()
func (*ListDealRecordsConfig) String ¶
func (x *ListDealRecordsConfig) String() string
type ListRetrievalDealRecordsRequest ¶
type ListRetrievalDealRecordsRequest struct { Config *ListDealRecordsConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
func (*ListRetrievalDealRecordsRequest) Descriptor
deprecated
func (*ListRetrievalDealRecordsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRetrievalDealRecordsRequest.ProtoReflect.Descriptor instead.
func (*ListRetrievalDealRecordsRequest) GetConfig ¶
func (x *ListRetrievalDealRecordsRequest) GetConfig() *ListDealRecordsConfig
func (*ListRetrievalDealRecordsRequest) ProtoMessage ¶
func (*ListRetrievalDealRecordsRequest) ProtoMessage()
func (*ListRetrievalDealRecordsRequest) ProtoReflect ¶
func (x *ListRetrievalDealRecordsRequest) ProtoReflect() protoreflect.Message
func (*ListRetrievalDealRecordsRequest) Reset ¶
func (x *ListRetrievalDealRecordsRequest) Reset()
func (*ListRetrievalDealRecordsRequest) String ¶
func (x *ListRetrievalDealRecordsRequest) String() string
type ListRetrievalDealRecordsResponse ¶
type ListRetrievalDealRecordsResponse struct { Records []*RetrievalDealRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"` // contains filtered or unexported fields }
func (*ListRetrievalDealRecordsResponse) Descriptor
deprecated
func (*ListRetrievalDealRecordsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListRetrievalDealRecordsResponse.ProtoReflect.Descriptor instead.
func (*ListRetrievalDealRecordsResponse) GetRecords ¶
func (x *ListRetrievalDealRecordsResponse) GetRecords() []*RetrievalDealRecord
func (*ListRetrievalDealRecordsResponse) ProtoMessage ¶
func (*ListRetrievalDealRecordsResponse) ProtoMessage()
func (*ListRetrievalDealRecordsResponse) ProtoReflect ¶
func (x *ListRetrievalDealRecordsResponse) ProtoReflect() protoreflect.Message
func (*ListRetrievalDealRecordsResponse) Reset ¶
func (x *ListRetrievalDealRecordsResponse) Reset()
func (*ListRetrievalDealRecordsResponse) String ¶
func (x *ListRetrievalDealRecordsResponse) String() string
type ListStorageDealRecordsRequest ¶
type ListStorageDealRecordsRequest struct { Config *ListDealRecordsConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
func (*ListStorageDealRecordsRequest) Descriptor
deprecated
func (*ListStorageDealRecordsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListStorageDealRecordsRequest.ProtoReflect.Descriptor instead.
func (*ListStorageDealRecordsRequest) GetConfig ¶
func (x *ListStorageDealRecordsRequest) GetConfig() *ListDealRecordsConfig
func (*ListStorageDealRecordsRequest) ProtoMessage ¶
func (*ListStorageDealRecordsRequest) ProtoMessage()
func (*ListStorageDealRecordsRequest) ProtoReflect ¶
func (x *ListStorageDealRecordsRequest) ProtoReflect() protoreflect.Message
func (*ListStorageDealRecordsRequest) Reset ¶
func (x *ListStorageDealRecordsRequest) Reset()
func (*ListStorageDealRecordsRequest) String ¶
func (x *ListStorageDealRecordsRequest) String() string
type ListStorageDealRecordsResponse ¶
type ListStorageDealRecordsResponse struct { Records []*StorageDealRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"` // contains filtered or unexported fields }
func (*ListStorageDealRecordsResponse) Descriptor
deprecated
func (*ListStorageDealRecordsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListStorageDealRecordsResponse.ProtoReflect.Descriptor instead.
func (*ListStorageDealRecordsResponse) GetRecords ¶
func (x *ListStorageDealRecordsResponse) GetRecords() []*StorageDealRecord
func (*ListStorageDealRecordsResponse) ProtoMessage ¶
func (*ListStorageDealRecordsResponse) ProtoMessage()
func (*ListStorageDealRecordsResponse) ProtoReflect ¶
func (x *ListStorageDealRecordsResponse) ProtoReflect() protoreflect.Message
func (*ListStorageDealRecordsResponse) Reset ¶
func (x *ListStorageDealRecordsResponse) Reset()
func (*ListStorageDealRecordsResponse) String ¶
func (x *ListStorageDealRecordsResponse) String() string
type Module ¶
type Module interface { Import(ctx context.Context, data io.Reader, isCAR bool) (cid.Cid, int64, error) Store(ctx context.Context, waddr string, dataCid cid.Cid, pieceSize uint64, dcfgs []deals.StorageDealConfig, minDuration uint64) ([]deals.StoreResult, error) Fetch(ctx context.Context, waddr string, cid cid.Cid) error Retrieve(ctx context.Context, waddr string, cid cid.Cid, CAREncoding bool) (io.ReadCloser, error) GetDealStatus(ctx context.Context, pcid cid.Cid) (storagemarket.StorageDealStatus, bool, error) Watch(ctx context.Context, proposals []cid.Cid) (<-chan deals.StorageDealInfo, error) ListStorageDealRecords(opts ...deals.ListDealRecordsOption) ([]deals.StorageDealRecord, error) ListRetrievalDealRecords(opts ...deals.ListDealRecordsOption) ([]deals.RetrievalDealRecord, error) }
Module is an implementation of the Deals Module.
type RPC ¶
type RPC struct { UnimplementedRPCServiceServer Module Module }
RPC implements the gprc service.
func (*RPC) Fetch ¶
func (s *RPC) Fetch(ctx context.Context, req *FetchRequest) (*FetchResponse, error)
Fetch calls deals.Fetch.
func (*RPC) GetDealStatus ¶
func (s *RPC) GetDealStatus(ctx context.Context, req *GetDealStatusRequest) (*GetDealStatusResponse, error)
GetDealStatus calls deals.GetDealStatus.
func (*RPC) Import ¶
func (s *RPC) Import(srv RPCService_ImportServer) error
Import calls deals.Import.
func (*RPC) ListRetrievalDealRecords ¶
func (s *RPC) ListRetrievalDealRecords(ctx context.Context, req *ListRetrievalDealRecordsRequest) (*ListRetrievalDealRecordsResponse, error)
ListRetrievalDealRecords calls deals.ListRetrievalDealRecords.
func (*RPC) ListStorageDealRecords ¶
func (s *RPC) ListStorageDealRecords(ctx context.Context, req *ListStorageDealRecordsRequest) (*ListStorageDealRecordsResponse, error)
ListStorageDealRecords calls deals.ListStorageDealRecords.
func (*RPC) Retrieve ¶
func (s *RPC) Retrieve(req *RetrieveRequest, srv RPCService_RetrieveServer) error
Retrieve calls deals.Retreive.
func (*RPC) Store ¶
func (s *RPC) Store(ctx context.Context, req *StoreRequest) (*StoreResponse, error)
Store calls deals.Store.
func (*RPC) Watch ¶
func (s *RPC) Watch(req *WatchRequest, srv RPCService_WatchServer) error
Watch calls deals.Watch.
type RPCServiceClient ¶
type RPCServiceClient interface { Import(ctx context.Context, opts ...grpc.CallOption) (RPCService_ImportClient, error) Store(ctx context.Context, in *StoreRequest, opts ...grpc.CallOption) (*StoreResponse, error) Fetch(ctx context.Context, in *FetchRequest, opts ...grpc.CallOption) (*FetchResponse, error) Retrieve(ctx context.Context, in *RetrieveRequest, opts ...grpc.CallOption) (RPCService_RetrieveClient, error) GetDealStatus(ctx context.Context, in *GetDealStatusRequest, opts ...grpc.CallOption) (*GetDealStatusResponse, error) Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (RPCService_WatchClient, error) ListStorageDealRecords(ctx context.Context, in *ListStorageDealRecordsRequest, opts ...grpc.CallOption) (*ListStorageDealRecordsResponse, error) ListRetrievalDealRecords(ctx context.Context, in *ListRetrievalDealRecordsRequest, opts ...grpc.CallOption) (*ListRetrievalDealRecordsResponse, error) }
RPCServiceClient is the client API for RPCService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRPCServiceClient ¶
func NewRPCServiceClient(cc grpc.ClientConnInterface) RPCServiceClient
type RPCServiceServer ¶
type RPCServiceServer interface { Import(RPCService_ImportServer) error Store(context.Context, *StoreRequest) (*StoreResponse, error) Fetch(context.Context, *FetchRequest) (*FetchResponse, error) Retrieve(*RetrieveRequest, RPCService_RetrieveServer) error GetDealStatus(context.Context, *GetDealStatusRequest) (*GetDealStatusResponse, error) Watch(*WatchRequest, RPCService_WatchServer) error ListStorageDealRecords(context.Context, *ListStorageDealRecordsRequest) (*ListStorageDealRecordsResponse, error) ListRetrievalDealRecords(context.Context, *ListRetrievalDealRecordsRequest) (*ListRetrievalDealRecordsResponse, error) }
RPCServiceServer is the server API for RPCService service.
type RPCService_ImportClient ¶
type RPCService_ImportClient interface { Send(*ImportRequest) error CloseAndRecv() (*ImportResponse, error) grpc.ClientStream }
type RPCService_ImportServer ¶
type RPCService_ImportServer interface { SendAndClose(*ImportResponse) error Recv() (*ImportRequest, error) grpc.ServerStream }
type RPCService_RetrieveClient ¶
type RPCService_RetrieveClient interface { Recv() (*RetrieveResponse, error) grpc.ClientStream }
type RPCService_RetrieveServer ¶
type RPCService_RetrieveServer interface { Send(*RetrieveResponse) error grpc.ServerStream }
type RPCService_WatchClient ¶
type RPCService_WatchClient interface { Recv() (*WatchResponse, error) grpc.ClientStream }
type RPCService_WatchServer ¶
type RPCService_WatchServer interface { Send(*WatchResponse) error grpc.ServerStream }
type RetrievalDealInfo ¶
type RetrievalDealInfo struct { RootCid string `protobuf:"bytes,1,opt,name=root_cid,json=rootCid,proto3" json:"root_cid,omitempty"` Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` MinPrice uint64 `protobuf:"varint,3,opt,name=min_price,json=minPrice,proto3" json:"min_price,omitempty"` PaymentInterval uint64 `protobuf:"varint,4,opt,name=payment_interval,json=paymentInterval,proto3" json:"payment_interval,omitempty"` PaymentIntervalIncrease uint64 `` /* 133-byte string literal not displayed */ Miner string `protobuf:"bytes,6,opt,name=miner,proto3" json:"miner,omitempty"` MinerPeerId string `protobuf:"bytes,7,opt,name=miner_peer_id,json=minerPeerId,proto3" json:"miner_peer_id,omitempty"` // contains filtered or unexported fields }
func (*RetrievalDealInfo) Descriptor
deprecated
func (*RetrievalDealInfo) Descriptor() ([]byte, []int)
Deprecated: Use RetrievalDealInfo.ProtoReflect.Descriptor instead.
func (*RetrievalDealInfo) GetMinPrice ¶
func (x *RetrievalDealInfo) GetMinPrice() uint64
func (*RetrievalDealInfo) GetMiner ¶
func (x *RetrievalDealInfo) GetMiner() string
func (*RetrievalDealInfo) GetMinerPeerId ¶
func (x *RetrievalDealInfo) GetMinerPeerId() string
func (*RetrievalDealInfo) GetPaymentInterval ¶
func (x *RetrievalDealInfo) GetPaymentInterval() uint64
func (*RetrievalDealInfo) GetPaymentIntervalIncrease ¶
func (x *RetrievalDealInfo) GetPaymentIntervalIncrease() uint64
func (*RetrievalDealInfo) GetRootCid ¶
func (x *RetrievalDealInfo) GetRootCid() string
func (*RetrievalDealInfo) GetSize ¶
func (x *RetrievalDealInfo) GetSize() uint64
func (*RetrievalDealInfo) ProtoMessage ¶
func (*RetrievalDealInfo) ProtoMessage()
func (*RetrievalDealInfo) ProtoReflect ¶
func (x *RetrievalDealInfo) ProtoReflect() protoreflect.Message
func (*RetrievalDealInfo) Reset ¶
func (x *RetrievalDealInfo) Reset()
func (*RetrievalDealInfo) String ¶
func (x *RetrievalDealInfo) String() string
type RetrievalDealRecord ¶
type RetrievalDealRecord struct { Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"` Time int64 `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"` DealInfo *RetrievalDealInfo `protobuf:"bytes,3,opt,name=deal_info,json=dealInfo,proto3" json:"deal_info,omitempty"` // contains filtered or unexported fields }
func ToRPCRetrievalDealRecords ¶
func ToRPCRetrievalDealRecords(records []deals.RetrievalDealRecord) []*RetrievalDealRecord
ToRPCRetrievalDealRecords converts from Go to gRPC representations.
func (*RetrievalDealRecord) Descriptor
deprecated
func (*RetrievalDealRecord) Descriptor() ([]byte, []int)
Deprecated: Use RetrievalDealRecord.ProtoReflect.Descriptor instead.
func (*RetrievalDealRecord) GetAddr ¶
func (x *RetrievalDealRecord) GetAddr() string
func (*RetrievalDealRecord) GetDealInfo ¶
func (x *RetrievalDealRecord) GetDealInfo() *RetrievalDealInfo
func (*RetrievalDealRecord) GetTime ¶
func (x *RetrievalDealRecord) GetTime() int64
func (*RetrievalDealRecord) ProtoMessage ¶
func (*RetrievalDealRecord) ProtoMessage()
func (*RetrievalDealRecord) ProtoReflect ¶
func (x *RetrievalDealRecord) ProtoReflect() protoreflect.Message
func (*RetrievalDealRecord) Reset ¶
func (x *RetrievalDealRecord) Reset()
func (*RetrievalDealRecord) String ¶
func (x *RetrievalDealRecord) String() string
type RetrieveRequest ¶
type RetrieveRequest struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Cid string `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"` CarEncoding bool `protobuf:"varint,3,opt,name=car_encoding,json=carEncoding,proto3" json:"car_encoding,omitempty"` // contains filtered or unexported fields }
func (*RetrieveRequest) Descriptor
deprecated
func (*RetrieveRequest) Descriptor() ([]byte, []int)
Deprecated: Use RetrieveRequest.ProtoReflect.Descriptor instead.
func (*RetrieveRequest) GetAddress ¶
func (x *RetrieveRequest) GetAddress() string
func (*RetrieveRequest) GetCarEncoding ¶
func (x *RetrieveRequest) GetCarEncoding() bool
func (*RetrieveRequest) GetCid ¶
func (x *RetrieveRequest) GetCid() string
func (*RetrieveRequest) ProtoMessage ¶
func (*RetrieveRequest) ProtoMessage()
func (*RetrieveRequest) ProtoReflect ¶
func (x *RetrieveRequest) ProtoReflect() protoreflect.Message
func (*RetrieveRequest) Reset ¶
func (x *RetrieveRequest) Reset()
func (*RetrieveRequest) String ¶
func (x *RetrieveRequest) String() string
type RetrieveResponse ¶
type RetrieveResponse struct { Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"` // contains filtered or unexported fields }
func (*RetrieveResponse) Descriptor
deprecated
func (*RetrieveResponse) Descriptor() ([]byte, []int)
Deprecated: Use RetrieveResponse.ProtoReflect.Descriptor instead.
func (*RetrieveResponse) GetChunk ¶
func (x *RetrieveResponse) GetChunk() []byte
func (*RetrieveResponse) ProtoMessage ¶
func (*RetrieveResponse) ProtoMessage()
func (*RetrieveResponse) ProtoReflect ¶
func (x *RetrieveResponse) ProtoReflect() protoreflect.Message
func (*RetrieveResponse) Reset ¶
func (x *RetrieveResponse) Reset()
func (*RetrieveResponse) String ¶
func (x *RetrieveResponse) String() string
type StorageDealConfig ¶
type StorageDealConfig struct { Miner string `protobuf:"bytes,1,opt,name=miner,proto3" json:"miner,omitempty"` EpochPrice uint64 `protobuf:"varint,2,opt,name=epoch_price,json=epochPrice,proto3" json:"epoch_price,omitempty"` // contains filtered or unexported fields }
func (*StorageDealConfig) Descriptor
deprecated
func (*StorageDealConfig) Descriptor() ([]byte, []int)
Deprecated: Use StorageDealConfig.ProtoReflect.Descriptor instead.
func (*StorageDealConfig) GetEpochPrice ¶
func (x *StorageDealConfig) GetEpochPrice() uint64
func (*StorageDealConfig) GetMiner ¶
func (x *StorageDealConfig) GetMiner() string
func (*StorageDealConfig) ProtoMessage ¶
func (*StorageDealConfig) ProtoMessage()
func (*StorageDealConfig) ProtoReflect ¶
func (x *StorageDealConfig) ProtoReflect() protoreflect.Message
func (*StorageDealConfig) Reset ¶
func (x *StorageDealConfig) Reset()
func (*StorageDealConfig) String ¶
func (x *StorageDealConfig) String() string
type StorageDealInfo ¶
type StorageDealInfo struct { ProposalCid string `protobuf:"bytes,1,opt,name=proposal_cid,json=proposalCid,proto3" json:"proposal_cid,omitempty"` StateId uint64 `protobuf:"varint,2,opt,name=state_id,json=stateId,proto3" json:"state_id,omitempty"` StateName string `protobuf:"bytes,3,opt,name=state_name,json=stateName,proto3" json:"state_name,omitempty"` Miner string `protobuf:"bytes,4,opt,name=miner,proto3" json:"miner,omitempty"` PieceCid string `protobuf:"bytes,5,opt,name=piece_cid,json=pieceCid,proto3" json:"piece_cid,omitempty"` Size uint64 `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"` PricePerEpoch uint64 `protobuf:"varint,7,opt,name=price_per_epoch,json=pricePerEpoch,proto3" json:"price_per_epoch,omitempty"` StartEpoch uint64 `protobuf:"varint,8,opt,name=start_epoch,json=startEpoch,proto3" json:"start_epoch,omitempty"` Duration uint64 `protobuf:"varint,9,opt,name=duration,proto3" json:"duration,omitempty"` DealId uint64 `protobuf:"varint,10,opt,name=deal_id,json=dealId,proto3" json:"deal_id,omitempty"` ActivationEpoch int64 `protobuf:"varint,11,opt,name=activation_epoch,json=activationEpoch,proto3" json:"activation_epoch,omitempty"` Msg string `protobuf:"bytes,12,opt,name=msg,proto3" json:"msg,omitempty"` // contains filtered or unexported fields }
func (*StorageDealInfo) Descriptor
deprecated
func (*StorageDealInfo) Descriptor() ([]byte, []int)
Deprecated: Use StorageDealInfo.ProtoReflect.Descriptor instead.
func (*StorageDealInfo) GetActivationEpoch ¶
func (x *StorageDealInfo) GetActivationEpoch() int64
func (*StorageDealInfo) GetDealId ¶
func (x *StorageDealInfo) GetDealId() uint64
func (*StorageDealInfo) GetDuration ¶
func (x *StorageDealInfo) GetDuration() uint64
func (*StorageDealInfo) GetMiner ¶
func (x *StorageDealInfo) GetMiner() string
func (*StorageDealInfo) GetMsg ¶
func (x *StorageDealInfo) GetMsg() string
func (*StorageDealInfo) GetPieceCid ¶
func (x *StorageDealInfo) GetPieceCid() string
func (*StorageDealInfo) GetPricePerEpoch ¶
func (x *StorageDealInfo) GetPricePerEpoch() uint64
func (*StorageDealInfo) GetProposalCid ¶
func (x *StorageDealInfo) GetProposalCid() string
func (*StorageDealInfo) GetSize ¶
func (x *StorageDealInfo) GetSize() uint64
func (*StorageDealInfo) GetStartEpoch ¶
func (x *StorageDealInfo) GetStartEpoch() uint64
func (*StorageDealInfo) GetStateId ¶
func (x *StorageDealInfo) GetStateId() uint64
func (*StorageDealInfo) GetStateName ¶
func (x *StorageDealInfo) GetStateName() string
func (*StorageDealInfo) ProtoMessage ¶
func (*StorageDealInfo) ProtoMessage()
func (*StorageDealInfo) ProtoReflect ¶
func (x *StorageDealInfo) ProtoReflect() protoreflect.Message
func (*StorageDealInfo) Reset ¶
func (x *StorageDealInfo) Reset()
func (*StorageDealInfo) String ¶
func (x *StorageDealInfo) String() string
type StorageDealRecord ¶
type StorageDealRecord struct { RootCid string `protobuf:"bytes,1,opt,name=root_cid,json=rootCid,proto3" json:"root_cid,omitempty"` Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"` Time int64 `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"` Pending bool `protobuf:"varint,4,opt,name=pending,proto3" json:"pending,omitempty"` DealInfo *StorageDealInfo `protobuf:"bytes,5,opt,name=deal_info,json=dealInfo,proto3" json:"deal_info,omitempty"` // contains filtered or unexported fields }
func ToRPCStorageDealRecords ¶
func ToRPCStorageDealRecords(records []deals.StorageDealRecord) []*StorageDealRecord
ToRPCStorageDealRecords converts from Go to gRPC representations.
func (*StorageDealRecord) Descriptor
deprecated
func (*StorageDealRecord) Descriptor() ([]byte, []int)
Deprecated: Use StorageDealRecord.ProtoReflect.Descriptor instead.
func (*StorageDealRecord) GetAddr ¶
func (x *StorageDealRecord) GetAddr() string
func (*StorageDealRecord) GetDealInfo ¶
func (x *StorageDealRecord) GetDealInfo() *StorageDealInfo
func (*StorageDealRecord) GetPending ¶
func (x *StorageDealRecord) GetPending() bool
func (*StorageDealRecord) GetRootCid ¶
func (x *StorageDealRecord) GetRootCid() string
func (*StorageDealRecord) GetTime ¶
func (x *StorageDealRecord) GetTime() int64
func (*StorageDealRecord) ProtoMessage ¶
func (*StorageDealRecord) ProtoMessage()
func (*StorageDealRecord) ProtoReflect ¶
func (x *StorageDealRecord) ProtoReflect() protoreflect.Message
func (*StorageDealRecord) Reset ¶
func (x *StorageDealRecord) Reset()
func (*StorageDealRecord) String ¶
func (x *StorageDealRecord) String() string
type StorageDealStatus ¶
type StorageDealStatus int32
const ( StorageDealStatus_STORAGE_DEAL_STATUS_UNSPECIFIED StorageDealStatus = 0 StorageDealStatus_STORAGE_DEAL_STATUS_PROPOSAL_NOT_FOUND StorageDealStatus = 1 StorageDealStatus_STORAGE_DEAL_STATUS_PROPOSAL_REJECTED StorageDealStatus = 2 StorageDealStatus_STORAGE_DEAL_STATUS_PROPOSAL_ACCEPTED StorageDealStatus = 3 StorageDealStatus_STORAGE_DEAL_STATUS_STAGED StorageDealStatus = 4 StorageDealStatus_STORAGE_DEAL_STATUS_SEALING StorageDealStatus = 5 StorageDealStatus_STORAGE_DEAL_STATUS_ACTIVE StorageDealStatus = 6 StorageDealStatus_STORAGE_DEAL_STATUS_FAILING StorageDealStatus = 7 StorageDealStatus_STORAGE_DEAL_STATUS_NOT_FOUND StorageDealStatus = 8 )
func (StorageDealStatus) Descriptor ¶
func (StorageDealStatus) Descriptor() protoreflect.EnumDescriptor
func (StorageDealStatus) Enum ¶
func (x StorageDealStatus) Enum() *StorageDealStatus
func (StorageDealStatus) EnumDescriptor
deprecated
func (StorageDealStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use StorageDealStatus.Descriptor instead.
func (StorageDealStatus) Number ¶
func (x StorageDealStatus) Number() protoreflect.EnumNumber
func (StorageDealStatus) String ¶
func (x StorageDealStatus) String() string
func (StorageDealStatus) Type ¶
func (StorageDealStatus) Type() protoreflect.EnumType
type StoreRequest ¶
type StoreRequest struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` DataCid string `protobuf:"bytes,2,opt,name=data_cid,json=dataCid,proto3" json:"data_cid,omitempty"` PieceSize uint64 `protobuf:"varint,3,opt,name=piece_size,json=pieceSize,proto3" json:"piece_size,omitempty"` StorageDealConfigs []*StorageDealConfig `protobuf:"bytes,4,rep,name=storage_deal_configs,json=storageDealConfigs,proto3" json:"storage_deal_configs,omitempty"` MinDuration uint64 `protobuf:"varint,5,opt,name=min_duration,json=minDuration,proto3" json:"min_duration,omitempty"` // contains filtered or unexported fields }
func (*StoreRequest) Descriptor
deprecated
func (*StoreRequest) Descriptor() ([]byte, []int)
Deprecated: Use StoreRequest.ProtoReflect.Descriptor instead.
func (*StoreRequest) GetAddress ¶
func (x *StoreRequest) GetAddress() string
func (*StoreRequest) GetDataCid ¶
func (x *StoreRequest) GetDataCid() string
func (*StoreRequest) GetMinDuration ¶
func (x *StoreRequest) GetMinDuration() uint64
func (*StoreRequest) GetPieceSize ¶
func (x *StoreRequest) GetPieceSize() uint64
func (*StoreRequest) GetStorageDealConfigs ¶
func (x *StoreRequest) GetStorageDealConfigs() []*StorageDealConfig
func (*StoreRequest) ProtoMessage ¶
func (*StoreRequest) ProtoMessage()
func (*StoreRequest) ProtoReflect ¶
func (x *StoreRequest) ProtoReflect() protoreflect.Message
func (*StoreRequest) Reset ¶
func (x *StoreRequest) Reset()
func (*StoreRequest) String ¶
func (x *StoreRequest) String() string
type StoreResponse ¶
type StoreResponse struct { Results []*StoreResult `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"` // contains filtered or unexported fields }
func (*StoreResponse) Descriptor
deprecated
func (*StoreResponse) Descriptor() ([]byte, []int)
Deprecated: Use StoreResponse.ProtoReflect.Descriptor instead.
func (*StoreResponse) GetResults ¶
func (x *StoreResponse) GetResults() []*StoreResult
func (*StoreResponse) ProtoMessage ¶
func (*StoreResponse) ProtoMessage()
func (*StoreResponse) ProtoReflect ¶
func (x *StoreResponse) ProtoReflect() protoreflect.Message
func (*StoreResponse) Reset ¶
func (x *StoreResponse) Reset()
func (*StoreResponse) String ¶
func (x *StoreResponse) String() string
type StoreResult ¶
type StoreResult struct { ProposalCid string `protobuf:"bytes,1,opt,name=proposal_cid,json=proposalCid,proto3" json:"proposal_cid,omitempty"` Config *StorageDealConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"` Success bool `protobuf:"varint,3,opt,name=success,proto3" json:"success,omitempty"` Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*StoreResult) Descriptor
deprecated
func (*StoreResult) Descriptor() ([]byte, []int)
Deprecated: Use StoreResult.ProtoReflect.Descriptor instead.
func (*StoreResult) GetConfig ¶
func (x *StoreResult) GetConfig() *StorageDealConfig
func (*StoreResult) GetMessage ¶
func (x *StoreResult) GetMessage() string
func (*StoreResult) GetProposalCid ¶
func (x *StoreResult) GetProposalCid() string
func (*StoreResult) GetSuccess ¶
func (x *StoreResult) GetSuccess() bool
func (*StoreResult) ProtoMessage ¶
func (*StoreResult) ProtoMessage()
func (*StoreResult) ProtoReflect ¶
func (x *StoreResult) ProtoReflect() protoreflect.Message
func (*StoreResult) Reset ¶
func (x *StoreResult) Reset()
func (*StoreResult) String ¶
func (x *StoreResult) String() string
type UnimplementedRPCServiceServer ¶
type UnimplementedRPCServiceServer struct { }
UnimplementedRPCServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedRPCServiceServer) Fetch ¶
func (*UnimplementedRPCServiceServer) Fetch(context.Context, *FetchRequest) (*FetchResponse, error)
func (*UnimplementedRPCServiceServer) GetDealStatus ¶
func (*UnimplementedRPCServiceServer) GetDealStatus(context.Context, *GetDealStatusRequest) (*GetDealStatusResponse, error)
func (*UnimplementedRPCServiceServer) Import ¶
func (*UnimplementedRPCServiceServer) Import(RPCService_ImportServer) error
func (*UnimplementedRPCServiceServer) ListRetrievalDealRecords ¶
func (*UnimplementedRPCServiceServer) ListRetrievalDealRecords(context.Context, *ListRetrievalDealRecordsRequest) (*ListRetrievalDealRecordsResponse, error)
func (*UnimplementedRPCServiceServer) ListStorageDealRecords ¶
func (*UnimplementedRPCServiceServer) ListStorageDealRecords(context.Context, *ListStorageDealRecordsRequest) (*ListStorageDealRecordsResponse, error)
func (*UnimplementedRPCServiceServer) Retrieve ¶
func (*UnimplementedRPCServiceServer) Retrieve(*RetrieveRequest, RPCService_RetrieveServer) error
func (*UnimplementedRPCServiceServer) Store ¶
func (*UnimplementedRPCServiceServer) Store(context.Context, *StoreRequest) (*StoreResponse, error)
func (*UnimplementedRPCServiceServer) Watch ¶
func (*UnimplementedRPCServiceServer) Watch(*WatchRequest, RPCService_WatchServer) error
type WatchRequest ¶
type WatchRequest struct { Proposals []string `protobuf:"bytes,1,rep,name=proposals,proto3" json:"proposals,omitempty"` // contains filtered or unexported fields }
func (*WatchRequest) Descriptor
deprecated
func (*WatchRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.
func (*WatchRequest) GetProposals ¶
func (x *WatchRequest) GetProposals() []string
func (*WatchRequest) ProtoMessage ¶
func (*WatchRequest) ProtoMessage()
func (*WatchRequest) ProtoReflect ¶
func (x *WatchRequest) ProtoReflect() protoreflect.Message
func (*WatchRequest) Reset ¶
func (x *WatchRequest) Reset()
func (*WatchRequest) String ¶
func (x *WatchRequest) String() string
type WatchResponse ¶
type WatchResponse struct { DealInfo *StorageDealInfo `protobuf:"bytes,1,opt,name=deal_info,json=dealInfo,proto3" json:"deal_info,omitempty"` // contains filtered or unexported fields }
func (*WatchResponse) Descriptor
deprecated
func (*WatchResponse) Descriptor() ([]byte, []int)
Deprecated: Use WatchResponse.ProtoReflect.Descriptor instead.
func (*WatchResponse) GetDealInfo ¶
func (x *WatchResponse) GetDealInfo() *StorageDealInfo
func (*WatchResponse) ProtoMessage ¶
func (*WatchResponse) ProtoMessage()
func (*WatchResponse) ProtoReflect ¶
func (x *WatchResponse) ProtoReflect() protoreflect.Message
func (*WatchResponse) Reset ¶
func (x *WatchResponse) Reset()
func (*WatchResponse) String ¶
func (x *WatchResponse) String() string