rpc

package
v0.6.6 Latest Latest
Warning

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

Go to latest
Published: Sep 26, 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 (*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 (*DefaultStorageConfigResponse) Reset added in v0.2.0

func (x *DefaultStorageConfigResponse) Reset()

func (*DefaultStorageConfigResponse) String added in v0.2.0

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

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"`
	// 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) 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

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

func (*ListRetrievalDealRecordsRequest) ProtoMessage()

func (*ListRetrievalDealRecordsRequest) ProtoReflect

func (*ListRetrievalDealRecordsRequest) Reset

func (*ListRetrievalDealRecordsRequest) String

type ListRetrievalDealRecordsResponse

type ListRetrievalDealRecordsResponse struct {
	Records []*RetrievalDealRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRetrievalDealRecordsResponse) Descriptor deprecated

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

Deprecated: Use ListRetrievalDealRecordsResponse.ProtoReflect.Descriptor instead.

func (*ListRetrievalDealRecordsResponse) GetRecords

func (*ListRetrievalDealRecordsResponse) ProtoMessage

func (*ListRetrievalDealRecordsResponse) ProtoMessage()

func (*ListRetrievalDealRecordsResponse) ProtoReflect

func (*ListRetrievalDealRecordsResponse) Reset

func (*ListRetrievalDealRecordsResponse) String

type ListStorageDealRecordsRequest

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

func (*ListStorageDealRecordsRequest) Descriptor deprecated

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

Deprecated: Use ListStorageDealRecordsRequest.ProtoReflect.Descriptor instead.

func (*ListStorageDealRecordsRequest) GetConfig

func (*ListStorageDealRecordsRequest) ProtoMessage

func (*ListStorageDealRecordsRequest) ProtoMessage()

func (*ListStorageDealRecordsRequest) ProtoReflect

func (*ListStorageDealRecordsRequest) Reset

func (x *ListStorageDealRecordsRequest) Reset()

func (*ListStorageDealRecordsRequest) String

type ListStorageDealRecordsResponse

type ListStorageDealRecordsResponse struct {
	Records []*StorageDealRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStorageDealRecordsResponse) Descriptor deprecated

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

Deprecated: Use ListStorageDealRecordsResponse.ProtoReflect.Descriptor instead.

func (*ListStorageDealRecordsResponse) GetRecords

func (*ListStorageDealRecordsResponse) ProtoMessage

func (*ListStorageDealRecordsResponse) ProtoMessage()

func (*ListStorageDealRecordsResponse) ProtoReflect

func (*ListStorageDealRecordsResponse) Reset

func (x *ListStorageDealRecordsResponse) Reset()

func (*ListStorageDealRecordsResponse) String

type 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 (*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) 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) 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)
	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)
	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 (*SetDefaultStorageConfigRequest) ProtoMessage added in v0.2.0

func (*SetDefaultStorageConfigRequest) ProtoMessage()

func (*SetDefaultStorageConfigRequest) ProtoReflect added in v0.2.0

func (*SetDefaultStorageConfigRequest) Reset added in v0.2.0

func (x *SetDefaultStorageConfigRequest) Reset()

func (*SetDefaultStorageConfigRequest) String added in v0.2.0

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 (*SetDefaultStorageConfigResponse) Reset added in v0.2.0

func (*SetDefaultStorageConfigResponse) String added in v0.2.0

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

func (*UnimplementedRPCServiceServer) Create

func (*UnimplementedRPCServiceServer) CreatePayChannel

func (*UnimplementedRPCServiceServer) DefaultStorageConfig added in v0.2.0

func (*UnimplementedRPCServiceServer) Get

func (*UnimplementedRPCServiceServer) GetStorageConfig added in v0.2.0

func (*UnimplementedRPCServiceServer) GetStorageJob added in v0.6.0

func (*UnimplementedRPCServiceServer) ID

func (*UnimplementedRPCServiceServer) Info

func (*UnimplementedRPCServiceServer) ListAPI

func (*UnimplementedRPCServiceServer) ListPayChannels

func (*UnimplementedRPCServiceServer) NewAddr

func (*UnimplementedRPCServiceServer) PushStorageConfig added in v0.2.0

func (*UnimplementedRPCServiceServer) RedeemPayChannel

func (*UnimplementedRPCServiceServer) Remove

func (*UnimplementedRPCServiceServer) Replace

func (*UnimplementedRPCServiceServer) SendFil

func (*UnimplementedRPCServiceServer) SetDefaultStorageConfig added in v0.2.0

func (*UnimplementedRPCServiceServer) Show

func (*UnimplementedRPCServiceServer) ShowAll

func (*UnimplementedRPCServiceServer) Stage added in v0.2.0

func (*UnimplementedRPCServiceServer) WatchJobs

func (*UnimplementedRPCServiceServer) WatchLogs

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

Jump to

Keyboard shortcuts

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