powergate: github.com/textileio/powergate/ffs/rpc Index | Files

package rpc

import "github.com/textileio/powergate/ffs/rpc"

Index

Package Files

rpc.go rpc.pb.go

Variables

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.

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.

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

func RegisterRPCServiceServer Uses

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

type AddrInfo Uses

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 Uses

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

Deprecated: Use AddrInfo.ProtoReflect.Descriptor instead.

func (*AddrInfo) GetAddr Uses

func (x *AddrInfo) GetAddr() string

func (*AddrInfo) GetName Uses

func (x *AddrInfo) GetName() string

func (*AddrInfo) GetType Uses

func (x *AddrInfo) GetType() string

func (*AddrInfo) ProtoMessage Uses

func (*AddrInfo) ProtoMessage()

func (*AddrInfo) ProtoReflect Uses

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

func (*AddrInfo) Reset Uses

func (x *AddrInfo) Reset()

func (*AddrInfo) String Uses

func (x *AddrInfo) String() string

type AddrsRequest Uses

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

func (*AddrsRequest) Descriptor Uses

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

Deprecated: Use AddrsRequest.ProtoReflect.Descriptor instead.

func (*AddrsRequest) ProtoMessage Uses

func (*AddrsRequest) ProtoMessage()

func (*AddrsRequest) ProtoReflect Uses

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

func (*AddrsRequest) Reset Uses

func (x *AddrsRequest) Reset()

func (*AddrsRequest) String Uses

func (x *AddrsRequest) String() string

type AddrsResponse Uses

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

func (*AddrsResponse) Descriptor Uses

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

Deprecated: Use AddrsResponse.ProtoReflect.Descriptor instead.

func (*AddrsResponse) GetAddrs Uses

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

func (*AddrsResponse) ProtoMessage Uses

func (*AddrsResponse) ProtoMessage()

func (*AddrsResponse) ProtoReflect Uses

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

func (*AddrsResponse) Reset Uses

func (x *AddrsResponse) Reset()

func (*AddrsResponse) String Uses

func (x *AddrsResponse) String() string

type BalanceInfo Uses

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 Uses

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

Deprecated: Use BalanceInfo.ProtoReflect.Descriptor instead.

func (*BalanceInfo) GetAddr Uses

func (x *BalanceInfo) GetAddr() *AddrInfo

func (*BalanceInfo) GetBalance Uses

func (x *BalanceInfo) GetBalance() int64

func (*BalanceInfo) ProtoMessage Uses

func (*BalanceInfo) ProtoMessage()

func (*BalanceInfo) ProtoReflect Uses

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

func (*BalanceInfo) Reset Uses

func (x *BalanceInfo) Reset()

func (*BalanceInfo) String Uses

func (x *BalanceInfo) String() string

type CancelJobRequest Uses

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

func (*CancelJobRequest) Descriptor Uses

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

Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.

func (*CancelJobRequest) GetJid Uses

func (x *CancelJobRequest) GetJid() string

func (*CancelJobRequest) ProtoMessage Uses

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) ProtoReflect Uses

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

func (*CancelJobRequest) Reset Uses

func (x *CancelJobRequest) Reset()

func (*CancelJobRequest) String Uses

func (x *CancelJobRequest) String() string

type CancelJobResponse Uses

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

func (*CancelJobResponse) Descriptor Uses

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

Deprecated: Use CancelJobResponse.ProtoReflect.Descriptor instead.

func (*CancelJobResponse) ProtoMessage Uses

func (*CancelJobResponse) ProtoMessage()

func (*CancelJobResponse) ProtoReflect Uses

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

func (*CancelJobResponse) Reset Uses

func (x *CancelJobResponse) Reset()

func (*CancelJobResponse) String Uses

func (x *CancelJobResponse) String() string

type CidInfo Uses

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 Uses

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

Deprecated: Use CidInfo.ProtoReflect.Descriptor instead.

func (*CidInfo) GetCid Uses

func (x *CidInfo) GetCid() string

func (*CidInfo) GetCold Uses

func (x *CidInfo) GetCold() *ColdInfo

func (*CidInfo) GetCreated Uses

func (x *CidInfo) GetCreated() int64

func (*CidInfo) GetHot Uses

func (x *CidInfo) GetHot() *HotInfo

func (*CidInfo) GetJobId Uses

func (x *CidInfo) GetJobId() string

func (*CidInfo) ProtoMessage Uses

func (*CidInfo) ProtoMessage()

func (*CidInfo) ProtoReflect Uses

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

func (*CidInfo) Reset Uses

func (x *CidInfo) Reset()

func (*CidInfo) String Uses

func (x *CidInfo) String() string

type ColdConfig Uses

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 Uses

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

Deprecated: Use ColdConfig.ProtoReflect.Descriptor instead.

func (*ColdConfig) GetEnabled Uses

func (x *ColdConfig) GetEnabled() bool

func (*ColdConfig) GetFilecoin Uses

func (x *ColdConfig) GetFilecoin() *FilConfig

func (*ColdConfig) ProtoMessage Uses

func (*ColdConfig) ProtoMessage()

func (*ColdConfig) ProtoReflect Uses

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

func (*ColdConfig) Reset Uses

func (x *ColdConfig) Reset()

func (*ColdConfig) String Uses

func (x *ColdConfig) String() string

type ColdInfo Uses

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 Uses

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

Deprecated: Use ColdInfo.ProtoReflect.Descriptor instead.

func (*ColdInfo) GetEnabled Uses

func (x *ColdInfo) GetEnabled() bool

func (*ColdInfo) GetFilecoin Uses

func (x *ColdInfo) GetFilecoin() *FilInfo

func (*ColdInfo) ProtoMessage Uses

func (*ColdInfo) ProtoMessage()

func (*ColdInfo) ProtoReflect Uses

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

func (*ColdInfo) Reset Uses

func (x *ColdInfo) Reset()

func (*ColdInfo) String Uses

func (x *ColdInfo) String() string

type CreatePayChannelRequest Uses

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 Uses

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

Deprecated: Use CreatePayChannelRequest.ProtoReflect.Descriptor instead.

func (*CreatePayChannelRequest) GetAmount Uses

func (x *CreatePayChannelRequest) GetAmount() uint64

func (*CreatePayChannelRequest) GetFrom Uses

func (x *CreatePayChannelRequest) GetFrom() string

func (*CreatePayChannelRequest) GetTo Uses

func (x *CreatePayChannelRequest) GetTo() string

func (*CreatePayChannelRequest) ProtoMessage Uses

func (*CreatePayChannelRequest) ProtoMessage()

func (*CreatePayChannelRequest) ProtoReflect Uses

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

func (*CreatePayChannelRequest) Reset Uses

func (x *CreatePayChannelRequest) Reset()

func (*CreatePayChannelRequest) String Uses

func (x *CreatePayChannelRequest) String() string

type CreatePayChannelResponse Uses

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 Uses

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

Deprecated: Use CreatePayChannelResponse.ProtoReflect.Descriptor instead.

func (*CreatePayChannelResponse) GetChannelMessageCid Uses

func (x *CreatePayChannelResponse) GetChannelMessageCid() string

func (*CreatePayChannelResponse) GetPayChannel Uses

func (x *CreatePayChannelResponse) GetPayChannel() *PaychInfo

func (*CreatePayChannelResponse) ProtoMessage Uses

func (*CreatePayChannelResponse) ProtoMessage()

func (*CreatePayChannelResponse) ProtoReflect Uses

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

