Documentation ¶
Index ¶
- Variables
- func BuildListDealRecordsOptions(conf *ListDealRecordsConfig) []deals.ListDealRecordsOption
- func RegisterRPCServiceServer(s *grpc.Server, srv RPCServiceServer)
- type DealConfig
- 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) 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(srv RPCService_StoreServer) error
- func (s *RPC) Watch(req *WatchRequest, srv RPCService_WatchServer) error
- type RPCServiceClient
- type RPCServiceServer
- type RPCService_RetrieveClient
- type RPCService_RetrieveServer
- type RPCService_StoreClient
- type RPCService_StoreServer
- 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) GetCid() string
- func (*RetrieveRequest) ProtoMessage()
- func (x *RetrieveRequest) ProtoReflect() protoreflect.Message
- func (x *RetrieveRequest) Reset()
- func (x *RetrieveRequest) String() string
- type RetrieveResponse
- 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 StoreParams
- func (*StoreParams) Descriptor() ([]byte, []int)deprecated
- func (x *StoreParams) GetAddress() string
- func (x *StoreParams) GetDealConfigs() []*DealConfig
- func (x *StoreParams) GetMinDuration() uint64
- func (*StoreParams) ProtoMessage()
- func (x *StoreParams) ProtoReflect() protoreflect.Message
- func (x *StoreParams) Reset()
- func (x *StoreParams) String() string
- type StoreRequest
- func (*StoreRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StoreRequest) GetChunk() []byte
- func (m *StoreRequest) GetPayload() isStoreRequest_Payload
- func (x *StoreRequest) GetStoreParams() *StoreParams
- func (*StoreRequest) ProtoMessage()
- func (x *StoreRequest) ProtoReflect() protoreflect.Message
- func (x *StoreRequest) Reset()
- func (x *StoreRequest) String() string
- type StoreRequest_Chunk
- type StoreRequest_StoreParams
- type StoreResponse
- func (*StoreResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StoreResponse) GetDataCid() string
- func (x *StoreResponse) GetFailedDeals() []*DealConfig
- func (x *StoreResponse) GetProposalCids() []string
- func (*StoreResponse) ProtoMessage()
- func (x *StoreResponse) ProtoReflect() protoreflect.Message
- func (x *StoreResponse) Reset()
- func (x *StoreResponse) String() string
- type UnimplementedRPCServiceServer
- 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(RPCService_StoreServer) error
- func (*UnimplementedRPCServiceServer) Watch(*WatchRequest, RPCService_WatchServer) error
- type WatchRequest
- type WatchResponse
Constants ¶
This section is empty.
Variables ¶
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 DealConfig ¶
type DealConfig 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 (*DealConfig) Descriptor
deprecated
func (*DealConfig) Descriptor() ([]byte, []int)
Deprecated: Use DealConfig.ProtoReflect.Descriptor instead.
func (*DealConfig) GetEpochPrice ¶
func (x *DealConfig) GetEpochPrice() uint64
func (*DealConfig) GetMiner ¶
func (x *DealConfig) GetMiner() string
func (*DealConfig) ProtoMessage ¶
func (*DealConfig) ProtoMessage()
func (*DealConfig) ProtoReflect ¶
func (x *DealConfig) ProtoReflect() protoreflect.Message
func (*DealConfig) Reset ¶
func (x *DealConfig) Reset()
func (*DealConfig) String ¶
func (x *DealConfig) 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) 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) Watch ¶
func (s *RPC) Watch(req *WatchRequest, srv RPCService_WatchServer) error
Watch calls deals.Watch.
type RPCServiceClient ¶
type RPCServiceClient interface { Store(ctx context.Context, opts ...grpc.CallOption) (RPCService_StoreClient, error) Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (RPCService_WatchClient, error) Retrieve(ctx context.Context, in *RetrieveRequest, opts ...grpc.CallOption) (RPCService_RetrieveClient, 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 { Store(RPCService_StoreServer) error Watch(*WatchRequest, RPCService_WatchServer) error Retrieve(*RetrieveRequest, RPCService_RetrieveServer) error ListStorageDealRecords(context.Context, *ListStorageDealRecordsRequest) (*ListStorageDealRecordsResponse, error) ListRetrievalDealRecords(context.Context, *ListRetrievalDealRecordsRequest) (*ListRetrievalDealRecordsResponse, error) }
RPCServiceServer is the server API for RPCService service.
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_StoreClient ¶
type RPCService_StoreClient interface { Send(*StoreRequest) error CloseAndRecv() (*StoreResponse, error) grpc.ClientStream }
type RPCService_StoreServer ¶
type RPCService_StoreServer interface { SendAndClose(*StoreResponse) error Recv() (*StoreRequest, 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"` // 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) 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 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 StoreParams ¶
type StoreParams struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` DealConfigs []*DealConfig `protobuf:"bytes,2,rep,name=deal_configs,json=dealConfigs,proto3" json:"deal_configs,omitempty"` MinDuration uint64 `protobuf:"varint,3,opt,name=min_duration,json=minDuration,proto3" json:"min_duration,omitempty"` // contains filtered or unexported fields }
func (*StoreParams) Descriptor
deprecated
func (*StoreParams) Descriptor() ([]byte, []int)
Deprecated: Use StoreParams.ProtoReflect.Descriptor instead.
func (*StoreParams) GetAddress ¶
func (x *StoreParams) GetAddress() string
func (*StoreParams) GetDealConfigs ¶
func (x *StoreParams) GetDealConfigs() []*DealConfig
func (*StoreParams) GetMinDuration ¶
func (x *StoreParams) GetMinDuration() uint64
func (*StoreParams) ProtoMessage ¶
func (*StoreParams) ProtoMessage()
func (*StoreParams) ProtoReflect ¶
func (x *StoreParams) ProtoReflect() protoreflect.Message
func (*StoreParams) Reset ¶
func (x *StoreParams) Reset()
func (*StoreParams) String ¶
func (x *StoreParams) String() string
type StoreRequest ¶
type StoreRequest struct { // Types that are assignable to Payload: // *StoreRequest_StoreParams // *StoreRequest_Chunk Payload isStoreRequest_Payload `protobuf_oneof:"payload"` // contains filtered or unexported fields }
func (*StoreRequest) Descriptor
deprecated
func (*StoreRequest) Descriptor() ([]byte, []int)
Deprecated: Use StoreRequest.ProtoReflect.Descriptor instead.
func (*StoreRequest) GetChunk ¶
func (x *StoreRequest) GetChunk() []byte
func (*StoreRequest) GetPayload ¶
func (m *StoreRequest) GetPayload() isStoreRequest_Payload
func (*StoreRequest) GetStoreParams ¶
func (x *StoreRequest) GetStoreParams() *StoreParams
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 StoreRequest_Chunk ¶
type StoreRequest_Chunk struct {
Chunk []byte `protobuf:"bytes,2,opt,name=chunk,proto3,oneof"`
}
type StoreRequest_StoreParams ¶
type StoreRequest_StoreParams struct {
StoreParams *StoreParams `protobuf:"bytes,1,opt,name=store_params,json=storeParams,proto3,oneof"`
}
type StoreResponse ¶
type StoreResponse struct { DataCid string `protobuf:"bytes,1,opt,name=data_cid,json=dataCid,proto3" json:"data_cid,omitempty"` ProposalCids []string `protobuf:"bytes,2,rep,name=proposal_cids,json=proposalCids,proto3" json:"proposal_cids,omitempty"` FailedDeals []*DealConfig `protobuf:"bytes,3,rep,name=failed_deals,json=failedDeals,proto3" json:"failed_deals,omitempty"` // contains filtered or unexported fields }
func (*StoreResponse) Descriptor
deprecated
func (*StoreResponse) Descriptor() ([]byte, []int)
Deprecated: Use StoreResponse.ProtoReflect.Descriptor instead.
func (*StoreResponse) GetDataCid ¶
func (x *StoreResponse) GetDataCid() string
func (*StoreResponse) GetFailedDeals ¶
func (x *StoreResponse) GetFailedDeals() []*DealConfig
func (*StoreResponse) GetProposalCids ¶
func (x *StoreResponse) GetProposalCids() []string
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 UnimplementedRPCServiceServer ¶
type UnimplementedRPCServiceServer struct { }
UnimplementedRPCServiceServer can be embedded to have forward compatible implementations.
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(RPCService_StoreServer) 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