rpc

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 2020 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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 New 

func New(dm Module) *RPC

New creates a new rpc 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) Store 

func (s *RPC) Store(srv RPCService_StoreServer) 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 {
	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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.