func (*CreatePayChannelResponse) Reset Uses

func (x *CreatePayChannelResponse) Reset()

func (*CreatePayChannelResponse) String Uses

func (x *CreatePayChannelResponse) String() string

type CreateRequest Uses

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

func (*CreateRequest) Descriptor Uses

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) ProtoMessage Uses

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect Uses

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

func (*CreateRequest) Reset Uses

func (x *CreateRequest) Reset()

func (*CreateRequest) String Uses

func (x *CreateRequest) String() string

type CreateResponse Uses

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 Uses

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetId Uses

func (x *CreateResponse) GetId() string

func (*CreateResponse) GetToken Uses

func (x *CreateResponse) GetToken() string

func (*CreateResponse) ProtoMessage Uses

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect Uses

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

func (*CreateResponse) Reset Uses

func (x *CreateResponse) Reset()

func (*CreateResponse) String Uses

func (x *CreateResponse) String() string

type DealError Uses

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 Uses

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

Deprecated: Use DealError.ProtoReflect.Descriptor instead.

func (*DealError) GetMessage Uses

func (x *DealError) GetMessage() string

func (*DealError) GetMiner Uses

func (x *DealError) GetMiner() string

func (*DealError) GetProposalCid Uses

func (x *DealError) GetProposalCid() string

func (*DealError) ProtoMessage Uses

func (*DealError) ProtoMessage()

func (*DealError) ProtoReflect Uses

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

func (*DealError) Reset Uses

func (x *DealError) Reset()

func (*DealError) String Uses

func (x *DealError) String() string

type DefaultStorageConfigRequest Uses

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

func (*DefaultStorageConfigRequest) Descriptor Uses

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

Deprecated: Use DefaultStorageConfigRequest.ProtoReflect.Descriptor instead.

func (*DefaultStorageConfigRequest) ProtoMessage Uses

func (*DefaultStorageConfigRequest) ProtoMessage()

func (*DefaultStorageConfigRequest) ProtoReflect Uses

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

func (*DefaultStorageConfigRequest) Reset Uses

func (x *DefaultStorageConfigRequest) Reset()

func (*DefaultStorageConfigRequest) String Uses

func (x *DefaultStorageConfigRequest) String() string

type DefaultStorageConfigResponse Uses

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 Uses

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

Deprecated: Use DefaultStorageConfigResponse.ProtoReflect.Descriptor instead.

func (*DefaultStorageConfigResponse) GetDefaultStorageConfig Uses

func (x *DefaultStorageConfigResponse) GetDefaultStorageConfig() *StorageConfig

func (*DefaultStorageConfigResponse) ProtoMessage Uses

func (*DefaultStorageConfigResponse) ProtoMessage()

func (*DefaultStorageConfigResponse) ProtoReflect Uses

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

func (*DefaultStorageConfigResponse) Reset Uses

func (x *DefaultStorageConfigResponse) Reset()

func (*DefaultStorageConfigResponse) String Uses

func (x *DefaultStorageConfigResponse) String() string

type Direction Uses

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

func (Direction) Descriptor Uses

func (Direction) Descriptor() protoreflect.EnumDescriptor

func (Direction) Enum Uses

func (x Direction) Enum() *Direction

func (Direction) EnumDescriptor Uses

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

Deprecated: Use Direction.Descriptor instead.

func (Direction) Number Uses

func (x Direction) Number() protoreflect.EnumNumber

func (Direction) String Uses

func (x Direction) String() string

func (Direction) Type Uses

func (Direction) Type() protoreflect.EnumType

type FilConfig Uses

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 Uses

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

Deprecated: Use FilConfig.ProtoReflect.Descriptor instead.

func (*FilConfig) GetAddr Uses

func (x *FilConfig) GetAddr() string

func (*FilConfig) GetCountryCodes Uses

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

func (*FilConfig) GetDealMinDuration Uses

func (x *FilConfig) GetDealMinDuration() int64

func (*FilConfig) GetDealStartOffset Uses

func (x *FilConfig) GetDealStartOffset() int64

func (*FilConfig) GetExcludedMiners Uses

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

func (*FilConfig) GetFastRetrieval Uses

func (x *FilConfig) GetFastRetrieval() bool

func (*FilConfig) GetMaxPrice Uses

func (x *FilConfig) GetMaxPrice() uint64

func (*FilConfig) GetRenew Uses

func (x *FilConfig) GetRenew() *FilRenew

func (*FilConfig) GetRepFactor Uses

func (x *FilConfig) GetRepFactor() int64

func (*FilConfig) GetTrustedMiners Uses

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

func (*FilConfig) ProtoMessage Uses

func (*FilConfig) ProtoMessage()

func (*FilConfig) ProtoReflect Uses

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

func (*FilConfig) Reset Uses

func (x *FilConfig) Reset()

func (*FilConfig) String Uses

func (x *FilConfig) String() string

type FilInfo Uses

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 Uses

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

Deprecated: Use FilInfo.ProtoReflect.Descriptor instead.

func (*FilInfo) GetDataCid Uses

func (x *FilInfo) GetDataCid() string

func (*FilInfo) GetProposals Uses

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

func (*FilInfo) GetSize Uses

func (x *FilInfo) GetSize() uint64

func (*FilInfo) ProtoMessage Uses

func (*FilInfo) ProtoMessage()

func (*FilInfo) ProtoReflect Uses

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

func (*FilInfo) Reset Uses

func (x *FilInfo) Reset()

func (*FilInfo) String Uses

func (x *FilInfo) String() string

type FilRenew Uses

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 Uses

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

Deprecated: Use FilRenew.ProtoReflect.Descriptor instead.

func (*FilRenew) GetEnabled Uses

func (x *FilRenew) GetEnabled() bool

func (*FilRenew) GetThreshold Uses

func (x *FilRenew) GetThreshold() int64

func (*FilRenew) ProtoMessage Uses

func (*FilRenew) ProtoMessage()

func (*FilRenew) ProtoReflect Uses

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

func (*FilRenew) Reset Uses

func (x *FilRenew) Reset()

func (*FilRenew) String Uses

func (x *FilRenew) String() string

type FilStorage Uses

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 Uses

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

Deprecated: Use FilStorage.ProtoReflect.Descriptor instead.

func (*FilStorage) GetActivationEpoch Uses

func (x *FilStorage) GetActivationEpoch() int64

func (*FilStorage) GetDuration Uses

func (x *FilStorage) GetDuration() int64

func (*FilStorage) GetEpochPrice Uses

func (x *FilStorage) GetEpochPrice() uint64

func (*FilStorage) GetMiner Uses

func (x *FilStorage) GetMiner() string

func (*FilStorage) GetPieceCid Uses

func (x *FilStorage) GetPieceCid() string

func (*FilStorage) GetProposalCid Uses

func (x *FilStorage) GetProposalCid() string

func (*FilStorage) GetRenewed Uses

func (x *FilStorage) GetRenewed() bool

func (*FilStorage) GetStartEpoch Uses

func (x *FilStorage) GetStartEpoch() uint64

func (*FilStorage) ProtoMessage Uses

func (*FilStorage) ProtoMessage()

func (*FilStorage) ProtoReflect Uses

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

func (*FilStorage) Reset Uses

func (x *FilStorage) Reset()

func (*FilStorage) String Uses

func (x *FilStorage) String() string

type GetRequest Uses

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

func (*GetRequest) Descriptor Uses

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetCid Uses

func (x *GetRequest) GetCid() string

func (*GetRequest) ProtoMessage Uses

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect Uses

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

