rpc

package
v0.1.1-pre.2 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

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

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 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 (*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 (*ListRetrievalDealRecordsRequest) ProtoMessage

func (*ListRetrievalDealRecordsRequest) ProtoMessage()

func (*ListRetrievalDealRecordsRequest) ProtoReflect

func (*ListRetrievalDealRecordsRequest) Reset

func (*ListRetrievalDealRecordsRequest) 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 (*ListRetrievalDealRecordsResponse) ProtoMessage

func (*ListRetrievalDealRecordsResponse) ProtoMessage()

func (*ListRetrievalDealRecordsResponse) ProtoReflect

func (*ListRetrievalDealRecordsResponse) Reset

func (*ListRetrievalDealRecordsResponse) 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 (*ListStorageDealRecordsRequest) ProtoMessage

func (*ListStorageDealRecordsRequest) ProtoMessage()

func (*ListStorageDealRecordsRequest) ProtoReflect

func (*ListStorageDealRecordsRequest) Reset

func (x *ListStorageDealRecordsRequest) Reset()

func (*ListStorageDealRecordsRequest) 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 (*ListStorageDealRecordsResponse) ProtoMessage

func (*ListStorageDealRecordsResponse) ProtoMessage()

func (*ListStorageDealRecordsResponse) ProtoReflect

func (*ListStorageDealRecordsResponse) Reset

func (x *ListStorageDealRecordsResponse) Reset()

func (*ListStorageDealRecordsResponse) 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) 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

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 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) Enum

func (StorageDealStatus) EnumDescriptor deprecated

func (StorageDealStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use StorageDealStatus.Descriptor instead.

func (StorageDealStatus) Number

func (StorageDealStatus) String

func (x StorageDealStatus) String() string

func (StorageDealStatus) Type

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) GetDealStatus

func (*UnimplementedRPCServiceServer) Import

func (*UnimplementedRPCServiceServer) Retrieve

func (*UnimplementedRPCServiceServer) Store

func (*UnimplementedRPCServiceServer) Watch

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL