rpc

package
v0.9.4 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 2020 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	JobStatus_name = map[int32]string{
		0: "JOB_STATUS_UNSPECIFIED",
		1: "JOB_STATUS_QUEUED",
		2: "JOB_STATUS_EXECUTING",
		3: "JOB_STATUS_FAILED",
		4: "JOB_STATUS_CANCELED",
		5: "JOB_STATUS_SUCCESS",
	}
	JobStatus_value = map[string]int32{
		"JOB_STATUS_UNSPECIFIED": 0,
		"JOB_STATUS_QUEUED":      1,
		"JOB_STATUS_EXECUTING":   2,
		"JOB_STATUS_FAILED":      3,
		"JOB_STATUS_CANCELED":    4,
		"JOB_STATUS_SUCCESS":     5,
	}
)

Enum value maps for JobStatus.

View Source 
var (
	Direction_name = map[int32]string{
		0: "DIRECTION_UNSPECIFIED",
		1: "DIRECTION_INBOUND",
		2: "DIRECTION_OUTBOUND",
	}
	Direction_value = map[string]int32{
		"DIRECTION_UNSPECIFIED": 0,
		"DIRECTION_INBOUND":     1,
		"DIRECTION_OUTBOUND":    2,
	}
)

Enum value maps for Direction.

View Source 
var (
	// ErrEmptyAuthToken is returned when the provided auth-token is unknown.
	ErrEmptyAuthToken = errors.New("auth token can't be empty")
)
View Source 
var File_ffs_rpc_rpc_proto protoreflect.FileDescriptor

Functions

func RegisterRPCServiceServer 

func RegisterRPCServiceServer(s *grpc.Server, srv RPCServiceServer)

Types

type AddrInfo 

type AddrInfo struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Addr string `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*AddrInfo) Descriptor deprecated 

func (*AddrInfo) Descriptor() ([]byte, []int)

Deprecated: Use AddrInfo.ProtoReflect.Descriptor instead.

func (*AddrInfo) GetAddr 

func (x *AddrInfo) GetAddr() string

func (*AddrInfo) GetName 

func (x *AddrInfo) GetName() string

func (*AddrInfo) GetType 

func (x *AddrInfo) GetType() string

func (*AddrInfo) ProtoMessage 

func (*AddrInfo) ProtoMessage()

func (*AddrInfo) ProtoReflect 

func (x *AddrInfo) ProtoReflect() protoreflect.Message

func (*AddrInfo) Reset 

func (x *AddrInfo) Reset()

func (*AddrInfo) String 

func (x *AddrInfo) String() string

type AddrsRequest 

type AddrsRequest struct {
	// contains filtered or unexported fields
}

func (*AddrsRequest) Descriptor deprecated 

func (*AddrsRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddrsRequest.ProtoReflect.Descriptor instead.

func (*AddrsRequest) ProtoMessage 

func (*AddrsRequest) ProtoMessage()

func (*AddrsRequest) ProtoReflect 

func (x *AddrsRequest) ProtoReflect() protoreflect.Message

func (*AddrsRequest) Reset 

func (x *AddrsRequest) Reset()

func (*AddrsRequest) String 

func (x *AddrsRequest) String() string

type AddrsResponse 

type AddrsResponse struct {
	Addrs []*AddrInfo `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"`
	// contains filtered or unexported fields
}

func (*AddrsResponse) Descriptor deprecated 

func (*AddrsResponse) Descriptor() ([]byte, []int)

Deprecated: Use AddrsResponse.ProtoReflect.Descriptor instead.

func (*AddrsResponse) GetAddrs 

func (x *AddrsResponse) GetAddrs() []*AddrInfo

func (*AddrsResponse) ProtoMessage 

func (*AddrsResponse) ProtoMessage()

func (*AddrsResponse) ProtoReflect 

func (x *AddrsResponse) ProtoReflect() protoreflect.Message

func (*AddrsResponse) Reset 

func (x *AddrsResponse) Reset()

func (*AddrsResponse) String 

func (x *AddrsResponse) String() string

type BalanceInfo 

type BalanceInfo struct {
	Addr    *AddrInfo `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Balance int64     `protobuf:"varint,2,opt,name=balance,proto3" json:"balance,omitempty"`
	// contains filtered or unexported fields
}

func (*BalanceInfo) Descriptor deprecated 

func (*BalanceInfo) Descriptor() ([]byte, []int)

Deprecated: Use BalanceInfo.ProtoReflect.Descriptor instead.

func (*BalanceInfo) GetAddr 

func (x *BalanceInfo) GetAddr() *AddrInfo

func (*BalanceInfo) GetBalance 

func (x *BalanceInfo) GetBalance() int64

func (*BalanceInfo) ProtoMessage 

func (*BalanceInfo) ProtoMessage()

func (*BalanceInfo) ProtoReflect 

func (x *BalanceInfo) ProtoReflect() protoreflect.Message

func (*BalanceInfo) Reset 

func (x *BalanceInfo) Reset()

func (*BalanceInfo) String 

func (x *BalanceInfo) String() string

type CancelJobRequest 

type CancelJobRequest struct {
	Jid string `protobuf:"bytes,1,opt,name=jid,proto3" json:"jid,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelJobRequest) Descriptor deprecated 

func (*CancelJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.

func (*CancelJobRequest) GetJid 

func (x *CancelJobRequest) GetJid() string

func (*CancelJobRequest) ProtoMessage 

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) ProtoReflect 

func (x *CancelJobRequest) ProtoReflect() protoreflect.Message

func (*CancelJobRequest) Reset 

func (x *CancelJobRequest) Reset()

func (*CancelJobRequest) String 

func (x *CancelJobRequest) String() string

type CancelJobResponse 

type CancelJobResponse struct {
	// contains filtered or unexported fields
}

func (*CancelJobResponse) Descriptor deprecated 

func (*CancelJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use CancelJobResponse.ProtoReflect.Descriptor instead.

func (*CancelJobResponse) ProtoMessage 

func (*CancelJobResponse) ProtoMessage()

func (*CancelJobResponse) ProtoReflect 

func (x *CancelJobResponse) ProtoReflect() protoreflect.Message

func (*CancelJobResponse) Reset 

func (x *CancelJobResponse) Reset()

func (*CancelJobResponse) String 

func (x *CancelJobResponse) String() string

type CidInfo 

type CidInfo struct {
	JobId   string    `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Cid     string    `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"`
	Created int64     `protobuf:"varint,3,opt,name=created,proto3" json:"created,omitempty"`
	Hot     *HotInfo  `protobuf:"bytes,4,opt,name=hot,proto3" json:"hot,omitempty"`
	Cold    *ColdInfo `protobuf:"bytes,5,opt,name=cold,proto3" json:"cold,omitempty"`
	// contains filtered or unexported fields
}

func (*CidInfo) Descriptor deprecated 

func (*CidInfo) Descriptor() ([]byte, []int)

Deprecated: Use CidInfo.ProtoReflect.Descriptor instead.

func (*CidInfo) GetCid 

func (x *CidInfo) GetCid() string

func (*CidInfo) GetCold 

func (x *CidInfo) GetCold() *ColdInfo

func (*CidInfo) GetCreated 

func (x *CidInfo) GetCreated() int64

func (*CidInfo) GetHot 

func (x *CidInfo) GetHot() *HotInfo

func (*CidInfo) GetJobId 

func (x *CidInfo) GetJobId() string

func (*CidInfo) ProtoMessage 

func (*CidInfo) ProtoMessage()

func (*CidInfo) ProtoReflect 

func (x *CidInfo) ProtoReflect() protoreflect.Message

func (*CidInfo) Reset 

func (x *CidInfo) Reset()

func (*CidInfo) String 

func (x *CidInfo) String() string

type ColdConfig 

type ColdConfig struct {
	Enabled  bool       `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Filecoin *FilConfig `protobuf:"bytes,2,opt,name=filecoin,proto3" json:"filecoin,omitempty"`
	// contains filtered or unexported fields
}

func (*ColdConfig) Descriptor deprecated 

func (*ColdConfig) Descriptor() ([]byte, []int)

Deprecated: Use ColdConfig.ProtoReflect.Descriptor instead.

func (*ColdConfig) GetEnabled 

func (x *ColdConfig) GetEnabled() bool

func (*ColdConfig) GetFilecoin 

func (x *ColdConfig) GetFilecoin() *FilConfig

func (*ColdConfig) ProtoMessage 

func (*ColdConfig) ProtoMessage()

func (*ColdConfig) ProtoReflect 

func (x *ColdConfig) ProtoReflect() protoreflect.Message

func (*ColdConfig) Reset 

func (x *ColdConfig) Reset()

func (*ColdConfig) String 

func (x *ColdConfig) String() string

type ColdInfo 

type ColdInfo struct {
	Enabled  bool     `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Filecoin *FilInfo `protobuf:"bytes,2,opt,name=filecoin,proto3" json:"filecoin,omitempty"`
	// contains filtered or unexported fields
}

func (*ColdInfo) Descriptor deprecated 

func (*ColdInfo) Descriptor() ([]byte, []int)

Deprecated: Use ColdInfo.ProtoReflect.Descriptor instead.

func (*ColdInfo) GetEnabled 

func (x *ColdInfo) GetEnabled() bool

func (*ColdInfo) GetFilecoin 

func (x *ColdInfo) GetFilecoin() *FilInfo

func (*ColdInfo) ProtoMessage 

func (*ColdInfo) ProtoMessage()

func (*ColdInfo) ProtoReflect 

func (x *ColdInfo) ProtoReflect() protoreflect.Message

func (*ColdInfo) Reset 

func (x *ColdInfo) Reset()

func (*ColdInfo) String 

func (x *ColdInfo) String() string

type CreatePayChannelRequest 

type CreatePayChannelRequest struct {
	From   string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To     string `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	Amount uint64 `protobuf:"varint,3,opt,name=amount,proto3" json:"amount,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePayChannelRequest) Descriptor deprecated 

func (*CreatePayChannelRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreatePayChannelRequest.ProtoReflect.Descriptor instead.

func (*CreatePayChannelRequest) GetAmount 

func (x *CreatePayChannelRequest) GetAmount() uint64

func (*CreatePayChannelRequest) GetFrom 

func (x *CreatePayChannelRequest) GetFrom() string

func (*CreatePayChannelRequest) GetTo 

func (x *CreatePayChannelRequest) GetTo() string

func (*CreatePayChannelRequest) ProtoMessage 

func (*CreatePayChannelRequest) ProtoMessage()

func (*CreatePayChannelRequest) ProtoReflect 

func (x *CreatePayChannelRequest) ProtoReflect() protoreflect.Message

func (*CreatePayChannelRequest) Reset 

func (x *CreatePayChannelRequest) Reset()

func (*CreatePayChannelRequest) String 

func (x *CreatePayChannelRequest) String() string

type CreatePayChannelResponse 

type CreatePayChannelResponse struct {
	PayChannel        *PaychInfo `protobuf:"bytes,1,opt,name=pay_channel,json=payChannel,proto3" json:"pay_channel,omitempty"`
	ChannelMessageCid string     `protobuf:"bytes,2,opt,name=channel_message_cid,json=channelMessageCid,proto3" json:"channel_message_cid,omitempty"`
	// contains filtered or unexported fields
}

func (*CreatePayChannelResponse) Descriptor deprecated 

func (*CreatePayChannelResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreatePayChannelResponse.ProtoReflect.Descriptor instead.

func (*CreatePayChannelResponse) GetChannelMessageCid 

func (x *CreatePayChannelResponse) GetChannelMessageCid() string

func (*CreatePayChannelResponse) GetPayChannel 

func (x *CreatePayChannelResponse) GetPayChannel() *PaychInfo

func (*CreatePayChannelResponse) ProtoMessage 

func (*CreatePayChannelResponse) ProtoMessage()

func (*CreatePayChannelResponse) ProtoReflect 

func (x *CreatePayChannelResponse) ProtoReflect() protoreflect.Message

func (*CreatePayChannelResponse) Reset 

func (x *CreatePayChannelResponse) Reset()

func (*CreatePayChannelResponse) String 

func (x *CreatePayChannelResponse) String() string

type CreateRequest 

type CreateRequest struct {
	// contains filtered or unexported fields
}

func (*CreateRequest) Descriptor deprecated 

func (*CreateRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

func (x *CreateRequest) ProtoReflect() protoreflect.Message

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateResponse 

type CreateResponse struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateResponse) Descriptor deprecated 

func (*CreateResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetId 

func (x *CreateResponse) GetId() string

func (*CreateResponse) GetToken 

func (x *CreateResponse) GetToken() string

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect 

func (x *CreateResponse) ProtoReflect() protoreflect.Message

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type DealError 

type DealError struct {
	ProposalCid string `protobuf:"bytes,1,opt,name=proposal_cid,json=proposalCid,proto3" json:"proposal_cid,omitempty"`
	Miner       string `protobuf:"bytes,2,opt,name=miner,proto3" json:"miner,omitempty"`
	Message     string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*DealError) Descriptor deprecated 

func (*DealError) Descriptor() ([]byte, []int)

Deprecated: Use DealError.ProtoReflect.Descriptor instead.

func (*DealError) GetMessage 

func (x *DealError) GetMessage() string

func (*DealError) GetMiner 

func (x *DealError) GetMiner() string

func (*DealError) GetProposalCid 

func (x *DealError) GetProposalCid() string

func (*DealError) ProtoMessage 

func (*DealError) ProtoMessage()

func (*DealError) ProtoReflect 

func (x *DealError) ProtoReflect() protoreflect.Message

func (*DealError) Reset 

func (x *DealError) Reset()

func (*DealError) String 

func (x *DealError) String() string

type DefaultStorageConfigRequest added in v0.2.0 

type DefaultStorageConfigRequest struct {
	// contains filtered or unexported fields
}

func (*DefaultStorageConfigRequest) Descriptor deprecated added in v0.2.0 

func (*DefaultStorageConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use DefaultStorageConfigRequest.ProtoReflect.Descriptor instead.

func (*DefaultStorageConfigRequest) ProtoMessage added in v0.2.0 

func (*DefaultStorageConfigRequest) ProtoMessage()

func (*DefaultStorageConfigRequest) ProtoReflect added in v0.2.0 

func (x *DefaultStorageConfigRequest) ProtoReflect() protoreflect.Message

func (*DefaultStorageConfigRequest) Reset added in v0.2.0 

func (x *DefaultStorageConfigRequest) Reset()

func (*DefaultStorageConfigRequest) String added in v0.2.0 

func (x *DefaultStorageConfigRequest) String() string

type DefaultStorageConfigResponse added in v0.2.0 

type DefaultStorageConfigResponse struct {
	DefaultStorageConfig *StorageConfig `protobuf:"bytes,1,opt,name=default_storage_config,json=defaultStorageConfig,proto3" json:"default_storage_config,omitempty"`
	// contains filtered or unexported fields
}

func (*DefaultStorageConfigResponse) Descriptor deprecated added in v0.2.0 

func (*DefaultStorageConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use DefaultStorageConfigResponse.ProtoReflect.Descriptor instead.

func (*DefaultStorageConfigResponse) GetDefaultStorageConfig added in v0.2.0 

func (x *DefaultStorageConfigResponse) GetDefaultStorageConfig() *StorageConfig

func (*DefaultStorageConfigResponse) ProtoMessage added in v0.2.0 

func (*DefaultStorageConfigResponse) ProtoMessage()

func (*DefaultStorageConfigResponse) ProtoReflect added in v0.2.0 

func (x *DefaultStorageConfigResponse) ProtoReflect() protoreflect.Message

func (*DefaultStorageConfigResponse) Reset added in v0.2.0 

func (x *DefaultStorageConfigResponse) Reset()

func (*DefaultStorageConfigResponse) String added in v0.2.0 

func (x *DefaultStorageConfigResponse) String() string

type Direction 

type Direction int32
const (
	Direction_DIRECTION_UNSPECIFIED Direction = 0
	Direction_DIRECTION_INBOUND     Direction = 1
	Direction_DIRECTION_OUTBOUND    Direction = 2
)

func (Direction) Descriptor 

func (Direction) Descriptor() protoreflect.EnumDescriptor

func (Direction) Enum 

func (x Direction) Enum() *Direction

func (Direction) EnumDescriptor deprecated 

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

Deprecated: Use Direction.Descriptor instead.

func (Direction) Number 

func (x Direction) Number() protoreflect.EnumNumber

func (Direction) String 

func (x Direction) String() string

func (Direction) Type 

func (Direction) Type() protoreflect.EnumType

type FilConfig 

type FilConfig struct {
	RepFactor       int64     `protobuf:"varint,1,opt,name=rep_factor,json=repFactor,proto3" json:"rep_factor,omitempty"`
	DealMinDuration int64     `protobuf:"varint,2,opt,name=deal_min_duration,json=dealMinDuration,proto3" json:"deal_min_duration,omitempty"`
	ExcludedMiners  []string  `protobuf:"bytes,3,rep,name=excluded_miners,json=excludedMiners,proto3" json:"excluded_miners,omitempty"`
	TrustedMiners   []string  `protobuf:"bytes,4,rep,name=trusted_miners,json=trustedMiners,proto3" json:"trusted_miners,omitempty"`
	CountryCodes    []string  `protobuf:"bytes,5,rep,name=country_codes,json=countryCodes,proto3" json:"country_codes,omitempty"`
	Renew           *FilRenew `protobuf:"bytes,6,opt,name=renew,proto3" json:"renew,omitempty"`
	Addr            string    `protobuf:"bytes,7,opt,name=addr,proto3" json:"addr,omitempty"`
	MaxPrice        uint64    `protobuf:"varint,8,opt,name=max_price,json=maxPrice,proto3" json:"max_price,omitempty"`
	FastRetrieval   bool      `protobuf:"varint,9,opt,name=fast_retrieval,json=fastRetrieval,proto3" json:"fast_retrieval,omitempty"`
	DealStartOffset int64     `protobuf:"varint,10,opt,name=deal_start_offset,json=dealStartOffset,proto3" json:"deal_start_offset,omitempty"`
	// contains filtered or unexported fields
}

func (*FilConfig) Descriptor deprecated 

func (*FilConfig) Descriptor() ([]byte, []int)

Deprecated: Use FilConfig.ProtoReflect.Descriptor instead.

func (*FilConfig) GetAddr 

func (x *FilConfig) GetAddr() string

func (*FilConfig) GetCountryCodes 

func (x *FilConfig) GetCountryCodes() []string

func (*FilConfig) GetDealMinDuration 

func (x *FilConfig) GetDealMinDuration() int64

func (*FilConfig) GetDealStartOffset added in v0.6.1 

func (x *FilConfig) GetDealStartOffset() int64

func (*FilConfig) GetExcludedMiners 

func (x *FilConfig) GetExcludedMiners() []string

func (*FilConfig) GetFastRetrieval added in v0.6.0 

func (x *FilConfig) GetFastRetrieval() bool

func (*FilConfig) GetMaxPrice 

func (x *FilConfig) GetMaxPrice() uint64

func (*FilConfig) GetRenew 

func (x *FilConfig) GetRenew() *FilRenew

func (*FilConfig) GetRepFactor 

func (x *FilConfig) GetRepFactor() int64

func (*FilConfig) GetTrustedMiners 

func (x *FilConfig) GetTrustedMiners() []string

func (*FilConfig) ProtoMessage 

func (*FilConfig) ProtoMessage()

func (*FilConfig) ProtoReflect 

func (x *FilConfig) ProtoReflect() protoreflect.Message

func (*FilConfig) Reset 

func (x *FilConfig) Reset()

func (*FilConfig) String 

func (x *FilConfig) String() string

type FilInfo 

type FilInfo struct {
	DataCid   string        `protobuf:"bytes,1,opt,name=data_cid,json=dataCid,proto3" json:"data_cid,omitempty"`
	Size      uint64        `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Proposals []*FilStorage `protobuf:"bytes,3,rep,name=proposals,proto3" json:"proposals,omitempty"`
	// contains filtered or unexported fields
}

func (*FilInfo) Descriptor deprecated 

func (*FilInfo) Descriptor() ([]byte, []int)

Deprecated: Use FilInfo.ProtoReflect.Descriptor instead.

func (*FilInfo) GetDataCid 

func (x *FilInfo) GetDataCid() string

func (*FilInfo) GetProposals 

func (x *FilInfo) GetProposals() []*FilStorage

func (*FilInfo) GetSize 

func (x *FilInfo) GetSize() uint64

func (*FilInfo) ProtoMessage 

func (*FilInfo) ProtoMessage()

func (*FilInfo) ProtoReflect 

func (x *FilInfo) ProtoReflect() protoreflect.Message

func (*FilInfo) Reset 

func (x *FilInfo) Reset()

func (*FilInfo) String 

func (x *FilInfo) String() string

type FilRenew 

type FilRenew struct {
	Enabled   bool  `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Threshold int64 `protobuf:"varint,2,opt,name=threshold,proto3" json:"threshold,omitempty"`
	// contains filtered or unexported fields
}

func (*FilRenew) Descriptor deprecated 

func (*FilRenew) Descriptor() ([]byte, []int)

Deprecated: Use FilRenew.ProtoReflect.Descriptor instead.

func (*FilRenew) GetEnabled 

func (x *FilRenew) GetEnabled() bool

func (*FilRenew) GetThreshold 

func (x *FilRenew) GetThreshold() int64

func (*FilRenew) ProtoMessage 

func (*FilRenew) ProtoMessage()

func (*FilRenew) ProtoReflect 

func (x *FilRenew) ProtoReflect() protoreflect.Message

func (*FilRenew) Reset 

func (x *FilRenew) Reset()

func (*FilRenew) String 

func (x *FilRenew) String() string

type FilStorage 

type FilStorage struct {
	ProposalCid     string `protobuf:"bytes,1,opt,name=proposal_cid,json=proposalCid,proto3" json:"proposal_cid,omitempty"`
	Renewed         bool   `protobuf:"varint,2,opt,name=renewed,proto3" json:"renewed,omitempty"`
	Duration        int64  `protobuf:"varint,3,opt,name=duration,proto3" json:"duration,omitempty"`
	ActivationEpoch int64  `protobuf:"varint,4,opt,name=activation_epoch,json=activationEpoch,proto3" json:"activation_epoch,omitempty"`
	StartEpoch      uint64 `protobuf:"varint,5,opt,name=start_epoch,json=startEpoch,proto3" json:"start_epoch,omitempty"`
	Miner           string `protobuf:"bytes,6,opt,name=miner,proto3" json:"miner,omitempty"`
	EpochPrice      uint64 `protobuf:"varint,7,opt,name=epoch_price,json=epochPrice,proto3" json:"epoch_price,omitempty"`
	PieceCid        string `protobuf:"bytes,8,opt,name=piece_cid,json=pieceCid,proto3" json:"piece_cid,omitempty"`
	// contains filtered or unexported fields
}

func (*FilStorage) Descriptor deprecated 

func (*FilStorage) Descriptor() ([]byte, []int)

Deprecated: Use FilStorage.ProtoReflect.Descriptor instead.

func (*FilStorage) GetActivationEpoch 

func (x *FilStorage) GetActivationEpoch() int64

func (*FilStorage) GetDuration 

func (x *FilStorage) GetDuration() int64

func (*FilStorage) GetEpochPrice 

func (x *FilStorage) GetEpochPrice() uint64

func (*FilStorage) GetMiner 

func (x *FilStorage) GetMiner() string

func (*FilStorage) GetPieceCid added in v0.6.0 

func (x *FilStorage) GetPieceCid() string

func (*FilStorage) GetProposalCid 

func (x *FilStorage) GetProposalCid() string

func (*FilStorage) GetRenewed 

func (x *FilStorage) GetRenewed() bool

func (*FilStorage) GetStartEpoch 

func (x *FilStorage) GetStartEpoch() uint64

func (*FilStorage) ProtoMessage 

func (*FilStorage) ProtoMessage()

func (*FilStorage) ProtoReflect 

func (x *FilStorage) ProtoReflect() protoreflect.Message

func (*FilStorage) Reset 

func (x *FilStorage) Reset()

func (*FilStorage) String 

func (x *FilStorage) String() string

type GetRequest 

type GetRequest struct {
	Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

func (*GetRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetCid 

func (x *GetRequest) GetCid() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

func (x *GetRequest) ProtoReflect() protoreflect.Message

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

func (*GetResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetChunk 

func (x *GetResponse) GetChunk() []byte

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

func (x *GetResponse) ProtoReflect() protoreflect.Message

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type GetStorageConfigRequest added in v0.2.0 

type GetStorageConfigRequest struct {
	Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStorageConfigRequest) Descriptor deprecated added in v0.2.0 

func (*GetStorageConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetStorageConfigRequest.ProtoReflect.Descriptor instead.

func (*GetStorageConfigRequest) GetCid added in v0.2.0 

func (x *GetStorageConfigRequest) GetCid() string

func (*GetStorageConfigRequest) ProtoMessage added in v0.2.0 

func (*GetStorageConfigRequest) ProtoMessage()

func (*GetStorageConfigRequest) ProtoReflect added in v0.2.0 

func (x *GetStorageConfigRequest) ProtoReflect() protoreflect.Message

func (*GetStorageConfigRequest) Reset added in v0.2.0 

func (x *GetStorageConfigRequest) Reset()

func (*GetStorageConfigRequest) String added in v0.2.0 

func (x *GetStorageConfigRequest) String() string

type GetStorageConfigResponse added in v0.2.0 

type GetStorageConfigResponse struct {
	Config *StorageConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStorageConfigResponse) Descriptor deprecated added in v0.2.0 

func (*GetStorageConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetStorageConfigResponse.ProtoReflect.Descriptor instead.

func (*GetStorageConfigResponse) GetConfig added in v0.2.0 

func (x *GetStorageConfigResponse) GetConfig() *StorageConfig

func (*GetStorageConfigResponse) ProtoMessage added in v0.2.0 

func (*GetStorageConfigResponse) ProtoMessage()

func (*GetStorageConfigResponse) ProtoReflect added in v0.2.0 

func (x *GetStorageConfigResponse) ProtoReflect() protoreflect.Message

func (*GetStorageConfigResponse) Reset added in v0.2.0 

func (x *GetStorageConfigResponse) Reset()

func (*GetStorageConfigResponse) String added in v0.2.0 

func (x *GetStorageConfigResponse) String() string

type GetStorageJobRequest added in v0.6.0 

type GetStorageJobRequest struct {
	Jid string `protobuf:"bytes,1,opt,name=jid,proto3" json:"jid,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStorageJobRequest) Descriptor deprecated added in v0.6.0 

func (*GetStorageJobRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetStorageJobRequest.ProtoReflect.Descriptor instead.

func (*GetStorageJobRequest) GetJid added in v0.6.0 

func (x *GetStorageJobRequest) GetJid() string

func (*GetStorageJobRequest) ProtoMessage added in v0.6.0 

func (*GetStorageJobRequest) ProtoMessage()

func (*GetStorageJobRequest) ProtoReflect added in v0.6.0 

func (x *GetStorageJobRequest) ProtoReflect() protoreflect.Message

func (*GetStorageJobRequest) Reset added in v0.6.0 

func (x *GetStorageJobRequest) Reset()

func (*GetStorageJobRequest) String added in v0.6.0 

func (x *GetStorageJobRequest) String() string

type GetStorageJobResponse added in v0.6.0 

type GetStorageJobResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStorageJobResponse) Descriptor deprecated added in v0.6.0 

func (*GetStorageJobResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetStorageJobResponse.ProtoReflect.Descriptor instead.

func (*GetStorageJobResponse) GetJob added in v0.6.0 

func (x *GetStorageJobResponse) GetJob() *Job

func (*GetStorageJobResponse) ProtoMessage added in v0.6.0 

func (*GetStorageJobResponse) ProtoMessage()

func (*GetStorageJobResponse) ProtoReflect added in v0.6.0 

func (x *GetStorageJobResponse) ProtoReflect() protoreflect.Message

func (*GetStorageJobResponse) Reset added in v0.6.0 

func (x *GetStorageJobResponse) Reset()

func (*GetStorageJobResponse) String added in v0.6.0 

func (x *GetStorageJobResponse) String() string

type HotConfig 

type HotConfig struct {
	Enabled          bool        `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	AllowUnfreeze    bool        `protobuf:"varint,2,opt,name=allow_unfreeze,json=allowUnfreeze,proto3" json:"allow_unfreeze,omitempty"`
	UnfreezeMaxPrice uint64      `protobuf:"varint,3,opt,name=unfreeze_max_price,json=unfreezeMaxPrice,proto3" json:"unfreeze_max_price,omitempty"`
	Ipfs             *IpfsConfig `protobuf:"bytes,4,opt,name=ipfs,proto3" json:"ipfs,omitempty"`
	// contains filtered or unexported fields
}

func (*HotConfig) Descriptor deprecated 

func (*HotConfig) Descriptor() ([]byte, []int)

Deprecated: Use HotConfig.ProtoReflect.Descriptor instead.

func (*HotConfig) GetAllowUnfreeze 

func (x *HotConfig) GetAllowUnfreeze() bool

func (*HotConfig) GetEnabled 

func (x *HotConfig) GetEnabled() bool

func (*HotConfig) GetIpfs 

func (x *HotConfig) GetIpfs() *IpfsConfig

func (*HotConfig) GetUnfreezeMaxPrice added in v0.6.0 

func (x *HotConfig) GetUnfreezeMaxPrice() uint64

func (*HotConfig) ProtoMessage 

func (*HotConfig) ProtoMessage()

func (*HotConfig) ProtoReflect 

func (x *HotConfig) ProtoReflect() protoreflect.Message

func (*HotConfig) Reset 

func (x *HotConfig) Reset()

func (*HotConfig) String 

func (x *HotConfig) String() string

type HotInfo 

type HotInfo struct {
	Enabled bool         `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	Size    int64        `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Ipfs    *IpfsHotInfo `protobuf:"bytes,3,opt,name=ipfs,proto3" json:"ipfs,omitempty"`
	// contains filtered or unexported fields
}

func (*HotInfo) Descriptor deprecated 

func (*HotInfo) Descriptor() ([]byte, []int)

Deprecated: Use HotInfo.ProtoReflect.Descriptor instead.

func (*HotInfo) GetEnabled 

func (x *HotInfo) GetEnabled() bool

func (*HotInfo) GetIpfs 

func (x *HotInfo) GetIpfs() *IpfsHotInfo

func (*HotInfo) GetSize 

func (x *HotInfo) GetSize() int64

func (*HotInfo) ProtoMessage 

func (*HotInfo) ProtoMessage()

func (*HotInfo) ProtoReflect 

func (x *HotInfo) ProtoReflect() protoreflect.Message

func (*HotInfo) Reset 

func (x *HotInfo) Reset()

func (*HotInfo) String 

func (x *HotInfo) String() string

type IDRequest 

type IDRequest struct {
	// contains filtered or unexported fields
}

func (*IDRequest) Descriptor deprecated 

func (*IDRequest) Descriptor() ([]byte, []int)

Deprecated: Use IDRequest.ProtoReflect.Descriptor instead.

func (*IDRequest) ProtoMessage 

func (*IDRequest) ProtoMessage()

func (*IDRequest) ProtoReflect 

func (x *IDRequest) ProtoReflect() protoreflect.Message

func (*IDRequest) Reset 

func (x *IDRequest) Reset()

func (*IDRequest) String 

func (x *IDRequest) String() string

type IDResponse 

type IDResponse struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*IDResponse) Descriptor deprecated 

func (*IDResponse) Descriptor() ([]byte, []int)

Deprecated: Use IDResponse.ProtoReflect.Descriptor instead.

func (*IDResponse) GetId 

func (x *IDResponse) GetId() string

func (*IDResponse) ProtoMessage 

func (*IDResponse) ProtoMessage()

func (*IDResponse) ProtoReflect 

func (x *IDResponse) ProtoReflect() protoreflect.Message

func (*IDResponse) Reset 

func (x *IDResponse) Reset()

func (*IDResponse) String 

func (x *IDResponse) String() string

type InfoRequest 

type InfoRequest struct {
	// contains filtered or unexported fields
}

func (*InfoRequest) Descriptor deprecated 

func (*InfoRequest) Descriptor() ([]byte, []int)

Deprecated: Use InfoRequest.ProtoReflect.Descriptor instead.

func (*InfoRequest) ProtoMessage 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) ProtoReflect 

func (x *InfoRequest) ProtoReflect() protoreflect.Message

func (*InfoRequest) Reset 

func (x *InfoRequest) Reset()

func (*InfoRequest) String 

func (x *InfoRequest) String() string

type InfoResponse 

type InfoResponse struct {
	Info *InstanceInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoResponse) Descriptor deprecated 

func (*InfoResponse) Descriptor() ([]byte, []int)

Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.

func (*InfoResponse) GetInfo 

func (x *InfoResponse) GetInfo() *InstanceInfo

func (*InfoResponse) ProtoMessage 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) ProtoReflect 

func (x *InfoResponse) ProtoReflect() protoreflect.Message

func (*InfoResponse) Reset 

func (x *InfoResponse) Reset()

func (*InfoResponse) String 

func (x *InfoResponse) String() string

type InstanceInfo 

type InstanceInfo struct {
	Id                   string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	DefaultStorageConfig *StorageConfig `protobuf:"bytes,2,opt,name=default_storage_config,json=defaultStorageConfig,proto3" json:"default_storage_config,omitempty"`
	Balances             []*BalanceInfo `protobuf:"bytes,3,rep,name=balances,proto3" json:"balances,omitempty"`
	Pins                 []string       `protobuf:"bytes,4,rep,name=pins,proto3" json:"pins,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceInfo) Descriptor deprecated 

func (*InstanceInfo) Descriptor() ([]byte, []int)

Deprecated: Use InstanceInfo.ProtoReflect.Descriptor instead.

func (*InstanceInfo) GetBalances 

func (x *InstanceInfo) GetBalances() []*BalanceInfo

func (*InstanceInfo) GetDefaultStorageConfig added in v0.2.0 

func (x *InstanceInfo) GetDefaultStorageConfig() *StorageConfig

func (*InstanceInfo) GetId 

func (x *InstanceInfo) GetId() string

func (*InstanceInfo) GetPins 

func (x *InstanceInfo) GetPins() []string

func (*InstanceInfo) ProtoMessage 

func (*InstanceInfo) ProtoMessage()

func (*InstanceInfo) ProtoReflect 

func (x *InstanceInfo) ProtoReflect() protoreflect.Message

func (*InstanceInfo) Reset 

func (x *InstanceInfo) Reset()

func (*InstanceInfo) String 

func (x *InstanceInfo) String() string

type IpfsConfig 

type IpfsConfig struct {
	AddTimeout int64 `protobuf:"varint,1,opt,name=add_timeout,json=addTimeout,proto3" json:"add_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*IpfsConfig) Descriptor deprecated 

func (*IpfsConfig) Descriptor() ([]byte, []int)

Deprecated: Use IpfsConfig.ProtoReflect.Descriptor instead.

func (*IpfsConfig) GetAddTimeout 

func (x *IpfsConfig) GetAddTimeout() int64

func (*IpfsConfig) ProtoMessage 

func (*IpfsConfig) ProtoMessage()

func (*IpfsConfig) ProtoReflect 

func (x *IpfsConfig) ProtoReflect() protoreflect.Message

func (*IpfsConfig) Reset 

func (x *IpfsConfig) Reset()

func (*IpfsConfig) String 

func (x *IpfsConfig) String() string

type IpfsHotInfo 

type IpfsHotInfo struct {
	Created int64 `protobuf:"varint,1,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

func (*IpfsHotInfo) Descriptor deprecated 

func (*IpfsHotInfo) Descriptor() ([]byte, []int)

Deprecated: Use IpfsHotInfo.ProtoReflect.Descriptor instead.

func (*IpfsHotInfo) GetCreated 

func (x *IpfsHotInfo) GetCreated() int64

func (*IpfsHotInfo) ProtoMessage 

func (*IpfsHotInfo) ProtoMessage()

func (*IpfsHotInfo) ProtoReflect 

func (x *IpfsHotInfo) ProtoReflect() protoreflect.Message

func (*IpfsHotInfo) Reset 

func (x *IpfsHotInfo) Reset()

func (*IpfsHotInfo) String 

func (x *IpfsHotInfo) String() string

type Job 

type Job struct {
	Id         string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ApiId      string       `protobuf:"bytes,2,opt,name=api_id,json=apiId,proto3" json:"api_id,omitempty"`
	Cid        string       `protobuf:"bytes,3,opt,name=cid,proto3" json:"cid,omitempty"`
	Status     JobStatus    `protobuf:"varint,4,opt,name=status,proto3,enum=ffs.rpc.JobStatus" json:"status,omitempty"`
	ErrCause   string       `protobuf:"bytes,5,opt,name=err_cause,json=errCause,proto3" json:"err_cause,omitempty"`
	DealErrors []*DealError `protobuf:"bytes,6,rep,name=deal_errors,json=dealErrors,proto3" json:"deal_errors,omitempty"`
	CreatedAt  int64        `protobuf:"varint,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Job) Descriptor deprecated 

func (*Job) Descriptor() ([]byte, []int)

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetApiId 

func (x *Job) GetApiId() string

func (*Job) GetCid 

func (x *Job) GetCid() string

func (*Job) GetCreatedAt added in v0.6.10 

func (x *Job) GetCreatedAt() int64

func (*Job) GetDealErrors 

func (x *Job) GetDealErrors() []*DealError

func (*Job) GetErrCause 

func (x *Job) GetErrCause() string

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetStatus 

func (x *Job) GetStatus() JobStatus

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

func (x *Job) ProtoReflect() protoreflect.Message

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobStatus 

type JobStatus int32
const (
	JobStatus_JOB_STATUS_UNSPECIFIED JobStatus = 0
	JobStatus_JOB_STATUS_QUEUED      JobStatus = 1
	JobStatus_JOB_STATUS_EXECUTING   JobStatus = 2
	JobStatus_JOB_STATUS_FAILED      JobStatus = 3
	JobStatus_JOB_STATUS_CANCELED    JobStatus = 4
	JobStatus_JOB_STATUS_SUCCESS     JobStatus = 5
)

func (JobStatus) Descriptor 

func (JobStatus) Descriptor() protoreflect.EnumDescriptor

func (JobStatus) Enum 

func (x JobStatus) Enum() *JobStatus

func (JobStatus) EnumDescriptor deprecated 

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

Deprecated: Use JobStatus.Descriptor instead.

func (JobStatus) Number 

func (x JobStatus) Number() protoreflect.EnumNumber

func (JobStatus) String 

func (x JobStatus) String() string

func (JobStatus) Type 

func (JobStatus) Type() protoreflect.EnumType

type ListAPIRequest 

type ListAPIRequest struct {
	// contains filtered or unexported fields
}

func (*ListAPIRequest) Descriptor deprecated 

func (*ListAPIRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAPIRequest.ProtoReflect.Descriptor instead.

func (*ListAPIRequest) ProtoMessage 

func (*ListAPIRequest) ProtoMessage()

func (*ListAPIRequest) ProtoReflect 

func (x *ListAPIRequest) ProtoReflect() protoreflect.Message

func (*ListAPIRequest) Reset 

func (x *ListAPIRequest) Reset()

func (*ListAPIRequest) String 

func (x *ListAPIRequest) String() string

type ListAPIResponse 

type ListAPIResponse struct {
	Instances []string `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAPIResponse) Descriptor deprecated 

func (*ListAPIResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAPIResponse.ProtoReflect.Descriptor instead.

func (*ListAPIResponse) GetInstances 

func (x *ListAPIResponse) GetInstances() []string

func (*ListAPIResponse) ProtoMessage 

func (*ListAPIResponse) ProtoMessage()

func (*ListAPIResponse) ProtoReflect 

func (x *ListAPIResponse) ProtoReflect() protoreflect.Message

func (*ListAPIResponse) Reset 

func (x *ListAPIResponse) Reset()

func (*ListAPIResponse) String 

func (x *ListAPIResponse) String() string

type ListDealRecordsConfig added in v0.1.1 

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 added in v0.1.1 

func (*ListDealRecordsConfig) Descriptor() ([]byte, []int)

Deprecated: Use ListDealRecordsConfig.ProtoReflect.Descriptor instead.

func (*ListDealRecordsConfig) GetAscending added in v0.1.1 

func (x *ListDealRecordsConfig) GetAscending() bool

func (*ListDealRecordsConfig) GetDataCids added in v0.1.1 

func (x *ListDealRecordsConfig) GetDataCids() []string

func (*ListDealRecordsConfig) GetFromAddrs added in v0.1.1 

func (x *ListDealRecordsConfig) GetFromAddrs() []string

func (*ListDealRecordsConfig) GetIncludeFinal added in v0.1.1 

func (x *ListDealRecordsConfig) GetIncludeFinal() bool

func (*ListDealRecordsConfig) GetIncludePending added in v0.1.1 

func (x *ListDealRecordsConfig) GetIncludePending() bool

func (*ListDealRecordsConfig) ProtoMessage added in v0.1.1 

func (*ListDealRecordsConfig) ProtoMessage()

func (*ListDealRecordsConfig) ProtoReflect added in v0.1.1 

func (x *ListDealRecordsConfig) ProtoReflect() protoreflect.Message

func (*ListDealRecordsConfig) Reset added in v0.1.1 

func (x *ListDealRecordsConfig) Reset()

func (*ListDealRecordsConfig) String added in v0.1.1 

func (x *ListDealRecordsConfig) String() string

type ListPayChannelsRequest 

type ListPayChannelsRequest struct {
	// contains filtered or unexported fields
}

func (*ListPayChannelsRequest) Descriptor deprecated 

func (*ListPayChannelsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListPayChannelsRequest.ProtoReflect.Descriptor instead.

func (*ListPayChannelsRequest) ProtoMessage 

func (*ListPayChannelsRequest) ProtoMessage()

func (*ListPayChannelsRequest) ProtoReflect 

func (x *ListPayChannelsRequest) ProtoReflect() protoreflect.Message

func (*ListPayChannelsRequest) Reset 

func (x *ListPayChannelsRequest) Reset()

func (*ListPayChannelsRequest) String 

func (x *ListPayChannelsRequest) String() string

type ListPayChannelsResponse 

type ListPayChannelsResponse struct {
	PayChannels []*PaychInfo `protobuf:"bytes,1,rep,name=pay_channels,json=payChannels,proto3" json:"pay_channels,omitempty"`
	// contains filtered or unexported fields
}

func (*ListPayChannelsResponse) Descriptor deprecated 

func (*ListPayChannelsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListPayChannelsResponse.ProtoReflect.Descriptor instead.

func (*ListPayChannelsResponse) GetPayChannels 

func (x *ListPayChannelsResponse) GetPayChannels() []*PaychInfo

func (*ListPayChannelsResponse) ProtoMessage 

func (*ListPayChannelsResponse) ProtoMessage()

func (*ListPayChannelsResponse) ProtoReflect 

func (x *ListPayChannelsResponse) ProtoReflect() protoreflect.Message

func (*ListPayChannelsResponse) Reset 

func (x *ListPayChannelsResponse) Reset()

func (*ListPayChannelsResponse) String 

func (x *ListPayChannelsResponse) 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 LogEntry 

type LogEntry struct {
	Cid  string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Jid  string `protobuf:"bytes,2,opt,name=jid,proto3" json:"jid,omitempty"`
	Time int64  `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	Msg  string `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry) Descriptor deprecated 

func (*LogEntry) Descriptor() ([]byte, []int)

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetCid 

func (x *LogEntry) GetCid() string

func (*LogEntry) GetJid 

func (x *LogEntry) GetJid() string

func (*LogEntry) GetMsg 

func (x *LogEntry) GetMsg() string

func (*LogEntry) GetTime 

func (x *LogEntry) GetTime() int64

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

func (x *LogEntry) ProtoReflect() protoreflect.Message

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) String 

func (x *LogEntry) String() string

type NewAddrRequest 

type NewAddrRequest struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	AddressType string `protobuf:"bytes,2,opt,name=address_type,json=addressType,proto3" json:"address_type,omitempty"`
	MakeDefault bool   `protobuf:"varint,3,opt,name=make_default,json=makeDefault,proto3" json:"make_default,omitempty"`
	// contains filtered or unexported fields
}

func (*NewAddrRequest) Descriptor deprecated 

func (*NewAddrRequest) Descriptor() ([]byte, []int)

Deprecated: Use NewAddrRequest.ProtoReflect.Descriptor instead.

func (*NewAddrRequest) GetAddressType 

func (x *NewAddrRequest) GetAddressType() string

func (*NewAddrRequest) GetMakeDefault 

func (x *NewAddrRequest) GetMakeDefault() bool

func (*NewAddrRequest) GetName 

func (x *NewAddrRequest) GetName() string

func (*NewAddrRequest) ProtoMessage 

func (*NewAddrRequest) ProtoMessage()

func (*NewAddrRequest) ProtoReflect 

func (x *NewAddrRequest) ProtoReflect() protoreflect.Message

func (*NewAddrRequest) Reset 

func (x *NewAddrRequest) Reset()

func (*NewAddrRequest) String 

func (x *NewAddrRequest) String() string

type NewAddrResponse 

type NewAddrResponse struct {
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	// contains filtered or unexported fields
}

func (*NewAddrResponse) Descriptor deprecated 

func (*NewAddrResponse) Descriptor() ([]byte, []int)

Deprecated: Use NewAddrResponse.ProtoReflect.Descriptor instead.

func (*NewAddrResponse) GetAddr 

func (x *NewAddrResponse) GetAddr() string

func (*NewAddrResponse) ProtoMessage 

func (*NewAddrResponse) ProtoMessage()

func (*NewAddrResponse) ProtoReflect 

func (x *NewAddrResponse) ProtoReflect() protoreflect.Message

func (*NewAddrResponse) Reset 

func (x *NewAddrResponse) Reset()

func (*NewAddrResponse) String 

func (x *NewAddrResponse) String() string

type PaychInfo 

type PaychInfo struct {
	CtlAddr   string    `protobuf:"bytes,1,opt,name=ctl_addr,json=ctlAddr,proto3" json:"ctl_addr,omitempty"`
	Addr      string    `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Direction Direction `protobuf:"varint,3,opt,name=direction,proto3,enum=ffs.rpc.Direction" json:"direction,omitempty"`
	// contains filtered or unexported fields
}

func (*PaychInfo) Descriptor deprecated 

func (*PaychInfo) Descriptor() ([]byte, []int)

Deprecated: Use PaychInfo.ProtoReflect.Descriptor instead.

func (*PaychInfo) GetAddr 

func (x *PaychInfo) GetAddr() string

func (*PaychInfo) GetCtlAddr 

func (x *PaychInfo) GetCtlAddr() string

func (*PaychInfo) GetDirection 

func (x *PaychInfo) GetDirection() Direction

func (*PaychInfo) ProtoMessage 

func (*PaychInfo) ProtoMessage()

func (*PaychInfo) ProtoReflect 

func (x *PaychInfo) ProtoReflect() protoreflect.Message

func (*PaychInfo) Reset 

func (x *PaychInfo) Reset()

func (*PaychInfo) String 

func (x *PaychInfo) String() string

type PushStorageConfigRequest added in v0.2.0 

type PushStorageConfigRequest struct {
	Cid               string         `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Config            *StorageConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	HasConfig         bool           `protobuf:"varint,3,opt,name=has_config,json=hasConfig,proto3" json:"has_config,omitempty"`
	OverrideConfig    bool           `protobuf:"varint,4,opt,name=override_config,json=overrideConfig,proto3" json:"override_config,omitempty"`
	HasOverrideConfig bool           `protobuf:"varint,5,opt,name=has_override_config,json=hasOverrideConfig,proto3" json:"has_override_config,omitempty"`
	// contains filtered or unexported fields
}

func (*PushStorageConfigRequest) Descriptor deprecated added in v0.2.0 

func (*PushStorageConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use PushStorageConfigRequest.ProtoReflect.Descriptor instead.

func (*PushStorageConfigRequest) GetCid added in v0.2.0 

func (x *PushStorageConfigRequest) GetCid() string

func (*PushStorageConfigRequest) GetConfig added in v0.2.0 

func (x *PushStorageConfigRequest) GetConfig() *StorageConfig

func (*PushStorageConfigRequest) GetHasConfig added in v0.2.0 

func (x *PushStorageConfigRequest) GetHasConfig() bool

func (*PushStorageConfigRequest) GetHasOverrideConfig added in v0.2.0 

func (x *PushStorageConfigRequest) GetHasOverrideConfig() bool

func (*PushStorageConfigRequest) GetOverrideConfig added in v0.2.0 

func (x *PushStorageConfigRequest) GetOverrideConfig() bool

func (*PushStorageConfigRequest) ProtoMessage added in v0.2.0 

func (*PushStorageConfigRequest) ProtoMessage()

func (*PushStorageConfigRequest) ProtoReflect added in v0.2.0 

func (x *PushStorageConfigRequest) ProtoReflect() protoreflect.Message

func (*PushStorageConfigRequest) Reset added in v0.2.0 

func (x *PushStorageConfigRequest) Reset()

func (*PushStorageConfigRequest) String added in v0.2.0 

func (x *PushStorageConfigRequest) String() string

type PushStorageConfigResponse added in v0.2.0 

type PushStorageConfigResponse struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PushStorageConfigResponse) Descriptor deprecated added in v0.2.0 

func (*PushStorageConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use PushStorageConfigResponse.ProtoReflect.Descriptor instead.

func (*PushStorageConfigResponse) GetJobId added in v0.2.0 

func (x *PushStorageConfigResponse) GetJobId() string

func (*PushStorageConfigResponse) ProtoMessage added in v0.2.0 

func (*PushStorageConfigResponse) ProtoMessage()

func (*PushStorageConfigResponse) ProtoReflect added in v0.2.0 

func (x *PushStorageConfigResponse) ProtoReflect() protoreflect.Message

func (*PushStorageConfigResponse) Reset added in v0.2.0 

func (x *PushStorageConfigResponse) Reset()

func (*PushStorageConfigResponse) String added in v0.2.0 

func (x *PushStorageConfigResponse) String() string

type RPC 

type RPC struct {
	UnimplementedRPCServiceServer
	// contains filtered or unexported fields
}

RPC implements the proto service definition of FFS.

func New 

func New(m *manager.Manager, hot ffs.HotStorage) *RPC

New creates a new rpc service.

func (*RPC) Addrs 

func (s *RPC) Addrs(ctx context.Context, req *AddrsRequest) (*AddrsResponse, error)

Addrs calls ffs.Addrs.

func (*RPC) CancelJob 

func (s *RPC) CancelJob(ctx context.Context, req *CancelJobRequest) (*CancelJobResponse, error)

CancelJob calls API.CancelJob.

func (*RPC) Create 

func (s *RPC) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error)

Create creates a new Api.

func (*RPC) CreatePayChannel 

func (s *RPC) CreatePayChannel(ctx context.Context, req *CreatePayChannelRequest) (*CreatePayChannelResponse, error)

CreatePayChannel creates a payment channel.

func (*RPC) DefaultStorageConfig added in v0.2.0 

func (s *RPC) DefaultStorageConfig(ctx context.Context, req *DefaultStorageConfigRequest) (*DefaultStorageConfigResponse, error)

DefaultStorageConfig calls ffs.DefaultStorageConfig.

func (*RPC) Get 

func (s *RPC) Get(req *GetRequest, srv RPCService_GetServer) error

Get gets the data for a stored Cid.

func (*RPC) GetStorageConfig added in v0.2.0 

func (s *RPC) GetStorageConfig(ctx context.Context, req *GetStorageConfigRequest) (*GetStorageConfigResponse, error)

GetStorageConfig returns the storage config for the provided cid.

func (*RPC) GetStorageJob added in v0.6.0 

func (s *RPC) GetStorageJob(ctx context.Context, req *GetStorageJobRequest) (*GetStorageJobResponse, error)

GetStorageJob calls API.GetStorageJob.

func (*RPC) ID 

func (s *RPC) ID(ctx context.Context, req *IDRequest) (*IDResponse, error)

ID returns the API instance id.

func (*RPC) Info 

func (s *RPC) Info(ctx context.Context, req *InfoRequest) (*InfoResponse, error)

Info returns an Api information.

func (*RPC) ListAPI 

func (s *RPC) ListAPI(ctx context.Context, req *ListAPIRequest) (*ListAPIResponse, error)

ListAPI returns a list of all existing API instances.

func (*RPC) ListPayChannels 

func (s *RPC) ListPayChannels(ctx context.Context, req *ListPayChannelsRequest) (*ListPayChannelsResponse, error)

ListPayChannels lists all pay channels.

func (*RPC) ListRetrievalDealRecords 

func (s *RPC) ListRetrievalDealRecords(ctx context.Context, req *ListRetrievalDealRecordsRequest) (*ListRetrievalDealRecordsResponse, error)

ListRetrievalDealRecords calls ffs.ListRetrievalDealRecords.

func (*RPC) ListStorageDealRecords 

func (s *RPC) ListStorageDealRecords(ctx context.Context, req *ListStorageDealRecordsRequest) (*ListStorageDealRecordsResponse, error)

ListStorageDealRecords calls ffs.ListStorageDealRecords.

func (*RPC) NewAddr 

func (s *RPC) NewAddr(ctx context.Context, req *NewAddrRequest) (*NewAddrResponse, error)

NewAddr calls ffs.NewAddr.

func (*RPC) PushStorageConfig added in v0.2.0 

func (s *RPC) PushStorageConfig(ctx context.Context, req *PushStorageConfigRequest) (*PushStorageConfigResponse, error)

PushStorageConfig applies the provided cid storage config.

func (*RPC) RedeemPayChannel 

func (s *RPC) RedeemPayChannel(ctx context.Context, req *RedeemPayChannelRequest) (*RedeemPayChannelResponse, error)

RedeemPayChannel redeems a payment channel.

func (*RPC) Remove 

func (s *RPC) Remove(ctx context.Context, req *RemoveRequest) (*RemoveResponse, error)

Remove calls ffs.Remove.

func (*RPC) Replace 

func (s *RPC) Replace(ctx context.Context, req *ReplaceRequest) (*ReplaceResponse, error)

Replace calls ffs.Replace.

func (*RPC) SendFil 

func (s *RPC) SendFil(ctx context.Context, req *SendFilRequest) (*SendFilResponse, error)

SendFil sends fil from a managed address to any other address.

func (*RPC) SetDefaultStorageConfig added in v0.2.0 

func (s *RPC) SetDefaultStorageConfig(ctx context.Context, req *SetDefaultStorageConfigRequest) (*SetDefaultStorageConfigResponse, error)

SetDefaultStorageConfig sets a new config to be used by default.

func (*RPC) Show 

func (s *RPC) Show(ctx context.Context, req *ShowRequest) (*ShowResponse, error)

Show returns information about a particular Cid.

func (*RPC) ShowAll 

func (s *RPC) ShowAll(ctx context.Context, req *ShowAllRequest) (*ShowAllResponse, error)

ShowAll returns a list of CidInfo for all data stored in the FFS instance.

func (*RPC) SignMessage added in v0.6.9 

func (s *RPC) SignMessage(ctx context.Context, req *SignMessageRequest) (*SignMessageResponse, error)

SignMessage calls ffs.SignMessage.

func (*RPC) Stage added in v0.2.0 

func (s *RPC) Stage(srv RPCService_StageServer) error

Stage allows you to temporarily cache data in the Hot layer in preparation for pushing a cid storage config.

func (*RPC) VerifyMessage added in v0.6.9 

func (s *RPC) VerifyMessage(ctx context.Context, req *VerifyMessageRequest) (*VerifyMessageResponse, error)

VerifyMessage calls ffs.VerifyMessage.

func (*RPC) WatchJobs 

func (s *RPC) WatchJobs(req *WatchJobsRequest, srv RPCService_WatchJobsServer) error

WatchJobs calls API.WatchJobs.

func (*RPC) WatchLogs 

func (s *RPC) WatchLogs(req *WatchLogsRequest, srv RPCService_WatchLogsServer) error

WatchLogs returns a stream of human-readable messages related to executions of a Cid. The listener is automatically unsubscribed when the client closes the stream.

type RPCServiceClient 

type RPCServiceClient interface {
	// Admin
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	ListAPI(ctx context.Context, in *ListAPIRequest, opts ...grpc.CallOption) (*ListAPIResponse, error)
	// Instance
	ID(ctx context.Context, in *IDRequest, opts ...grpc.CallOption) (*IDResponse, error)
	Addrs(ctx context.Context, in *AddrsRequest, opts ...grpc.CallOption) (*AddrsResponse, error)
	DefaultStorageConfig(ctx context.Context, in *DefaultStorageConfigRequest, opts ...grpc.CallOption) (*DefaultStorageConfigResponse, error)
	NewAddr(ctx context.Context, in *NewAddrRequest, opts ...grpc.CallOption) (*NewAddrResponse, error)
	SignMessage(ctx context.Context, in *SignMessageRequest, opts ...grpc.CallOption) (*SignMessageResponse, error)
	VerifyMessage(ctx context.Context, in *VerifyMessageRequest, opts ...grpc.CallOption) (*VerifyMessageResponse, error)
	GetStorageConfig(ctx context.Context, in *GetStorageConfigRequest, opts ...grpc.CallOption) (*GetStorageConfigResponse, error)
	SetDefaultStorageConfig(ctx context.Context, in *SetDefaultStorageConfigRequest, opts ...grpc.CallOption) (*SetDefaultStorageConfigResponse, error)
	Show(ctx context.Context, in *ShowRequest, opts ...grpc.CallOption) (*ShowResponse, error)
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*CancelJobResponse, error)
	GetStorageJob(ctx context.Context, in *GetStorageJobRequest, opts ...grpc.CallOption) (*GetStorageJobResponse, error)
	WatchJobs(ctx context.Context, in *WatchJobsRequest, opts ...grpc.CallOption) (RPCService_WatchJobsClient, error)
	WatchLogs(ctx context.Context, in *WatchLogsRequest, opts ...grpc.CallOption) (RPCService_WatchLogsClient, error)
	Replace(ctx context.Context, in *ReplaceRequest, opts ...grpc.CallOption) (*ReplaceResponse, error)
	PushStorageConfig(ctx context.Context, in *PushStorageConfigRequest, opts ...grpc.CallOption) (*PushStorageConfigResponse, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (RPCService_GetClient, error)
	SendFil(ctx context.Context, in *SendFilRequest, opts ...grpc.CallOption) (*SendFilResponse, error)
	Stage(ctx context.Context, opts ...grpc.CallOption) (RPCService_StageClient, error)
	ListPayChannels(ctx context.Context, in *ListPayChannelsRequest, opts ...grpc.CallOption) (*ListPayChannelsResponse, error)
	CreatePayChannel(ctx context.Context, in *CreatePayChannelRequest, opts ...grpc.CallOption) (*CreatePayChannelResponse, error)
	RedeemPayChannel(ctx context.Context, in *RedeemPayChannelRequest, opts ...grpc.CallOption) (*RedeemPayChannelResponse, error)
	ListStorageDealRecords(ctx context.Context, in *ListStorageDealRecordsRequest, opts ...grpc.CallOption) (*ListStorageDealRecordsResponse, error)
	ListRetrievalDealRecords(ctx context.Context, in *ListRetrievalDealRecordsRequest, opts ...grpc.CallOption) (*ListRetrievalDealRecordsResponse, error)
	// UI support
	ShowAll(ctx context.Context, in *ShowAllRequest, opts ...grpc.CallOption) (*ShowAllResponse, 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 {
	// Admin
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	ListAPI(context.Context, *ListAPIRequest) (*ListAPIResponse, error)
	// Instance
	ID(context.Context, *IDRequest) (*IDResponse, error)
	Addrs(context.Context, *AddrsRequest) (*AddrsResponse, error)
	DefaultStorageConfig(context.Context, *DefaultStorageConfigRequest) (*DefaultStorageConfigResponse, error)
	NewAddr(context.Context, *NewAddrRequest) (*NewAddrResponse, error)
	SignMessage(context.Context, *SignMessageRequest) (*SignMessageResponse, error)
	VerifyMessage(context.Context, *VerifyMessageRequest) (*VerifyMessageResponse, error)
	GetStorageConfig(context.Context, *GetStorageConfigRequest) (*GetStorageConfigResponse, error)
	SetDefaultStorageConfig(context.Context, *SetDefaultStorageConfigRequest) (*SetDefaultStorageConfigResponse, error)
	Show(context.Context, *ShowRequest) (*ShowResponse, error)
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)
	GetStorageJob(context.Context, *GetStorageJobRequest) (*GetStorageJobResponse, error)
	WatchJobs(*WatchJobsRequest, RPCService_WatchJobsServer) error
	WatchLogs(*WatchLogsRequest, RPCService_WatchLogsServer) error
	Replace(context.Context, *ReplaceRequest) (*ReplaceResponse, error)
	PushStorageConfig(context.Context, *PushStorageConfigRequest) (*PushStorageConfigResponse, error)
	Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
	Get(*GetRequest, RPCService_GetServer) error
	SendFil(context.Context, *SendFilRequest) (*SendFilResponse, error)
	Stage(RPCService_StageServer) error
	ListPayChannels(context.Context, *ListPayChannelsRequest) (*ListPayChannelsResponse, error)
	CreatePayChannel(context.Context, *CreatePayChannelRequest) (*CreatePayChannelResponse, error)
	RedeemPayChannel(context.Context, *RedeemPayChannelRequest) (*RedeemPayChannelResponse, error)
	ListStorageDealRecords(context.Context, *ListStorageDealRecordsRequest) (*ListStorageDealRecordsResponse, error)
	ListRetrievalDealRecords(context.Context, *ListRetrievalDealRecordsRequest) (*ListRetrievalDealRecordsResponse, error)
	// UI support
	ShowAll(context.Context, *ShowAllRequest) (*ShowAllResponse, error)
}

RPCServiceServer is the server API for RPCService service.

type RPCService_GetClient 

type RPCService_GetClient interface {
	Recv() (*GetResponse, error)
	grpc.ClientStream
}

type RPCService_GetServer 

type RPCService_GetServer interface {
	Send(*GetResponse) error
	grpc.ServerStream
}

type RPCService_StageClient added in v0.2.0 

type RPCService_StageClient interface {
	Send(*StageRequest) error
	CloseAndRecv() (*StageResponse, error)
	grpc.ClientStream
}

type RPCService_StageServer added in v0.2.0 

type RPCService_StageServer interface {
	SendAndClose(*StageResponse) error
	Recv() (*StageRequest, error)
	grpc.ServerStream
}

type RPCService_WatchJobsClient 

type RPCService_WatchJobsClient interface {
	Recv() (*WatchJobsResponse, error)
	grpc.ClientStream
}

type RPCService_WatchJobsServer 

type RPCService_WatchJobsServer interface {
	Send(*WatchJobsResponse) error
	grpc.ServerStream
}

type RPCService_WatchLogsClient 

type RPCService_WatchLogsClient interface {
	Recv() (*WatchLogsResponse, error)
	grpc.ClientStream
}

type RPCService_WatchLogsServer 

type RPCService_WatchLogsServer interface {
	Send(*WatchLogsResponse) error
	grpc.ServerStream
}

type RedeemPayChannelRequest 

type RedeemPayChannelRequest struct {
	PayChannelAddr string `protobuf:"bytes,1,opt,name=pay_channel_addr,json=payChannelAddr,proto3" json:"pay_channel_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*RedeemPayChannelRequest) Descriptor deprecated 

func (*RedeemPayChannelRequest) Descriptor() ([]byte, []int)

Deprecated: Use RedeemPayChannelRequest.ProtoReflect.Descriptor instead.

func (*RedeemPayChannelRequest) GetPayChannelAddr 

func (x *RedeemPayChannelRequest) GetPayChannelAddr() string

func (*RedeemPayChannelRequest) ProtoMessage 

func (*RedeemPayChannelRequest) ProtoMessage()

func (*RedeemPayChannelRequest) ProtoReflect 

func (x *RedeemPayChannelRequest) ProtoReflect() protoreflect.Message

func (*RedeemPayChannelRequest) Reset 

func (x *RedeemPayChannelRequest) Reset()

func (*RedeemPayChannelRequest) String 

func (x *RedeemPayChannelRequest) String() string

type RedeemPayChannelResponse 

type RedeemPayChannelResponse struct {
	// contains filtered or unexported fields
}

func (*RedeemPayChannelResponse) Descriptor deprecated 

func (*RedeemPayChannelResponse) Descriptor() ([]byte, []int)

Deprecated: Use RedeemPayChannelResponse.ProtoReflect.Descriptor instead.

func (*RedeemPayChannelResponse) ProtoMessage 

func (*RedeemPayChannelResponse) ProtoMessage()

func (*RedeemPayChannelResponse) ProtoReflect 

func (x *RedeemPayChannelResponse) ProtoReflect() protoreflect.Message

func (*RedeemPayChannelResponse) Reset 

func (x *RedeemPayChannelResponse) Reset()

func (*RedeemPayChannelResponse) String 

func (x *RedeemPayChannelResponse) String() string

type RemoveRequest 

type RemoveRequest struct {
	Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveRequest) Descriptor deprecated 

func (*RemoveRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetCid 

func (x *RemoveRequest) GetCid() string

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect 

func (x *RemoveRequest) ProtoReflect() protoreflect.Message

func (*RemoveRequest) Reset 

func (x *RemoveRequest) Reset()

func (*RemoveRequest) String 

func (x *RemoveRequest) String() string

type RemoveResponse 

type RemoveResponse struct {
	// contains filtered or unexported fields
}

func (*RemoveResponse) Descriptor deprecated 

func (*RemoveResponse) Descriptor() ([]byte, []int)

Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.

func (*RemoveResponse) ProtoMessage 

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) ProtoReflect 

func (x *RemoveResponse) ProtoReflect() protoreflect.Message

func (*RemoveResponse) Reset 

func (x *RemoveResponse) Reset()

func (*RemoveResponse) String 

func (x *RemoveResponse) String() string

type ReplaceRequest 

type ReplaceRequest struct {
	Cid1 string `protobuf:"bytes,1,opt,name=cid1,proto3" json:"cid1,omitempty"`
	Cid2 string `protobuf:"bytes,2,opt,name=cid2,proto3" json:"cid2,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceRequest) Descriptor deprecated 

func (*ReplaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceRequest.ProtoReflect.Descriptor instead.

func (*ReplaceRequest) GetCid1 

func (x *ReplaceRequest) GetCid1() string

func (*ReplaceRequest) GetCid2 

func (x *ReplaceRequest) GetCid2() string

func (*ReplaceRequest) ProtoMessage 

func (*ReplaceRequest) ProtoMessage()

func (*ReplaceRequest) ProtoReflect 

func (x *ReplaceRequest) ProtoReflect() protoreflect.Message

func (*ReplaceRequest) Reset 

func (x *ReplaceRequest) Reset()

func (*ReplaceRequest) String 

func (x *ReplaceRequest) String() string

type ReplaceResponse 

type ReplaceResponse struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceResponse) Descriptor deprecated 

func (*ReplaceResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceResponse.ProtoReflect.Descriptor instead.

func (*ReplaceResponse) GetJobId 

func (x *ReplaceResponse) GetJobId() string

func (*ReplaceResponse) ProtoMessage 

func (*ReplaceResponse) ProtoMessage()

func (*ReplaceResponse) ProtoReflect 

func (x *ReplaceResponse) ProtoReflect() protoreflect.Message

func (*ReplaceResponse) Reset 

func (x *ReplaceResponse) Reset()

func (*ReplaceResponse) String 

func (x *ReplaceResponse) String() string

type RetrievalDealInfo added in v0.1.1 

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 added in v0.1.1 

func (*RetrievalDealInfo) Descriptor() ([]byte, []int)

Deprecated: Use RetrievalDealInfo.ProtoReflect.Descriptor instead.

func (*RetrievalDealInfo) GetMinPrice added in v0.1.1 

func (x *RetrievalDealInfo) GetMinPrice() uint64

func (*RetrievalDealInfo) GetMiner added in v0.1.1 

func (x *RetrievalDealInfo) GetMiner() string

func (*RetrievalDealInfo) GetMinerPeerId added in v0.1.1 

func (x *RetrievalDealInfo) GetMinerPeerId() string

func (*RetrievalDealInfo) GetPaymentInterval added in v0.1.1 

func (x *RetrievalDealInfo) GetPaymentInterval() uint64

func (*RetrievalDealInfo) GetPaymentIntervalIncrease added in v0.1.1 

func (x *RetrievalDealInfo) GetPaymentIntervalIncrease() uint64

func (*RetrievalDealInfo) GetRootCid added in v0.1.1 

func (x *RetrievalDealInfo) GetRootCid() string

func (*RetrievalDealInfo) GetSize added in v0.1.1 

func (x *RetrievalDealInfo) GetSize() uint64

func (*RetrievalDealInfo) ProtoMessage added in v0.1.1 

func (*RetrievalDealInfo) ProtoMessage()

func (*RetrievalDealInfo) ProtoReflect added in v0.1.1 

func (x *RetrievalDealInfo) ProtoReflect() protoreflect.Message

func (*RetrievalDealInfo) Reset added in v0.1.1 

func (x *RetrievalDealInfo) Reset()

func (*RetrievalDealInfo) String added in v0.1.1 

func (x *RetrievalDealInfo) String() string

type RetrievalDealRecord added in v0.1.1 

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 (*RetrievalDealRecord) Descriptor deprecated added in v0.1.1 

func (*RetrievalDealRecord) Descriptor() ([]byte, []int)

Deprecated: Use RetrievalDealRecord.ProtoReflect.Descriptor instead.

func (*RetrievalDealRecord) GetAddr added in v0.1.1 

func (x *RetrievalDealRecord) GetAddr() string

func (*RetrievalDealRecord) GetDealInfo added in v0.1.1 

func (x *RetrievalDealRecord) GetDealInfo() *RetrievalDealInfo

func (*RetrievalDealRecord) GetTime added in v0.1.1 

func (x *RetrievalDealRecord) GetTime() int64

func (*RetrievalDealRecord) ProtoMessage added in v0.1.1 

func (*RetrievalDealRecord) ProtoMessage()

func (*RetrievalDealRecord) ProtoReflect added in v0.1.1 

func (x *RetrievalDealRecord) ProtoReflect() protoreflect.Message

func (*RetrievalDealRecord) Reset added in v0.1.1 

func (x *RetrievalDealRecord) Reset()

func (*RetrievalDealRecord) String added in v0.1.1 

func (x *RetrievalDealRecord) String() string

type SendFilRequest 

type SendFilRequest struct {
	From   string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	To     string `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"`
	Amount int64  `protobuf:"varint,3,opt,name=amount,proto3" json:"amount,omitempty"`
	// contains filtered or unexported fields
}

func (*SendFilRequest) Descriptor deprecated 

func (*SendFilRequest) Descriptor() ([]byte, []int)

Deprecated: Use SendFilRequest.ProtoReflect.Descriptor instead.

func (*SendFilRequest) GetAmount 

func (x *SendFilRequest) GetAmount() int64

func (*SendFilRequest) GetFrom 

func (x *SendFilRequest) GetFrom() string

func (*SendFilRequest) GetTo 

func (x *SendFilRequest) GetTo() string

func (*SendFilRequest) ProtoMessage 

func (*SendFilRequest) ProtoMessage()

func (*SendFilRequest) ProtoReflect 

func (x *SendFilRequest) ProtoReflect() protoreflect.Message

func (*SendFilRequest) Reset 

func (x *SendFilRequest) Reset()

func (*SendFilRequest) String 

func (x *SendFilRequest) String() string

type SendFilResponse 

type SendFilResponse struct {
	// contains filtered or unexported fields
}

func (*SendFilResponse) Descriptor deprecated 

func (*SendFilResponse) Descriptor() ([]byte, []int)

Deprecated: Use SendFilResponse.ProtoReflect.Descriptor instead.

func (*SendFilResponse) ProtoMessage 

func (*SendFilResponse) ProtoMessage()

func (*SendFilResponse) ProtoReflect 

func (x *SendFilResponse) ProtoReflect() protoreflect.Message

func (*SendFilResponse) Reset 

func (x *SendFilResponse) Reset()

func (*SendFilResponse) String 

func (x *SendFilResponse) String() string

type SetDefaultStorageConfigRequest added in v0.2.0 

type SetDefaultStorageConfigRequest struct {
	Config *StorageConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*SetDefaultStorageConfigRequest) Descriptor deprecated added in v0.2.0 

func (*SetDefaultStorageConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetDefaultStorageConfigRequest.ProtoReflect.Descriptor instead.

func (*SetDefaultStorageConfigRequest) GetConfig added in v0.2.0 

func (x *SetDefaultStorageConfigRequest) GetConfig() *StorageConfig

func (*SetDefaultStorageConfigRequest) ProtoMessage added in v0.2.0 

func (*SetDefaultStorageConfigRequest) ProtoMessage()

func (*SetDefaultStorageConfigRequest) ProtoReflect added in v0.2.0 

func (x *SetDefaultStorageConfigRequest) ProtoReflect() protoreflect.Message

func (*SetDefaultStorageConfigRequest) Reset added in v0.2.0 

func (x *SetDefaultStorageConfigRequest) Reset()

func (*SetDefaultStorageConfigRequest) String added in v0.2.0 

func (x *SetDefaultStorageConfigRequest) String() string

type SetDefaultStorageConfigResponse added in v0.2.0 

type SetDefaultStorageConfigResponse struct {
	// contains filtered or unexported fields
}

func (*SetDefaultStorageConfigResponse) Descriptor deprecated added in v0.2.0 

func (*SetDefaultStorageConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetDefaultStorageConfigResponse.ProtoReflect.Descriptor instead.

func (*SetDefaultStorageConfigResponse) ProtoMessage added in v0.2.0 

func (*SetDefaultStorageConfigResponse) ProtoMessage()

func (*SetDefaultStorageConfigResponse) ProtoReflect added in v0.2.0 

func (x *SetDefaultStorageConfigResponse) ProtoReflect() protoreflect.Message

func (*SetDefaultStorageConfigResponse) Reset added in v0.2.0 

func (x *SetDefaultStorageConfigResponse) Reset()

func (*SetDefaultStorageConfigResponse) String added in v0.2.0 

func (x *SetDefaultStorageConfigResponse) String() string

type ShowAllRequest 

type ShowAllRequest struct {
	// contains filtered or unexported fields
}

func (*ShowAllRequest) Descriptor deprecated 

func (*ShowAllRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowAllRequest.ProtoReflect.Descriptor instead.

func (*ShowAllRequest) ProtoMessage 

func (*ShowAllRequest) ProtoMessage()

func (*ShowAllRequest) ProtoReflect 

func (x *ShowAllRequest) ProtoReflect() protoreflect.Message

func (*ShowAllRequest) Reset 

func (x *ShowAllRequest) Reset()

func (*ShowAllRequest) String 

func (x *ShowAllRequest) String() string

type ShowAllResponse 

type ShowAllResponse struct {
	CidInfos []*CidInfo `protobuf:"bytes,1,rep,name=cid_infos,json=cidInfos,proto3" json:"cid_infos,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowAllResponse) Descriptor deprecated 

func (*ShowAllResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowAllResponse.ProtoReflect.Descriptor instead.

func (*ShowAllResponse) GetCidInfos 

func (x *ShowAllResponse) GetCidInfos() []*CidInfo

func (*ShowAllResponse) ProtoMessage 

func (*ShowAllResponse) ProtoMessage()

func (*ShowAllResponse) ProtoReflect 

func (x *ShowAllResponse) ProtoReflect() protoreflect.Message

func (*ShowAllResponse) Reset 

func (x *ShowAllResponse) Reset()

func (*ShowAllResponse) String 

func (x *ShowAllResponse) String() string

type ShowRequest 

type ShowRequest struct {
	Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowRequest) Descriptor deprecated 

func (*ShowRequest) Descriptor() ([]byte, []int)

Deprecated: Use ShowRequest.ProtoReflect.Descriptor instead.

func (*ShowRequest) GetCid 

func (x *ShowRequest) GetCid() string

func (*ShowRequest) ProtoMessage 

func (*ShowRequest) ProtoMessage()

func (*ShowRequest) ProtoReflect 

func (x *ShowRequest) ProtoReflect() protoreflect.Message

func (*ShowRequest) Reset 

func (x *ShowRequest) Reset()

func (*ShowRequest) String 

func (x *ShowRequest) String() string

type ShowResponse 

type ShowResponse struct {
	CidInfo *CidInfo `protobuf:"bytes,1,opt,name=cid_info,json=cidInfo,proto3" json:"cid_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowResponse) Descriptor deprecated 

func (*ShowResponse) Descriptor() ([]byte, []int)

Deprecated: Use ShowResponse.ProtoReflect.Descriptor instead.

func (*ShowResponse) GetCidInfo 

func (x *ShowResponse) GetCidInfo() *CidInfo

func (*ShowResponse) ProtoMessage 

func (*ShowResponse) ProtoMessage()

func (*ShowResponse) ProtoReflect 

func (x *ShowResponse) ProtoReflect() protoreflect.Message

func (*ShowResponse) Reset 

func (x *ShowResponse) Reset()

func (*ShowResponse) String 

func (x *ShowResponse) String() string

type SignMessageRequest added in v0.6.9 

type SignMessageRequest struct {
	Addr string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Msg  []byte `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*SignMessageRequest) Descriptor deprecated added in v0.6.9 

func (*SignMessageRequest) Descriptor() ([]byte, []int)

Deprecated: Use SignMessageRequest.ProtoReflect.Descriptor instead.

func (*SignMessageRequest) GetAddr added in v0.6.9 

func (x *SignMessageRequest) GetAddr() string

func (*SignMessageRequest) GetMsg added in v0.6.9 

func (x *SignMessageRequest) GetMsg() []byte

func (*SignMessageRequest) ProtoMessage added in v0.6.9 

func (*SignMessageRequest) ProtoMessage()

func (*SignMessageRequest) ProtoReflect added in v0.6.9 

func (x *SignMessageRequest) ProtoReflect() protoreflect.Message

func (*SignMessageRequest) Reset added in v0.6.9 

func (x *SignMessageRequest) Reset()

func (*SignMessageRequest) String added in v0.6.9 

func (x *SignMessageRequest) String() string

type SignMessageResponse added in v0.6.9 

type SignMessageResponse struct {
	Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*SignMessageResponse) Descriptor deprecated added in v0.6.9 

func (*SignMessageResponse) Descriptor() ([]byte, []int)

Deprecated: Use SignMessageResponse.ProtoReflect.Descriptor instead.

func (*SignMessageResponse) GetSignature added in v0.6.9 

func (x *SignMessageResponse) GetSignature() []byte

func (*SignMessageResponse) ProtoMessage added in v0.6.9 

func (*SignMessageResponse) ProtoMessage()

func (*SignMessageResponse) ProtoReflect added in v0.6.9 

func (x *SignMessageResponse) ProtoReflect() protoreflect.Message

func (*SignMessageResponse) Reset added in v0.6.9 

func (x *SignMessageResponse) Reset()

func (*SignMessageResponse) String added in v0.6.9 

func (x *SignMessageResponse) String() string

type StageRequest added in v0.2.0 

type StageRequest struct {
	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*StageRequest) Descriptor deprecated added in v0.2.0 

func (*StageRequest) Descriptor() ([]byte, []int)

Deprecated: Use StageRequest.ProtoReflect.Descriptor instead.

func (*StageRequest) GetChunk added in v0.2.0 

func (x *StageRequest) GetChunk() []byte

func (*StageRequest) ProtoMessage added in v0.2.0 

func (*StageRequest) ProtoMessage()

func (*StageRequest) ProtoReflect added in v0.2.0 

func (x *StageRequest) ProtoReflect() protoreflect.Message

func (*StageRequest) Reset added in v0.2.0 

func (x *StageRequest) Reset()

func (*StageRequest) String added in v0.2.0 

func (x *StageRequest) String() string

type StageResponse added in v0.2.0 

type StageResponse struct {
	Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	// contains filtered or unexported fields
}

func (*StageResponse) Descriptor deprecated added in v0.2.0 

func (*StageResponse) Descriptor() ([]byte, []int)

Deprecated: Use StageResponse.ProtoReflect.Descriptor instead.

func (*StageResponse) GetCid added in v0.2.0 

func (x *StageResponse) GetCid() string

func (*StageResponse) ProtoMessage added in v0.2.0 

func (*StageResponse) ProtoMessage()

func (*StageResponse) ProtoReflect added in v0.2.0 

func (x *StageResponse) ProtoReflect() protoreflect.Message

func (*StageResponse) Reset added in v0.2.0 

func (x *StageResponse) Reset()

func (*StageResponse) String added in v0.2.0 

func (x *StageResponse) String() string

type StorageConfig added in v0.2.0 

type StorageConfig struct {
	Hot        *HotConfig  `protobuf:"bytes,1,opt,name=hot,proto3" json:"hot,omitempty"`
	Cold       *ColdConfig `protobuf:"bytes,2,opt,name=cold,proto3" json:"cold,omitempty"`
	Repairable bool        `protobuf:"varint,3,opt,name=repairable,proto3" json:"repairable,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageConfig) Descriptor deprecated added in v0.2.0 

func (*StorageConfig) Descriptor() ([]byte, []int)

Deprecated: Use StorageConfig.ProtoReflect.Descriptor instead.

func (*StorageConfig) GetCold added in v0.2.0 

func (x *StorageConfig) GetCold() *ColdConfig

func (*StorageConfig) GetHot added in v0.2.0 

func (x *StorageConfig) GetHot() *HotConfig

func (*StorageConfig) GetRepairable added in v0.2.0 

func (x *StorageConfig) GetRepairable() bool

func (*StorageConfig) ProtoMessage added in v0.2.0 

func (*StorageConfig) ProtoMessage()

func (*StorageConfig) ProtoReflect added in v0.2.0 

func (x *StorageConfig) ProtoReflect() protoreflect.Message

func (*StorageConfig) Reset added in v0.2.0 

func (x *StorageConfig) Reset()

func (*StorageConfig) String added in v0.2.0 

func (x *StorageConfig) String() string

type StorageDealInfo added in v0.1.1 

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 added in v0.1.1 

func (*StorageDealInfo) Descriptor() ([]byte, []int)

Deprecated: Use StorageDealInfo.ProtoReflect.Descriptor instead.

func (*StorageDealInfo) GetActivationEpoch added in v0.1.1 

func (x *StorageDealInfo) GetActivationEpoch() int64

func (*StorageDealInfo) GetDealId added in v0.1.1 

func (x *StorageDealInfo) GetDealId() uint64

func (*StorageDealInfo) GetDuration added in v0.1.1 

func (x *StorageDealInfo) GetDuration() uint64

func (*StorageDealInfo) GetMiner added in v0.1.1 

func (x *StorageDealInfo) GetMiner() string

func (*StorageDealInfo) GetMsg added in v0.1.1 

func (x *StorageDealInfo) GetMsg() string

func (*StorageDealInfo) GetPieceCid added in v0.1.1 

func (x *StorageDealInfo) GetPieceCid() string

func (*StorageDealInfo) GetPricePerEpoch added in v0.1.1 

func (x *StorageDealInfo) GetPricePerEpoch() uint64

func (*StorageDealInfo) GetProposalCid added in v0.1.1 

func (x *StorageDealInfo) GetProposalCid() string

func (*StorageDealInfo) GetSize added in v0.1.1 

func (x *StorageDealInfo) GetSize() uint64

func (*StorageDealInfo) GetStartEpoch added in v0.1.1 

func (x *StorageDealInfo) GetStartEpoch() uint64

func (*StorageDealInfo) GetStateId added in v0.1.1 

func (x *StorageDealInfo) GetStateId() uint64

func (*StorageDealInfo) GetStateName added in v0.1.1 

func (x *StorageDealInfo) GetStateName() string

func (*StorageDealInfo) ProtoMessage added in v0.1.1 

func (*StorageDealInfo) ProtoMessage()

func (*StorageDealInfo) ProtoReflect added in v0.1.1 

func (x *StorageDealInfo) ProtoReflect() protoreflect.Message

func (*StorageDealInfo) Reset added in v0.1.1 

func (x *StorageDealInfo) Reset()

func (*StorageDealInfo) String added in v0.1.1 

func (x *StorageDealInfo) String() string

type StorageDealRecord added in v0.1.1 

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 (*StorageDealRecord) Descriptor deprecated added in v0.1.1 

func (*StorageDealRecord) Descriptor() ([]byte, []int)

Deprecated: Use StorageDealRecord.ProtoReflect.Descriptor instead.

func (*StorageDealRecord) GetAddr added in v0.1.1 

func (x *StorageDealRecord) GetAddr() string

func (*StorageDealRecord) GetDealInfo added in v0.1.1 

func (x *StorageDealRecord) GetDealInfo() *StorageDealInfo

func (*StorageDealRecord) GetPending added in v0.1.1 

func (x *StorageDealRecord) GetPending() bool

func (*StorageDealRecord) GetRootCid added in v0.1.1 

func (x *StorageDealRecord) GetRootCid() string

func (*StorageDealRecord) GetTime added in v0.1.1 

func (x *StorageDealRecord) GetTime() int64

func (*StorageDealRecord) ProtoMessage added in v0.1.1 

func (*StorageDealRecord) ProtoMessage()

func (*StorageDealRecord) ProtoReflect added in v0.1.1 

func (x *StorageDealRecord) ProtoReflect() protoreflect.Message

func (*StorageDealRecord) Reset added in v0.1.1 

func (x *StorageDealRecord) Reset()

func (*StorageDealRecord) String added in v0.1.1 

func (x *StorageDealRecord) String() string

type UnimplementedRPCServiceServer 

type UnimplementedRPCServiceServer struct {
}

UnimplementedRPCServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRPCServiceServer) Addrs 

func (*UnimplementedRPCServiceServer) Addrs(context.Context, *AddrsRequest) (*AddrsResponse, error)

func (*UnimplementedRPCServiceServer) CancelJob 

func (*UnimplementedRPCServiceServer) CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)

func (*UnimplementedRPCServiceServer) Create 

func (*UnimplementedRPCServiceServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

func (*UnimplementedRPCServiceServer) CreatePayChannel 

func (*UnimplementedRPCServiceServer) CreatePayChannel(context.Context, *CreatePayChannelRequest) (*CreatePayChannelResponse, error)

func (*UnimplementedRPCServiceServer) DefaultStorageConfig added in v0.2.0 

func (*UnimplementedRPCServiceServer) DefaultStorageConfig(context.Context, *DefaultStorageConfigRequest) (*DefaultStorageConfigResponse, error)

func (*UnimplementedRPCServiceServer) Get 

func (*UnimplementedRPCServiceServer) Get(*GetRequest, RPCService_GetServer) error

func (*UnimplementedRPCServiceServer) GetStorageConfig added in v0.2.0 

func (*UnimplementedRPCServiceServer) GetStorageConfig(context.Context, *GetStorageConfigRequest) (*GetStorageConfigResponse, error)

func (*UnimplementedRPCServiceServer) GetStorageJob added in v0.6.0 

func (*UnimplementedRPCServiceServer) GetStorageJob(context.Context, *GetStorageJobRequest) (*GetStorageJobResponse, error)

func (*UnimplementedRPCServiceServer) ID 

func (*UnimplementedRPCServiceServer) ID(context.Context, *IDRequest) (*IDResponse, error)

func (*UnimplementedRPCServiceServer) Info 

func (*UnimplementedRPCServiceServer) Info(context.Context, *InfoRequest) (*InfoResponse, error)

func (*UnimplementedRPCServiceServer) ListAPI 

func (*UnimplementedRPCServiceServer) ListAPI(context.Context, *ListAPIRequest) (*ListAPIResponse, error)

func (*UnimplementedRPCServiceServer) ListPayChannels 

func (*UnimplementedRPCServiceServer) ListPayChannels(context.Context, *ListPayChannelsRequest) (*ListPayChannelsResponse, error)

func (*UnimplementedRPCServiceServer) ListRetrievalDealRecords 

func (*UnimplementedRPCServiceServer) ListRetrievalDealRecords(context.Context, *ListRetrievalDealRecordsRequest) (*ListRetrievalDealRecordsResponse, error)

func (*UnimplementedRPCServiceServer) ListStorageDealRecords 

func (*UnimplementedRPCServiceServer) ListStorageDealRecords(context.Context, *ListStorageDealRecordsRequest) (*ListStorageDealRecordsResponse, error)

func (*UnimplementedRPCServiceServer) NewAddr 

func (*UnimplementedRPCServiceServer) NewAddr(context.Context, *NewAddrRequest) (*NewAddrResponse, error)

func (*UnimplementedRPCServiceServer) PushStorageConfig added in v0.2.0 

func (*UnimplementedRPCServiceServer) PushStorageConfig(context.Context, *PushStorageConfigRequest) (*PushStorageConfigResponse, error)

func (*UnimplementedRPCServiceServer) RedeemPayChannel 

func (*UnimplementedRPCServiceServer) RedeemPayChannel(context.Context, *RedeemPayChannelRequest) (*RedeemPayChannelResponse, error)

func (*UnimplementedRPCServiceServer) Remove 

func (*UnimplementedRPCServiceServer) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)

func (*UnimplementedRPCServiceServer) Replace 

func (*UnimplementedRPCServiceServer) Replace(context.Context, *ReplaceRequest) (*ReplaceResponse, error)

func (*UnimplementedRPCServiceServer) SendFil 

func (*UnimplementedRPCServiceServer) SendFil(context.Context, *SendFilRequest) (*SendFilResponse, error)

func (*UnimplementedRPCServiceServer) SetDefaultStorageConfig added in v0.2.0 

func (*UnimplementedRPCServiceServer) SetDefaultStorageConfig(context.Context, *SetDefaultStorageConfigRequest) (*SetDefaultStorageConfigResponse, error)

func (*UnimplementedRPCServiceServer) Show 

func (*UnimplementedRPCServiceServer) Show(context.Context, *ShowRequest) (*ShowResponse, error)

func (*UnimplementedRPCServiceServer) ShowAll 

func (*UnimplementedRPCServiceServer) ShowAll(context.Context, *ShowAllRequest) (*ShowAllResponse, error)

func (*UnimplementedRPCServiceServer) SignMessage added in v0.6.9 

func (*UnimplementedRPCServiceServer) SignMessage(context.Context, *SignMessageRequest) (*SignMessageResponse, error)

func (*UnimplementedRPCServiceServer) Stage added in v0.2.0 

func (*UnimplementedRPCServiceServer) Stage(RPCService_StageServer) error

func (*UnimplementedRPCServiceServer) VerifyMessage added in v0.6.9 

func (*UnimplementedRPCServiceServer) VerifyMessage(context.Context, *VerifyMessageRequest) (*VerifyMessageResponse, error)

func (*UnimplementedRPCServiceServer) WatchJobs 

func (*UnimplementedRPCServiceServer) WatchJobs(*WatchJobsRequest, RPCService_WatchJobsServer) error

func (*UnimplementedRPCServiceServer) WatchLogs 

func (*UnimplementedRPCServiceServer) WatchLogs(*WatchLogsRequest, RPCService_WatchLogsServer) error

type VerifyMessageRequest added in v0.6.9 

type VerifyMessageRequest struct {
	Addr      string `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Msg       []byte `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyMessageRequest) Descriptor deprecated added in v0.6.9 

func (*VerifyMessageRequest) Descriptor() ([]byte, []int)

Deprecated: Use VerifyMessageRequest.ProtoReflect.Descriptor instead.

func (*VerifyMessageRequest) GetAddr added in v0.6.9 

func (x *VerifyMessageRequest) GetAddr() string

func (*VerifyMessageRequest) GetMsg added in v0.6.9 

func (x *VerifyMessageRequest) GetMsg() []byte

func (*VerifyMessageRequest) GetSignature added in v0.6.9 

func (x *VerifyMessageRequest) GetSignature() []byte

func (*VerifyMessageRequest) ProtoMessage added in v0.6.9 

func (*VerifyMessageRequest) ProtoMessage()

func (*VerifyMessageRequest) ProtoReflect added in v0.6.9 

func (x *VerifyMessageRequest) ProtoReflect() protoreflect.Message

func (*VerifyMessageRequest) Reset added in v0.6.9 

func (x *VerifyMessageRequest) Reset()

func (*VerifyMessageRequest) String added in v0.6.9 

func (x *VerifyMessageRequest) String() string

type VerifyMessageResponse added in v0.6.9 

type VerifyMessageResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	// contains filtered or unexported fields
}

func (*VerifyMessageResponse) Descriptor deprecated added in v0.6.9 

func (*VerifyMessageResponse) Descriptor() ([]byte, []int)

Deprecated: Use VerifyMessageResponse.ProtoReflect.Descriptor instead.

func (*VerifyMessageResponse) GetOk added in v0.6.9 

func (x *VerifyMessageResponse) GetOk() bool

func (*VerifyMessageResponse) ProtoMessage added in v0.6.9 

func (*VerifyMessageResponse) ProtoMessage()

func (*VerifyMessageResponse) ProtoReflect added in v0.6.9 

func (x *VerifyMessageResponse) ProtoReflect() protoreflect.Message

func (*VerifyMessageResponse) Reset added in v0.6.9 

func (x *VerifyMessageResponse) Reset()

func (*VerifyMessageResponse) String added in v0.6.9 

func (x *VerifyMessageResponse) String() string

type WatchJobsRequest 

type WatchJobsRequest struct {
	Jids []string `protobuf:"bytes,1,rep,name=jids,proto3" json:"jids,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchJobsRequest) Descriptor deprecated 

func (*WatchJobsRequest) Descriptor() ([]byte, []int)

Deprecated: Use WatchJobsRequest.ProtoReflect.Descriptor instead.

func (*WatchJobsRequest) GetJids 

func (x *WatchJobsRequest) GetJids() []string

func (*WatchJobsRequest) ProtoMessage 

func (*WatchJobsRequest) ProtoMessage()

func (*WatchJobsRequest) ProtoReflect 

func (x *WatchJobsRequest) ProtoReflect() protoreflect.Message

func (*WatchJobsRequest) Reset 

func (x *WatchJobsRequest) Reset()

func (*WatchJobsRequest) String 

func (x *WatchJobsRequest) String() string

type WatchJobsResponse 

type WatchJobsResponse struct {
	Job *Job `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchJobsResponse) Descriptor deprecated 

func (*WatchJobsResponse) Descriptor() ([]byte, []int)

Deprecated: Use WatchJobsResponse.ProtoReflect.Descriptor instead.

func (*WatchJobsResponse) GetJob 

func (x *WatchJobsResponse) GetJob() *Job

func (*WatchJobsResponse) ProtoMessage 

func (*WatchJobsResponse) ProtoMessage()

func (*WatchJobsResponse) ProtoReflect 

func (x *WatchJobsResponse) ProtoReflect() protoreflect.Message

func (*WatchJobsResponse) Reset 

func (x *WatchJobsResponse) Reset()

func (*WatchJobsResponse) String 

func (x *WatchJobsResponse) String() string

type WatchLogsRequest 

type WatchLogsRequest struct {
	Cid     string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Jid     string `protobuf:"bytes,2,opt,name=jid,proto3" json:"jid,omitempty"`
	History bool   `protobuf:"varint,3,opt,name=history,proto3" json:"history,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchLogsRequest) Descriptor deprecated 

func (*WatchLogsRequest) Descriptor() ([]byte, []int)

Deprecated: Use WatchLogsRequest.ProtoReflect.Descriptor instead.

func (*WatchLogsRequest) GetCid 

func (x *WatchLogsRequest) GetCid() string

func (*WatchLogsRequest) GetHistory 

func (x *WatchLogsRequest) GetHistory() bool

func (*WatchLogsRequest) GetJid 

func (x *WatchLogsRequest) GetJid() string

func (*WatchLogsRequest) ProtoMessage 

func (*WatchLogsRequest) ProtoMessage()

func (*WatchLogsRequest) ProtoReflect 

func (x *WatchLogsRequest) ProtoReflect() protoreflect.Message

func (*WatchLogsRequest) Reset 

func (x *WatchLogsRequest) Reset()

func (*WatchLogsRequest) String 

func (x *WatchLogsRequest) String() string

type WatchLogsResponse 

type WatchLogsResponse struct {
	LogEntry *LogEntry `protobuf:"bytes,1,opt,name=log_entry,json=logEntry,proto3" json:"log_entry,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchLogsResponse) Descriptor deprecated 

func (*WatchLogsResponse) Descriptor() ([]byte, []int)

Deprecated: Use WatchLogsResponse.ProtoReflect.Descriptor instead.

func (*WatchLogsResponse) GetLogEntry 

func (x *WatchLogsResponse) GetLogEntry() *LogEntry

func (*WatchLogsResponse) ProtoMessage 

func (*WatchLogsResponse) ProtoMessage()

func (*WatchLogsResponse) ProtoReflect 

func (x *WatchLogsResponse) ProtoReflect() protoreflect.Message

func (*WatchLogsResponse) Reset 

func (x *WatchLogsResponse) Reset()

func (*WatchLogsResponse) String 

func (x *WatchLogsResponse) 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.