func (*GetRequest) Reset Uses

func (x *GetRequest) Reset()

func (*GetRequest) String Uses

func (x *GetRequest) String() string

type GetResponse Uses

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

func (*GetResponse) Descriptor Uses

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetChunk Uses

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

func (*GetResponse) ProtoMessage Uses

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect Uses

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

func (*GetResponse) Reset Uses

func (x *GetResponse) Reset()

func (*GetResponse) String Uses

func (x *GetResponse) String() string

type GetStorageConfigRequest Uses

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

func (*GetStorageConfigRequest) Descriptor Uses

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

Deprecated: Use GetStorageConfigRequest.ProtoReflect.Descriptor instead.

func (*GetStorageConfigRequest) GetCid Uses

func (x *GetStorageConfigRequest) GetCid() string

func (*GetStorageConfigRequest) ProtoMessage Uses

func (*GetStorageConfigRequest) ProtoMessage()

func (*GetStorageConfigRequest) ProtoReflect Uses

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

func (*GetStorageConfigRequest) Reset Uses

func (x *GetStorageConfigRequest) Reset()

func (*GetStorageConfigRequest) String Uses

func (x *GetStorageConfigRequest) String() string

type GetStorageConfigResponse Uses

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

func (*GetStorageConfigResponse) Descriptor Uses

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

Deprecated: Use GetStorageConfigResponse.ProtoReflect.Descriptor instead.

func (*GetStorageConfigResponse) GetConfig Uses

func (x *GetStorageConfigResponse) GetConfig() *StorageConfig

func (*GetStorageConfigResponse) ProtoMessage Uses

func (*GetStorageConfigResponse) ProtoMessage()

func (*GetStorageConfigResponse) ProtoReflect Uses

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

func (*GetStorageConfigResponse) Reset Uses

func (x *GetStorageConfigResponse) Reset()

func (*GetStorageConfigResponse) String Uses

func (x *GetStorageConfigResponse) String() string

type GetStorageJobRequest Uses

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

func (*GetStorageJobRequest) Descriptor Uses

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

Deprecated: Use GetStorageJobRequest.ProtoReflect.Descriptor instead.

func (*GetStorageJobRequest) GetJid Uses

func (x *GetStorageJobRequest) GetJid() string

func (*GetStorageJobRequest) ProtoMessage Uses

func (*GetStorageJobRequest) ProtoMessage()

func (*GetStorageJobRequest) ProtoReflect Uses

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

func (*GetStorageJobRequest) Reset Uses

func (x *GetStorageJobRequest) Reset()

func (*GetStorageJobRequest) String Uses

func (x *GetStorageJobRequest) String() string

type GetStorageJobResponse Uses

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

func (*GetStorageJobResponse) Descriptor Uses

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

Deprecated: Use GetStorageJobResponse.ProtoReflect.Descriptor instead.

func (*GetStorageJobResponse) GetJob Uses

func (x *GetStorageJobResponse) GetJob() *Job

func (*GetStorageJobResponse) ProtoMessage Uses

func (*GetStorageJobResponse) ProtoMessage()

func (*GetStorageJobResponse) ProtoReflect Uses

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

func (*GetStorageJobResponse) Reset Uses

func (x *GetStorageJobResponse) Reset()

func (*GetStorageJobResponse) String Uses

func (x *GetStorageJobResponse) String() string

type HotConfig Uses

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 Uses

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

Deprecated: Use HotConfig.ProtoReflect.Descriptor instead.

func (*HotConfig) GetAllowUnfreeze Uses

func (x *HotConfig) GetAllowUnfreeze() bool

func (*HotConfig) GetEnabled Uses

func (x *HotConfig) GetEnabled() bool

func (*HotConfig) GetIpfs Uses

func (x *HotConfig) GetIpfs() *IpfsConfig

func (*HotConfig) GetUnfreezeMaxPrice Uses

func (x *HotConfig) GetUnfreezeMaxPrice() uint64

func (*HotConfig) ProtoMessage Uses

func (*HotConfig) ProtoMessage()

func (*HotConfig) ProtoReflect Uses

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

func (*HotConfig) Reset Uses

func (x *HotConfig) Reset()

func (*HotConfig) String Uses

func (x *HotConfig) String() string

type HotInfo Uses

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 Uses

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

Deprecated: Use HotInfo.ProtoReflect.Descriptor instead.

func (*HotInfo) GetEnabled Uses

func (x *HotInfo) GetEnabled() bool

func (*HotInfo) GetIpfs Uses

func (x *HotInfo) GetIpfs() *IpfsHotInfo

func (*HotInfo) GetSize Uses

func (x *HotInfo) GetSize() int64

func (*HotInfo) ProtoMessage Uses

func (*HotInfo) ProtoMessage()

func (*HotInfo) ProtoReflect Uses

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

func (*HotInfo) Reset Uses

func (x *HotInfo) Reset()

func (*HotInfo) String Uses

func (x *HotInfo) String() string

type IDRequest Uses

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

func (*IDRequest) Descriptor Uses

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

Deprecated: Use IDRequest.ProtoReflect.Descriptor instead.

func (*IDRequest) ProtoMessage Uses

func (*IDRequest) ProtoMessage()

func (*IDRequest) ProtoReflect Uses

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

func (*IDRequest) Reset Uses

func (x *IDRequest) Reset()

func (*IDRequest) String Uses

func (x *IDRequest) String() string

type IDResponse Uses

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

func (*IDResponse) Descriptor Uses

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

Deprecated: Use IDResponse.ProtoReflect.Descriptor instead.

func (*IDResponse) GetId Uses

func (x *IDResponse) GetId() string

func (*IDResponse) ProtoMessage Uses

func (*IDResponse) ProtoMessage()

func (*IDResponse) ProtoReflect Uses

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

func (*IDResponse) Reset Uses

func (x *IDResponse) Reset()

func (*IDResponse) String Uses

func (x *IDResponse) String() string

type InfoRequest Uses

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

func (*InfoRequest) Descriptor Uses

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

Deprecated: Use InfoRequest.ProtoReflect.Descriptor instead.

func (*InfoRequest) ProtoMessage Uses

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) ProtoReflect Uses

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

func (*InfoRequest) Reset Uses

func (x *InfoRequest) Reset()

func (*InfoRequest) String Uses

func (x *InfoRequest) String() string

type InfoResponse Uses

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

func (*InfoResponse) Descriptor Uses

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

Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.

func (*InfoResponse) GetInfo Uses

func (x *InfoResponse) GetInfo() *InstanceInfo

func (*InfoResponse) ProtoMessage Uses

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) ProtoReflect Uses

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

func (*InfoResponse) Reset Uses

func (x *InfoResponse) Reset()

func (*InfoResponse) String Uses

func (x *InfoResponse) String() string

type InstanceInfo Uses

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 Uses

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

Deprecated: Use InstanceInfo.ProtoReflect.Descriptor instead.

func (*InstanceInfo) GetBalances Uses

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

func (*InstanceInfo) GetDefaultStorageConfig Uses

func (x *InstanceInfo) GetDefaultStorageConfig() *StorageConfig

func (*InstanceInfo) GetId Uses

func (x *InstanceInfo) GetId() string

func (*InstanceInfo) GetPins Uses

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

func (*InstanceInfo) ProtoMessage Uses

func (*InstanceInfo) ProtoMessage()

func (*InstanceInfo) ProtoReflect Uses

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

func (*InstanceInfo) Reset Uses

func (x *InstanceInfo) Reset()

func (*InstanceInfo) String Uses

func (x *InstanceInfo) String() string

type IpfsConfig Uses

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 Uses

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

Deprecated: Use IpfsConfig.ProtoReflect.Descriptor instead.

func (*IpfsConfig) GetAddTimeout Uses

func (x *IpfsConfig) GetAddTimeout() int64

func (*IpfsConfig) ProtoMessage Uses

func (*IpfsConfig) ProtoMessage()

func (*IpfsConfig) ProtoReflect Uses

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

func (*IpfsConfig) Reset Uses

func (x *IpfsConfig) Reset()

func (*IpfsConfig) String Uses

func (x *IpfsConfig) String() string

type IpfsHotInfo Uses

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

func (*IpfsHotInfo) Descriptor Uses

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

Deprecated: Use IpfsHotInfo.ProtoReflect.Descriptor instead.

func (*IpfsHotInfo) GetCreated Uses

func (x *IpfsHotInfo) GetCreated() int64

func (*IpfsHotInfo) ProtoMessage Uses

func (*IpfsHotInfo) ProtoMessage()

func (*IpfsHotInfo) ProtoReflect Uses

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

func (*IpfsHotInfo) Reset Uses

func (x *IpfsHotInfo) Reset()

func (*IpfsHotInfo) String Uses

func (x *IpfsHotInfo) String() string

type Job Uses

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 Uses

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetApiId Uses

func (x *Job) GetApiId() string

func (*Job) GetCid Uses

func (x *Job) GetCid() string

func (*Job) GetDealErrors Uses

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

func (*Job) GetErrCause Uses

func (x *Job) GetErrCause() string

func (*Job) GetId Uses

func (x *Job) GetId() string

func (*Job) GetStatus Uses

func (x *Job) GetStatus() JobStatus

func (*Job) ProtoMessage Uses

func (*Job) ProtoMessage()

func (*Job) ProtoReflect Uses

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

func (*Job) Reset Uses

func (x *Job) Reset()

func (*Job) String Uses

func (x *Job) String() string

type JobStatus Uses

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 Uses

func (JobStatus) Descriptor() protoreflect.EnumDescriptor

func (JobStatus) Enum Uses

func (x JobStatus) Enum() *JobStatus

func (JobStatus) EnumDescriptor Uses

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

Deprecated: Use JobStatus.Descriptor instead.

func (JobStatus) Number Uses

func (x JobStatus) Number() protoreflect.EnumNumber

func (JobStatus) String Uses

func (x JobStatus) String() string

func (JobStatus) Type Uses

func (JobStatus) Type() protoreflect.EnumType

type ListAPIRequest Uses

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

func (*ListAPIRequest) Descriptor Uses

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

Deprecated: Use ListAPIRequest.ProtoReflect.Descriptor instead.

func (*ListAPIRequest) ProtoMessage Uses

func (*ListAPIRequest) ProtoMessage()

func (*ListAPIRequest) ProtoReflect Uses

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

func (*ListAPIRequest) Reset Uses

func (x *ListAPIRequest) Reset()

func (*ListAPIRequest) String Uses

func (x *ListAPIRequest) String() string

type ListAPIResponse Uses

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

func (*ListAPIResponse) Descriptor Uses

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

Deprecated: Use ListAPIResponse.ProtoReflect.Descriptor instead.

func (*ListAPIResponse) GetInstances Uses

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

func (*ListAPIResponse) ProtoMessage Uses

func (*ListAPIResponse) ProtoMessage()

func (*ListAPIResponse) ProtoReflect Uses

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

func (*ListAPIResponse) Reset Uses

func (x *ListAPIResponse) Reset()

func (*ListAPIResponse) String Uses

func (x *ListAPIResponse) String() string

type ListDealRecordsConfig Uses

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 Uses

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

Deprecated: Use ListDealRecordsConfig.ProtoReflect.Descriptor instead.

func (*ListDealRecordsConfig) GetAscending Uses

func (x *ListDealRecordsConfig) GetAscending() bool

func (*ListDealRecordsConfig) GetDataCids Uses

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

func (*ListDealRecordsConfig) GetFromAddrs Uses

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

func (*ListDealRecordsConfig) GetIncludeFinal Uses

func (x *ListDealRecordsConfig) GetIncludeFinal() bool

func (*ListDealRecordsConfig) GetIncludePending Uses

func (x *ListDealRecordsConfig) GetIncludePending() bool

func (*ListDealRecordsConfig) ProtoMessage Uses

func (*ListDealRecordsConfig) ProtoMessage()

func (*ListDealRecordsConfig) ProtoReflect Uses

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

func (*ListDealRecordsConfig) Reset Uses

func (x *ListDealRecordsConfig) Reset()

func (*ListDealRecordsConfig) String Uses

func (x *ListDealRecordsConfig) String() string

type ListPayChannelsRequest Uses

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

func (*ListPayChannelsRequest) Descriptor Uses

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

Deprecated: Use ListPayChannelsRequest.ProtoReflect.Descriptor instead.

func (*ListPayChannelsRequest) ProtoMessage Uses

func (*ListPayChannelsRequest) ProtoMessage()

func (*ListPayChannelsRequest) ProtoReflect Uses

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

func (*ListPayChannelsRequest) Reset Uses

func (x *ListPayChannelsRequest) Reset()

func (*ListPayChannelsRequest) String Uses

func (x *ListPayChannelsRequest) String() string

type ListPayChannelsResponse Uses

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 Uses

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

Deprecated: Use ListPayChannelsResponse.ProtoReflect.Descriptor instead.

func (*ListPayChannelsResponse) GetPayChannels Uses

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

func (*ListPayChannelsResponse) ProtoMessage Uses

func (*ListPayChannelsResponse) ProtoMessage()

func (*ListPayChannelsResponse) ProtoReflect Uses

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

func (*ListPayChannelsResponse) Reset Uses

func (x *ListPayChannelsResponse) Reset()

func (*ListPayChannelsResponse) String Uses

func (x *ListPayChannelsResponse) String() string

type ListRetrievalDealRecordsRequest Uses

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

func (*ListRetrievalDealRecordsRequest) Descriptor Uses

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

Deprecated: Use ListRetrievalDealRecordsRequest.ProtoReflect.Descriptor instead.

func (*ListRetrievalDealRecordsRequest) GetConfig Uses

func (x *ListRetrievalDealRecordsRequest) GetConfig() *ListDealRecordsConfig

func (*ListRetrievalDealRecordsRequest) ProtoMessage Uses

func (*ListRetrievalDealRecordsRequest) ProtoMessage()

func (*ListRetrievalDealRecordsRequest) ProtoReflect Uses

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

func (*ListRetrievalDealRecordsRequest) Reset Uses

func (x *ListRetrievalDealRecordsRequest) Reset()

func (*ListRetrievalDealRecordsRequest) String Uses

func (x *ListRetrievalDealRecordsRequest) String() string

type ListRetrievalDealRecordsResponse Uses

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

func (*ListRetrievalDealRecordsResponse) Descriptor Uses

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

Deprecated: Use ListRetrievalDealRecordsResponse.ProtoReflect.Descriptor instead.

func (*ListRetrievalDealRecordsResponse) GetRecords Uses

func (x *ListRetrievalDealRecordsResponse) GetRecords() []*RetrievalDealRecord

func (*ListRetrievalDealRecordsResponse) ProtoMessage Uses

func (*ListRetrievalDealRecordsResponse) ProtoMessage()

func (*ListRetrievalDealRecordsResponse) ProtoReflect Uses

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

func (*ListRetrievalDealRecordsResponse) Reset Uses

func (x *ListRetrievalDealRecordsResponse) Reset()

func (*ListRetrievalDealRecordsResponse) String Uses

func (x *ListRetrievalDealRecordsResponse) String() string

type ListStorageDealRecordsRequest Uses

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

func (*ListStorageDealRecordsRequest) Descriptor Uses

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

Deprecated: Use ListStorageDealRecordsRequest.ProtoReflect.Descriptor instead.

func (*ListStorageDealRecordsRequest) GetConfig Uses

func (x *ListStorageDealRecordsRequest) GetConfig() *ListDealRecordsConfig

func (*ListStorageDealRecordsRequest) ProtoMessage Uses

func (*ListStorageDealRecordsRequest) ProtoMessage()

func (*ListStorageDealRecordsRequest) ProtoReflect Uses

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

func (*ListStorageDealRecordsRequest) Reset Uses

func (x *ListStorageDealRecordsRequest) Reset()

func (*ListStorageDealRecordsRequest) String Uses

func (x *ListStorageDealRecordsRequest) String() string

type ListStorageDealRecordsResponse Uses

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

func (*ListStorageDealRecordsResponse) Descriptor Uses

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

Deprecated: Use ListStorageDealRecordsResponse.ProtoReflect.Descriptor instead.

func (*ListStorageDealRecordsResponse) GetRecords Uses

func (x *ListStorageDealRecordsResponse) GetRecords() []*StorageDealRecord

func (*ListStorageDealRecordsResponse) ProtoMessage Uses

func (*ListStorageDealRecordsResponse) ProtoMessage()

func (*ListStorageDealRecordsResponse) ProtoReflect Uses

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

func (*ListStorageDealRecordsResponse) Reset Uses

func (x *ListStorageDealRecordsResponse) Reset()

func (*ListStorageDealRecordsResponse) String Uses

func (x *ListStorageDealRecordsResponse) String() string

type LogEntry Uses

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 Uses

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetCid Uses

func (x *LogEntry) GetCid() string

func (*LogEntry) GetJid Uses

func (x *LogEntry) GetJid() string

func (*LogEntry) GetMsg Uses

func (x *LogEntry) GetMsg() string

func (*LogEntry) GetTime Uses

func (x *LogEntry) GetTime() int64

func (*LogEntry) ProtoMessage Uses

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect Uses

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

func (*LogEntry) Reset Uses

func (x *LogEntry) Reset()

func (*LogEntry) String Uses

func (x *LogEntry) String() string

type NewAddrRequest Uses

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 Uses

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

Deprecated: Use NewAddrRequest.ProtoReflect.Descriptor instead.

func (*NewAddrRequest) GetAddressType Uses

func (x *NewAddrRequest) GetAddressType() string

func (*NewAddrRequest) GetMakeDefault Uses

func (x *NewAddrRequest) GetMakeDefault() bool

func (*NewAddrRequest) GetName Uses

func (x *NewAddrRequest) GetName() string

func (*NewAddrRequest) ProtoMessage Uses

func (*NewAddrRequest) ProtoMessage()

func (*NewAddrRequest) ProtoReflect Uses

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

func (*NewAddrRequest) Reset Uses

func (x *NewAddrRequest) Reset()

func (*NewAddrRequest) String Uses

func (x *NewAddrRequest) String() string

type NewAddrResponse Uses

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

func (*NewAddrResponse) Descriptor Uses

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

Deprecated: Use NewAddrResponse.ProtoReflect.Descriptor instead.

func (*NewAddrResponse) GetAddr Uses

func (x *NewAddrResponse) GetAddr() string

func (*NewAddrResponse) ProtoMessage Uses

func (*NewAddrResponse) ProtoMessage()

func (*NewAddrResponse) ProtoReflect Uses

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

func (*NewAddrResponse) Reset Uses

func (x *NewAddrResponse) Reset()

func (*NewAddrResponse) String Uses

func (x *NewAddrResponse) String() string

type PaychInfo Uses

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 Uses

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

Deprecated: Use PaychInfo.ProtoReflect.Descriptor instead.

func (*PaychInfo) GetAddr Uses

func (x *PaychInfo) GetAddr() string

func (*PaychInfo) GetCtlAddr Uses

func (x *PaychInfo) GetCtlAddr() string

func (*PaychInfo) GetDirection Uses

func (x *PaychInfo) GetDirection() Direction

func (*PaychInfo) ProtoMessage Uses

func (*PaychInfo) ProtoMessage()

func (*PaychInfo) ProtoReflect Uses

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

func (*PaychInfo) Reset Uses

func (x *PaychInfo) Reset()

func (*PaychInfo) String Uses

func (x *PaychInfo) String() string

type PushStorageConfigRequest Uses

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 Uses

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

Deprecated: Use PushStorageConfigRequest.ProtoReflect.Descriptor instead.

func (*PushStorageConfigRequest) GetCid Uses

func (x *PushStorageConfigRequest) GetCid() string

func (*PushStorageConfigRequest) GetConfig Uses

func (x *PushStorageConfigRequest) GetConfig() *StorageConfig

func (*PushStorageConfigRequest) GetHasConfig Uses

func (x *PushStorageConfigRequest) GetHasConfig() bool

func (*PushStorageConfigRequest) GetHasOverrideConfig Uses

func (x *PushStorageConfigRequest) GetHasOverrideConfig() bool

func (*PushStorageConfigRequest) GetOverrideConfig Uses

func (x *PushStorageConfigRequest) GetOverrideConfig() bool

func (*PushStorageConfigRequest) ProtoMessage Uses

func (*PushStorageConfigRequest) ProtoMessage()

func (*PushStorageConfigRequest) ProtoReflect Uses

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

func (*PushStorageConfigRequest) Reset Uses

func (x *PushStorageConfigRequest) Reset()

func (*PushStorageConfigRequest) String Uses

func (x *PushStorageConfigRequest) String() string

type PushStorageConfigResponse Uses

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 Uses

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

Deprecated: Use PushStorageConfigResponse.ProtoReflect.Descriptor instead.

func (*PushStorageConfigResponse) GetJobId Uses

func (x *PushStorageConfigResponse) GetJobId() string

func (*PushStorageConfigResponse) ProtoMessage Uses

func (*PushStorageConfigResponse) ProtoMessage()

func (*PushStorageConfigResponse) ProtoReflect Uses

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

func (*PushStorageConfigResponse) Reset Uses

func (x *PushStorageConfigResponse) Reset()

func (*PushStorageConfigResponse) String Uses

func (x *PushStorageConfigResponse) String() string

type RPC Uses

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

RPC implements the proto service definition of FFS.

func New Uses

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

New creates a new rpc service.

func (*RPC) Addrs Uses

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

Addrs calls ffs.Addrs.

func (*RPC) CancelJob Uses

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

CancelJob calls API.CancelJob.

func (*RPC) Create Uses

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

Create creates a new Api.

func (*RPC) CreatePayChannel Uses

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

CreatePayChannel creates a payment channel.

func (*RPC) DefaultStorageConfig Uses

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

DefaultStorageConfig calls ffs.DefaultStorageConfig.

func (*RPC) Get Uses

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

Get gets the data for a stored Cid.

func (*RPC) GetStorageConfig Uses

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

GetStorageConfig returns the storage config for the provided cid.

func (*RPC) GetStorageJob Uses

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

GetStorageJob calls API.GetStorageJob.

func (*RPC) ID Uses

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

ID returns the API instance id.

func (*RPC) Info Uses

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

Info returns an Api information.

func (*RPC) ListAPI Uses

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

ListAPI returns a list of all existing API instances.

func (*RPC) ListPayChannels Uses

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

ListPayChannels lists all pay channels.

func (*RPC) ListRetrievalDealRecords Uses

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

ListRetrievalDealRecords calls ffs.ListRetrievalDealRecords.

func (*RPC) ListStorageDealRecords Uses

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

ListStorageDealRecords calls ffs.ListStorageDealRecords.

func (*RPC) NewAddr Uses

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

NewAddr calls ffs.NewAddr.

func (*RPC) PushStorageConfig Uses

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

PushStorageConfig applies the provided cid storage config.

func (*RPC) RedeemPayChannel Uses

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

RedeemPayChannel redeems a payment channel.

func (*RPC) Remove Uses

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

Remove calls ffs.Remove.

func (*RPC) Replace Uses

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

Replace calls ffs.Replace.

func (*RPC) SendFil Uses

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 Uses

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

SetDefaultStorageConfig sets a new config to be used by default.

func (*RPC) Show Uses

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

Show returns information about a particular Cid.

func (*RPC) ShowAll Uses

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 Uses

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 Uses

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

WatchJobs calls API.WatchJobs.

func (*RPC) WatchLogs Uses

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 Uses

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 Uses

func NewRPCServiceClient(cc grpc.ClientConnInterface) RPCServiceClient

type RPCServiceServer Uses

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 Uses

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

type RPCService_GetServer Uses

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

type RPCService_StageClient Uses

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

type RPCService_StageServer Uses

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

type RPCService_WatchJobsClient Uses

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

type RPCService_WatchJobsServer Uses

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

type RPCService_WatchLogsClient Uses

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

type RPCService_WatchLogsServer Uses

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

type RedeemPayChannelRequest Uses

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 Uses

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

Deprecated: Use RedeemPayChannelRequest.ProtoReflect.Descriptor instead.

func (*RedeemPayChannelRequest) GetPayChannelAddr Uses

func (x *RedeemPayChannelRequest) GetPayChannelAddr() string

func (*RedeemPayChannelRequest) ProtoMessage Uses

func (*RedeemPayChannelRequest) ProtoMessage()

func (*RedeemPayChannelRequest) ProtoReflect Uses

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

func (*RedeemPayChannelRequest) Reset Uses

func (x *RedeemPayChannelRequest) Reset()

func (*RedeemPayChannelRequest) String Uses

func (x *RedeemPayChannelRequest) String() string

type RedeemPayChannelResponse Uses

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

func (*RedeemPayChannelResponse) Descriptor Uses

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

Deprecated: Use RedeemPayChannelResponse.ProtoReflect.Descriptor instead.

func (*RedeemPayChannelResponse) ProtoMessage Uses

func (*RedeemPayChannelResponse) ProtoMessage()

func (*RedeemPayChannelResponse) ProtoReflect Uses

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

func (*RedeemPayChannelResponse) Reset Uses

func (x *RedeemPayChannelResponse) Reset()

func (*RedeemPayChannelResponse) String Uses

func (x *RedeemPayChannelResponse) String() string

type RemoveRequest Uses

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

func (*RemoveRequest) Descriptor Uses

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

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetCid Uses

func (x *RemoveRequest) GetCid() string

func (*RemoveRequest) ProtoMessage Uses

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect Uses

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

func (*RemoveRequest) Reset Uses

func (x *RemoveRequest) Reset()

func (*RemoveRequest) String Uses

func (x *RemoveRequest) String() string

type RemoveResponse Uses

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

func (*RemoveResponse) Descriptor Uses

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

Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.

func (*RemoveResponse) ProtoMessage Uses

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) ProtoReflect Uses

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

func (*RemoveResponse) Reset Uses

func (x *RemoveResponse) Reset()

func (*RemoveResponse) String Uses

func (x *RemoveResponse) String() string

type ReplaceRequest Uses

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 Uses

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

Deprecated: Use ReplaceRequest.ProtoReflect.Descriptor instead.

func (*ReplaceRequest) GetCid1 Uses

func (x *ReplaceRequest) GetCid1() string

func (*ReplaceRequest) GetCid2 Uses

func (x *ReplaceRequest) GetCid2() string

func (*ReplaceRequest) ProtoMessage Uses

func (*ReplaceRequest) ProtoMessage()

func (*ReplaceRequest) ProtoReflect Uses

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

func (*ReplaceRequest) Reset Uses

func (x *ReplaceRequest) Reset()

func (*ReplaceRequest) String Uses

func (x *ReplaceRequest) String() string

type ReplaceResponse Uses

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 Uses

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

Deprecated: Use ReplaceResponse.ProtoReflect.Descriptor instead.

func (*ReplaceResponse) GetJobId Uses

func (x *ReplaceResponse) GetJobId() string

func (*ReplaceResponse) ProtoMessage Uses

func (*ReplaceResponse) ProtoMessage()

func (*ReplaceResponse) ProtoReflect Uses

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

func (*ReplaceResponse) Reset Uses

func (x *ReplaceResponse) Reset()

func (*ReplaceResponse) String Uses

func (x *ReplaceResponse) String() string

type RetrievalDealInfo Uses

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 `protobuf:"varint,5,opt,name=payment_interval_increase,json=paymentIntervalIncrease,proto3" json:"payment_interval_increase,omitempty"`
    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 Uses

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

Deprecated: Use RetrievalDealInfo.ProtoReflect.Descriptor instead.

func (*RetrievalDealInfo) GetMinPrice Uses

func (x *RetrievalDealInfo) GetMinPrice() uint64

func (*RetrievalDealInfo) GetMiner Uses

func (x *RetrievalDealInfo) GetMiner() string

func (*RetrievalDealInfo) GetMinerPeerId Uses

func (x *RetrievalDealInfo) GetMinerPeerId() string

func (*RetrievalDealInfo) GetPaymentInterval Uses

func (x *RetrievalDealInfo) GetPaymentInterval() uint64

func (*RetrievalDealInfo) GetPaymentIntervalIncrease Uses

func (x *RetrievalDealInfo) GetPaymentIntervalIncrease() uint64

func (*RetrievalDealInfo) GetRootCid Uses

func (x *RetrievalDealInfo) GetRootCid() string

func (*RetrievalDealInfo) GetSize Uses

func (x *RetrievalDealInfo) GetSize() uint64

func (*RetrievalDealInfo) ProtoMessage Uses

func (*RetrievalDealInfo) ProtoMessage()

func (*RetrievalDealInfo) ProtoReflect Uses

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

func (*RetrievalDealInfo) Reset Uses

func (x *RetrievalDealInfo) Reset()

func (*RetrievalDealInfo) String Uses

func (x *RetrievalDealInfo) String() string

type RetrievalDealRecord Uses

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 Uses

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

Deprecated: Use RetrievalDealRecord.ProtoReflect.Descriptor instead.

func (*RetrievalDealRecord) GetAddr Uses

func (x *RetrievalDealRecord) GetAddr() string

func (*RetrievalDealRecord) GetDealInfo Uses

func (x *RetrievalDealRecord) GetDealInfo() *RetrievalDealInfo

func (*RetrievalDealRecord) GetTime Uses

func (x *RetrievalDealRecord) GetTime() int64

func (*RetrievalDealRecord) ProtoMessage Uses

func (*RetrievalDealRecord) ProtoMessage()

func (*RetrievalDealRecord) ProtoReflect Uses

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

func (*RetrievalDealRecord) Reset Uses

func (x *RetrievalDealRecord) Reset()

func (*RetrievalDealRecord) String Uses

func (x *RetrievalDealRecord) String() string

type SendFilRequest Uses

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 Uses

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

Deprecated: Use SendFilRequest.ProtoReflect.Descriptor instead.

func (*SendFilRequest) GetAmount Uses

func (x *SendFilRequest) GetAmount() int64

func (*SendFilRequest) GetFrom Uses

func (x *SendFilRequest) GetFrom() string

func (*SendFilRequest) GetTo Uses

func (x *SendFilRequest) GetTo() string

func (*SendFilRequest) ProtoMessage Uses

func (*SendFilRequest) ProtoMessage()

func (*SendFilRequest) ProtoReflect Uses

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

func (*SendFilRequest) Reset Uses

func (x *SendFilRequest) Reset()

func (*SendFilRequest) String Uses

func (x *SendFilRequest) String() string

type SendFilResponse Uses

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

func (*SendFilResponse) Descriptor Uses

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

Deprecated: Use SendFilResponse.ProtoReflect.Descriptor instead.

func (*SendFilResponse) ProtoMessage Uses

func (*SendFilResponse) ProtoMessage()

func (*SendFilResponse) ProtoReflect Uses

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

func (*SendFilResponse) Reset Uses

func (x *SendFilResponse) Reset()

func (*SendFilResponse) String Uses

func (x *SendFilResponse) String() string

type SetDefaultStorageConfigRequest Uses

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

func (*SetDefaultStorageConfigRequest) Descriptor Uses

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

Deprecated: Use SetDefaultStorageConfigRequest.ProtoReflect.Descriptor instead.

func (*SetDefaultStorageConfigRequest) GetConfig Uses

func (x *SetDefaultStorageConfigRequest) GetConfig() *StorageConfig

func (*SetDefaultStorageConfigRequest) ProtoMessage Uses

func (*SetDefaultStorageConfigRequest) ProtoMessage()

func (*SetDefaultStorageConfigRequest) ProtoReflect Uses

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

func (*SetDefaultStorageConfigRequest) Reset Uses

func (x *SetDefaultStorageConfigRequest) Reset()

func (*SetDefaultStorageConfigRequest) String Uses

func (x *SetDefaultStorageConfigRequest) String() string

type SetDefaultStorageConfigResponse Uses

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

func (*SetDefaultStorageConfigResponse) Descriptor Uses

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

Deprecated: Use SetDefaultStorageConfigResponse.ProtoReflect.Descriptor instead.

func (*SetDefaultStorageConfigResponse) ProtoMessage Uses

func (*SetDefaultStorageConfigResponse) ProtoMessage()

func (*SetDefaultStorageConfigResponse) ProtoReflect Uses

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

func (*SetDefaultStorageConfigResponse) Reset Uses

func (x *SetDefaultStorageConfigResponse) Reset()

func (*SetDefaultStorageConfigResponse) String Uses

func (x *SetDefaultStorageConfigResponse) String() string

type ShowAllRequest Uses

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

func (*ShowAllRequest) Descriptor Uses

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

Deprecated: Use ShowAllRequest.ProtoReflect.Descriptor instead.

func (*ShowAllRequest) ProtoMessage Uses

func (*ShowAllRequest) ProtoMessage()

func (*ShowAllRequest) ProtoReflect Uses

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

func (*ShowAllRequest) Reset Uses

func (x *ShowAllRequest) Reset()

func (*ShowAllRequest) String Uses

func (x *ShowAllRequest) String() string

type ShowAllResponse Uses

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 Uses

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

Deprecated: Use ShowAllResponse.ProtoReflect.Descriptor instead.

func (*ShowAllResponse) GetCidInfos Uses

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

func (*ShowAllResponse) ProtoMessage Uses

func (*ShowAllResponse) ProtoMessage()

func (*ShowAllResponse) ProtoReflect Uses

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

func (*ShowAllResponse) Reset Uses

func (x *ShowAllResponse) Reset()

func (*ShowAllResponse) String Uses

func (x *ShowAllResponse) String() string

type ShowRequest Uses

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

func (*ShowRequest) Descriptor Uses

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

Deprecated: Use ShowRequest.ProtoReflect.Descriptor instead.

func (*ShowRequest) GetCid Uses

func (x *ShowRequest) GetCid() string

func (*ShowRequest) ProtoMessage Uses

func (*ShowRequest) ProtoMessage()

func (*ShowRequest) ProtoReflect Uses

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

func (*ShowRequest) Reset Uses

func (x *ShowRequest) Reset()

func (*ShowRequest) String Uses

func (x *ShowRequest) String() string

type ShowResponse Uses

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 Uses

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

Deprecated: Use ShowResponse.ProtoReflect.Descriptor instead.

func (*ShowResponse) GetCidInfo Uses

func (x *ShowResponse) GetCidInfo() *CidInfo

func (*ShowResponse) ProtoMessage Uses

func (*ShowResponse) ProtoMessage()

func (*ShowResponse) ProtoReflect Uses

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

func (*ShowResponse) Reset Uses

func (x *ShowResponse) Reset()

func (*ShowResponse) String Uses

func (x *ShowResponse) String() string

type StageRequest Uses

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

func (*StageRequest) Descriptor Uses

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

Deprecated: Use StageRequest.ProtoReflect.Descriptor instead.

func (*StageRequest) GetChunk Uses

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

func (*StageRequest) ProtoMessage Uses

func (*StageRequest) ProtoMessage()

func (*StageRequest) ProtoReflect Uses

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

func (*StageRequest) Reset Uses

func (x *StageRequest) Reset()

func (*StageRequest) String Uses

func (x *StageRequest) String() string

type StageResponse Uses

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

func (*StageResponse) Descriptor Uses

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

Deprecated: Use StageResponse.ProtoReflect.Descriptor instead.

func (*StageResponse) GetCid Uses

func (x *StageResponse) GetCid() string

func (*StageResponse) ProtoMessage Uses

func (*StageResponse) ProtoMessage()

func (*StageResponse) ProtoReflect Uses

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

func (*StageResponse) Reset Uses

func (x *StageResponse) Reset()

func (*StageResponse) String Uses

func (x *StageResponse) String() string

type StorageConfig Uses

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 Uses

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

Deprecated: Use StorageConfig.ProtoReflect.Descriptor instead.

func (*StorageConfig) GetCold Uses

func (x *StorageConfig) GetCold() *ColdConfig

func (*StorageConfig) GetHot Uses

func (x *StorageConfig) GetHot() *HotConfig

func (*StorageConfig) GetRepairable Uses

func (x *StorageConfig) GetRepairable() bool

func (*StorageConfig) ProtoMessage Uses

func (*StorageConfig) ProtoMessage()

func (*StorageConfig) ProtoReflect Uses

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

func (*StorageConfig) Reset Uses

func (x *StorageConfig) Reset()

func (*StorageConfig) String Uses

func (x *StorageConfig) String() string

type StorageDealInfo Uses

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 Uses

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

Deprecated: Use StorageDealInfo.ProtoReflect.Descriptor instead.

func (*StorageDealInfo) GetActivationEpoch Uses

func (x *StorageDealInfo) GetActivationEpoch() int64

func (*StorageDealInfo) GetDealId Uses

func (x *StorageDealInfo) GetDealId() uint64

func (*StorageDealInfo) GetDuration Uses

func (x *StorageDealInfo) GetDuration() uint64

func (*StorageDealInfo) GetMiner Uses

func (x *StorageDealInfo) GetMiner() string

func (*StorageDealInfo) GetMsg Uses

func (x *StorageDealInfo) GetMsg() string

func (*StorageDealInfo) GetPieceCid Uses

func (x *StorageDealInfo) GetPieceCid() string

func (*StorageDealInfo) GetPricePerEpoch Uses

func (x *StorageDealInfo) GetPricePerEpoch() uint64

func (*StorageDealInfo) GetProposalCid Uses

func (x *StorageDealInfo) GetProposalCid() string

func (*StorageDealInfo) GetSize Uses

func (x *StorageDealInfo) GetSize() uint64

func (*StorageDealInfo) GetStartEpoch Uses

func (x *StorageDealInfo) GetStartEpoch() uint64

func (*StorageDealInfo) GetStateId Uses

func (x *StorageDealInfo) GetStateId() uint64

func (*StorageDealInfo) GetStateName Uses

func (x *StorageDealInfo) GetStateName() string

func (*StorageDealInfo) ProtoMessage Uses

func (*StorageDealInfo) ProtoMessage()

func (*StorageDealInfo) ProtoReflect Uses

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

func (*StorageDealInfo) Reset Uses

func (x *StorageDealInfo) Reset()

func (*StorageDealInfo) String Uses

func (x *StorageDealInfo) String() string

type StorageDealRecord Uses

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 Uses

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

Deprecated: Use StorageDealRecord.ProtoReflect.Descriptor instead.

func (*StorageDealRecord) GetAddr Uses

func (x *StorageDealRecord) GetAddr() string

func (*StorageDealRecord) GetDealInfo Uses

func (x *StorageDealRecord) GetDealInfo() *StorageDealInfo

func (*StorageDealRecord) GetPending Uses

func (x *StorageDealRecord) GetPending() bool

func (*StorageDealRecord) GetRootCid Uses

func (x *StorageDealRecord) GetRootCid() string

func (*StorageDealRecord) GetTime Uses

func (x *StorageDealRecord) GetTime() int64

func (*StorageDealRecord) ProtoMessage Uses

func (*StorageDealRecord) ProtoMessage()

func (*StorageDealRecord) ProtoReflect Uses

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

func (*StorageDealRecord) Reset Uses

func (x *StorageDealRecord) Reset()

func (*StorageDealRecord) String Uses

func (x *StorageDealRecord) String() string

type UnimplementedRPCServiceServer Uses

type UnimplementedRPCServiceServer struct {
}

UnimplementedRPCServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRPCServiceServer) Addrs Uses

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

func (*UnimplementedRPCServiceServer) CancelJob Uses

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

func (*UnimplementedRPCServiceServer) Create Uses

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

func (*UnimplementedRPCServiceServer) CreatePayChannel Uses

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

func (*UnimplementedRPCServiceServer) DefaultStorageConfig Uses

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

func (*UnimplementedRPCServiceServer) Get Uses

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

func (*UnimplementedRPCServiceServer) GetStorageConfig Uses

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

func (*UnimplementedRPCServiceServer) GetStorageJob Uses

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

func (*UnimplementedRPCServiceServer) ID Uses

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

func (*UnimplementedRPCServiceServer) Info Uses

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

func (*UnimplementedRPCServiceServer) ListAPI Uses

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

func (*UnimplementedRPCServiceServer) ListPayChannels Uses

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

func (*UnimplementedRPCServiceServer) ListRetrievalDealRecords Uses

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

func (*UnimplementedRPCServiceServer) ListStorageDealRecords Uses

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

func (*UnimplementedRPCServiceServer) NewAddr Uses

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

func (*UnimplementedRPCServiceServer) PushStorageConfig Uses

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

func (*UnimplementedRPCServiceServer) RedeemPayChannel Uses

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

func (*UnimplementedRPCServiceServer) Remove Uses

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

func (*UnimplementedRPCServiceServer) Replace Uses

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

func (*UnimplementedRPCServiceServer) SendFil Uses

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

func (*UnimplementedRPCServiceServer) SetDefaultStorageConfig Uses

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

func (*UnimplementedRPCServiceServer) Show Uses

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

func (*UnimplementedRPCServiceServer) ShowAll Uses

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

func (*UnimplementedRPCServiceServer) Stage Uses

func (*UnimplementedRPCServiceServer) Stage(RPCService_StageServer) error

func (*UnimplementedRPCServiceServer) WatchJobs Uses

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

func (*UnimplementedRPCServiceServer) WatchLogs Uses

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

type WatchJobsRequest Uses

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

func (*WatchJobsRequest) Descriptor Uses

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

Deprecated: Use WatchJobsRequest.ProtoReflect.Descriptor instead.

func (*WatchJobsRequest) GetJids Uses

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

func (*WatchJobsRequest) ProtoMessage Uses

func (*WatchJobsRequest) ProtoMessage()

func (*WatchJobsRequest) ProtoReflect Uses

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

func (*WatchJobsRequest) Reset Uses

func (x *WatchJobsRequest) Reset()

func (*WatchJobsRequest) String Uses

func (x *WatchJobsRequest) String() string

type WatchJobsResponse Uses

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

func (*WatchJobsResponse) Descriptor Uses

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

Deprecated: Use WatchJobsResponse.ProtoReflect.Descriptor instead.

func (*WatchJobsResponse) GetJob Uses

func (x *WatchJobsResponse) GetJob() *Job

func (*WatchJobsResponse) ProtoMessage Uses

func (*WatchJobsResponse) ProtoMessage()

func (*WatchJobsResponse) ProtoReflect Uses

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

func (*WatchJobsResponse) Reset Uses

func (x *WatchJobsResponse) Reset()

func (*WatchJobsResponse) String Uses

func (x *WatchJobsResponse) String() string

type WatchLogsRequest Uses

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 Uses

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

Deprecated: Use WatchLogsRequest.ProtoReflect.Descriptor instead.

func (*WatchLogsRequest) GetCid Uses

func (x *WatchLogsRequest) GetCid() string

func (*WatchLogsRequest) GetHistory Uses

func (x *WatchLogsRequest) GetHistory() bool

func (*WatchLogsRequest) GetJid Uses

func (x *WatchLogsRequest) GetJid() string

func (*WatchLogsRequest) ProtoMessage Uses

func (*WatchLogsRequest) ProtoMessage()

func (*WatchLogsRequest) ProtoReflect Uses

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

func (*WatchLogsRequest) Reset Uses

func (x *WatchLogsRequest) Reset()

func (*WatchLogsRequest) String Uses

func (x *WatchLogsRequest) String() string

type WatchLogsResponse Uses

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 Uses

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

Deprecated: Use WatchLogsResponse.ProtoReflect.Descriptor instead.

func (*WatchLogsResponse) GetLogEntry Uses

func (x *WatchLogsResponse) GetLogEntry() *LogEntry

func (*WatchLogsResponse) ProtoMessage Uses

func (*WatchLogsResponse) ProtoMessage()

func (*WatchLogsResponse) ProtoReflect Uses

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

func (*WatchLogsResponse) Reset Uses

func (x *WatchLogsResponse) Reset()

func (*WatchLogsResponse) String Uses

func (x *WatchLogsResponse) String() string

Package rpc imports 20 packages (graph) and is imported by 6 packages. Updated 2020-09-23. Refresh now. Tools for package owners.