rpc

package
v0.1.2-pre.2 Latest Latest
Warning

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

 Go to latest Published: Jul 17, 2020 License: MIT Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for JobStatus.

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

Enum value maps for Direction.

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

Functions

func RegisterRPCServiceServer 

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

Types

type AddToHotRequest 

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

func (*AddToHotRequest) Descriptor deprecated 

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

Deprecated: Use AddToHotRequest.ProtoReflect.Descriptor instead.

func (*AddToHotRequest) GetChunk 

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

func (*AddToHotRequest) ProtoMessage 

func (*AddToHotRequest) ProtoMessage()

func (*AddToHotRequest) ProtoReflect 

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

func (*AddToHotRequest) Reset 

func (x *AddToHotRequest) Reset()

func (*AddToHotRequest) String 

func (x *AddToHotRequest) String() string

type AddToHotResponse 

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

func (*AddToHotResponse) Descriptor deprecated 

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

Deprecated: Use AddToHotResponse.ProtoReflect.Descriptor instead.

func (*AddToHotResponse) GetCid 

func (x *AddToHotResponse) GetCid() string

func (*AddToHotResponse) ProtoMessage 

func (*AddToHotResponse) ProtoMessage()

func (*AddToHotResponse) ProtoReflect 

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

func (*AddToHotResponse) Reset 

func (x *AddToHotResponse) Reset()

func (*AddToHotResponse) String 

func (x *AddToHotResponse) String() string

type AddrInfo 

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

func (*AddrInfo) Descriptor deprecated 

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

Deprecated: Use AddrInfo.ProtoReflect.Descriptor instead.

func (*AddrInfo) GetAddr 

func (x *AddrInfo) GetAddr() string

func (*AddrInfo) GetName 

func (x *AddrInfo) GetName() string

func (*AddrInfo) GetType 

func (x *AddrInfo) GetType() string

func (*AddrInfo) ProtoMessage 

func (*AddrInfo) ProtoMessage()

func (*AddrInfo) ProtoReflect 

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

func (*AddrInfo) Reset 

func (x *AddrInfo) Reset()

func (*AddrInfo) String 

func (x *AddrInfo) String() string

type AddrsRequest 

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

func (*AddrsRequest) Descriptor deprecated 

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

Deprecated: Use AddrsRequest.ProtoReflect.Descriptor instead.

func (*AddrsRequest) ProtoMessage 

func (*AddrsRequest) ProtoMessage()

func (*AddrsRequest) ProtoReflect 

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

func (*AddrsRequest) Reset 

func (x *AddrsRequest) Reset()

func (*AddrsRequest) String 

func (x *AddrsRequest) String() string

type AddrsResponse 

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

func (*AddrsResponse) Descriptor deprecated 

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

Deprecated: Use AddrsResponse.ProtoReflect.Descriptor instead.

func (*AddrsResponse) GetAddrs 

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

func (*AddrsResponse) ProtoMessage 

func (*AddrsResponse) ProtoMessage()

func (*AddrsResponse) ProtoReflect 

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

func (*AddrsResponse) Reset 

func (x *AddrsResponse) Reset()

func (*AddrsResponse) String 

func (x *AddrsResponse) String() string

type BalanceInfo 

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

func (*BalanceInfo) Descriptor deprecated 

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

Deprecated: Use BalanceInfo.ProtoReflect.Descriptor instead.

func (*BalanceInfo) GetAddr 

func (x *BalanceInfo) GetAddr() *AddrInfo

func (*BalanceInfo) GetBalance 

func (x *BalanceInfo) GetBalance() int64

func (*BalanceInfo) ProtoMessage 

func (*BalanceInfo) ProtoMessage()

func (*BalanceInfo) ProtoReflect 

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

func (*BalanceInfo) Reset 

func (x *BalanceInfo) Reset()

func (*BalanceInfo) String 

func (x *BalanceInfo) String() string

type CancelJobRequest 

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

func (*CancelJobRequest) Descriptor deprecated 

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

Deprecated: Use CancelJobRequest.ProtoReflect.Descriptor instead.

func (*CancelJobRequest) GetJid 

func (x *CancelJobRequest) GetJid() string

func (*CancelJobRequest) ProtoMessage 

func (*CancelJobRequest) ProtoMessage()

func (*CancelJobRequest) ProtoReflect 

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

func (*CancelJobRequest) Reset 

func (x *CancelJobRequest) Reset()

func (*CancelJobRequest) String 

func (x *CancelJobRequest) String() string

type CancelJobResponse 

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

func (*CancelJobResponse) Descriptor deprecated 

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

Deprecated: Use CancelJobResponse.ProtoReflect.Descriptor instead.

func (*CancelJobResponse) ProtoMessage 

func (*CancelJobResponse) ProtoMessage()

func (*CancelJobResponse) ProtoReflect 

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

func (*CancelJobResponse) Reset 

func (x *CancelJobResponse) Reset()

func (*CancelJobResponse) String 

func (x *CancelJobResponse) String() string

type CidConfig 

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

func (*CidConfig) Descriptor deprecated 

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

Deprecated: Use CidConfig.ProtoReflect.Descriptor instead.

func (*CidConfig) GetCid 

func (x *CidConfig) GetCid() string

func (*CidConfig) GetCold 

func (x *CidConfig) GetCold() *ColdConfig

func (*CidConfig) GetHot 

func (x *CidConfig) GetHot() *HotConfig

func (*CidConfig) GetRepairable 

func (x *CidConfig) GetRepairable() bool

func (*CidConfig) ProtoMessage 

func (*CidConfig) ProtoMessage()

func (*CidConfig) ProtoReflect 

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

func (*CidConfig) Reset 

func (x *CidConfig) Reset()

func (*CidConfig) String 

func (x *CidConfig) String() string

type CidInfo 

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

func (*CidInfo) Descriptor deprecated 

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

Deprecated: Use CidInfo.ProtoReflect.Descriptor instead.

func (*CidInfo) GetCid 

func (x *CidInfo) GetCid() string

func (*CidInfo) GetCold 

func (x *CidInfo) GetCold() *ColdInfo

func (*CidInfo) GetCreated 

func (x *CidInfo) GetCreated() int64

func (*CidInfo) GetHot 

func (x *CidInfo) GetHot() *HotInfo

func (*CidInfo) GetJobId 

func (x *CidInfo) GetJobId() string

func (*CidInfo) ProtoMessage 

func (*CidInfo) ProtoMessage()

func (*CidInfo) ProtoReflect 

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

func (*CidInfo) Reset 

func (x *CidInfo) Reset()

func (*CidInfo) String 

func (x *CidInfo) String() string

type CloseRequest 

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

func (*CloseRequest) Descriptor deprecated 

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

Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) ProtoReflect 

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

func (*CloseRequest) Reset 

func (x *CloseRequest) Reset()

func (*CloseRequest) String 

func (x *CloseRequest) String() string

type CloseResponse 

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

func (*CloseResponse) Descriptor deprecated 

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

Deprecated: Use CloseResponse.ProtoReflect.Descriptor instead.

func (*CloseResponse) ProtoMessage 

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) ProtoReflect 

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

func (*CloseResponse) Reset 

func (x *CloseResponse) Reset()

func (*CloseResponse) String 

func (x *CloseResponse) String() string

type ColdConfig 

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

func (*ColdConfig) Descriptor deprecated 

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

Deprecated: Use ColdConfig.ProtoReflect.Descriptor instead.

func (*ColdConfig) GetEnabled 

func (x *ColdConfig) GetEnabled() bool

func (*ColdConfig) GetFilecoin 

func (x *ColdConfig) GetFilecoin() *FilConfig

func (*ColdConfig) ProtoMessage 

func (*ColdConfig) ProtoMessage()

func (*ColdConfig) ProtoReflect 

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

func (*ColdConfig) Reset 

func (x *ColdConfig) Reset()

func (*ColdConfig) String 

func (x *ColdConfig) String() string

type ColdInfo 

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

func (*ColdInfo) Descriptor deprecated 

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

Deprecated: Use ColdInfo.ProtoReflect.Descriptor instead.

func (*ColdInfo) GetEnabled 

func (x *ColdInfo) GetEnabled() bool

func (*ColdInfo) GetFilecoin 

func (x *ColdInfo) GetFilecoin() *FilInfo

func (*ColdInfo) ProtoMessage 

func (*ColdInfo) ProtoMessage()

func (*ColdInfo) ProtoReflect 

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

func (*ColdInfo) Reset 

func (x *ColdInfo) Reset()

func (*ColdInfo) String 

func (x *ColdInfo) String() string

type CreatePayChannelRequest 

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

func (*CreatePayChannelRequest) Descriptor deprecated 

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

Deprecated: Use CreatePayChannelRequest.ProtoReflect.Descriptor instead.

func (*CreatePayChannelRequest) GetAmount 

func (x *CreatePayChannelRequest) GetAmount() uint64

func (*CreatePayChannelRequest) GetFrom 

func (x *CreatePayChannelRequest) GetFrom() string

func (*CreatePayChannelRequest) GetTo 

func (x *CreatePayChannelRequest) GetTo() string

func (*CreatePayChannelRequest) ProtoMessage 

func (*CreatePayChannelRequest) ProtoMessage()

func (*CreatePayChannelRequest) ProtoReflect 

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

func (*CreatePayChannelRequest) Reset 

func (x *CreatePayChannelRequest) Reset()

func (*CreatePayChannelRequest) String 

func (x *CreatePayChannelRequest) String() string

type CreatePayChannelResponse 

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

func (*CreatePayChannelResponse) Descriptor deprecated 

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

Deprecated: Use CreatePayChannelResponse.ProtoReflect.Descriptor instead.

func (*CreatePayChannelResponse) GetChannelMessageCid 

func (x *CreatePayChannelResponse) GetChannelMessageCid() string

func (*CreatePayChannelResponse) GetPayChannel 

func (x *CreatePayChannelResponse) GetPayChannel() *PaychInfo

func (*CreatePayChannelResponse) ProtoMessage 

func (*CreatePayChannelResponse) ProtoMessage()

func (*CreatePayChannelResponse) ProtoReflect 

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

func (*CreatePayChannelResponse) Reset 

func (x *CreatePayChannelResponse) Reset()

func (*CreatePayChannelResponse) String 

func (x *CreatePayChannelResponse) String() string

type CreateRequest 

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

func (*CreateRequest) Descriptor deprecated 

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

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect 

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

func (*CreateRequest) Reset 

func (x *CreateRequest) Reset()

func (*CreateRequest) String 

func (x *CreateRequest) String() string

type CreateResponse 

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

func (*CreateResponse) Descriptor deprecated 

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

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetId 

func (x *CreateResponse) GetId() string

func (*CreateResponse) GetToken 

func (x *CreateResponse) GetToken() string

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect 

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

func (*CreateResponse) Reset 

func (x *CreateResponse) Reset()

func (*CreateResponse) String 

func (x *CreateResponse) String() string

type DealError 

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

func (*DealError) Descriptor deprecated 

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

Deprecated: Use DealError.ProtoReflect.Descriptor instead.

func (*DealError) GetMessage 

func (x *DealError) GetMessage() string

func (*DealError) GetMiner 

func (x *DealError) GetMiner() string

func (*DealError) GetProposalCid 

func (x *DealError) GetProposalCid() string

func (*DealError) ProtoMessage 

func (*DealError) ProtoMessage()

func (*DealError) ProtoReflect 

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

func (*DealError) Reset 

func (x *DealError) Reset()

func (*DealError) String 

func (x *DealError) String() string

type DefaultConfig 

type DefaultConfig 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 (*DefaultConfig) Descriptor deprecated 

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

Deprecated: Use DefaultConfig.ProtoReflect.Descriptor instead.

func (*DefaultConfig) GetCold 

func (x *DefaultConfig) GetCold() *ColdConfig

func (*DefaultConfig) GetHot 

func (x *DefaultConfig) GetHot() *HotConfig

func (*DefaultConfig) GetRepairable 

func (x *DefaultConfig) GetRepairable() bool

func (*DefaultConfig) ProtoMessage 

func (*DefaultConfig) ProtoMessage()

func (*DefaultConfig) ProtoReflect 

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

func (*DefaultConfig) Reset 

func (x *DefaultConfig) Reset()

func (*DefaultConfig) String 

func (x *DefaultConfig) String() string

type DefaultConfigRequest 

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

func (*DefaultConfigRequest) Descriptor deprecated 

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

Deprecated: Use DefaultConfigRequest.ProtoReflect.Descriptor instead.

func (*DefaultConfigRequest) ProtoMessage 

func (*DefaultConfigRequest) ProtoMessage()

func (*DefaultConfigRequest) ProtoReflect 

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

func (*DefaultConfigRequest) Reset 

func (x *DefaultConfigRequest) Reset()

func (*DefaultConfigRequest) String 

func (x *DefaultConfigRequest) String() string

type DefaultConfigResponse 

type DefaultConfigResponse struct {
	DefaultConfig *DefaultConfig `protobuf:"bytes,1,opt,name=default_config,json=defaultConfig,proto3" json:"default_config,omitempty"`
	// contains filtered or unexported fields
}

func (*DefaultConfigResponse) Descriptor deprecated 

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

Deprecated: Use DefaultConfigResponse.ProtoReflect.Descriptor instead.

func (*DefaultConfigResponse) GetDefaultConfig 

func (x *DefaultConfigResponse) GetDefaultConfig() *DefaultConfig

func (*DefaultConfigResponse) ProtoMessage 

func (*DefaultConfigResponse) ProtoMessage()

func (*DefaultConfigResponse) ProtoReflect 

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

func (*DefaultConfigResponse) Reset 

func (x *DefaultConfigResponse) Reset()

func (*DefaultConfigResponse) String 

func (x *DefaultConfigResponse) String() string

type Direction 

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

func (Direction) Descriptor 

func (Direction) Descriptor() protoreflect.EnumDescriptor

func (Direction) Enum 

func (x Direction) Enum() *Direction

func (Direction) EnumDescriptor deprecated 

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

Deprecated: Use Direction.Descriptor instead.

func (Direction) Number 

func (x Direction) Number() protoreflect.EnumNumber

func (Direction) String 

func (x Direction) String() string

func (Direction) Type 

func (Direction) Type() protoreflect.EnumType

type FilConfig 

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

func (*FilConfig) Descriptor deprecated 

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

Deprecated: Use FilConfig.ProtoReflect.Descriptor instead.

func (*FilConfig) GetAddr 

func (x *FilConfig) GetAddr() string

func (*FilConfig) GetCountryCodes 

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

func (*FilConfig) GetDealMinDuration 

func (x *FilConfig) GetDealMinDuration() int64

func (*FilConfig) GetExcludedMiners 

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

func (*FilConfig) GetMaxPrice 

func (x *FilConfig) GetMaxPrice() uint64

func (*FilConfig) GetRenew 

func (x *FilConfig) GetRenew() *FilRenew

func (*FilConfig) GetRepFactor 

func (x *FilConfig) GetRepFactor() int64

func (*FilConfig) GetTrustedMiners 

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

func (*FilConfig) ProtoMessage 

func (*FilConfig) ProtoMessage()

func (*FilConfig) ProtoReflect 

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

func (*FilConfig) Reset 

func (x *FilConfig) Reset()

func (*FilConfig) String 

func (x *FilConfig) String() string

type FilInfo 

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

func (*FilInfo) Descriptor deprecated 

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

Deprecated: Use FilInfo.ProtoReflect.Descriptor instead.

func (*FilInfo) GetDataCid 

func (x *FilInfo) GetDataCid() string

func (*FilInfo) GetProposals 

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

func (*FilInfo) GetSize 

func (x *FilInfo) GetSize() uint64

func (*FilInfo) ProtoMessage 

func (*FilInfo) ProtoMessage()

func (*FilInfo) ProtoReflect 

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

func (*FilInfo) Reset 

func (x *FilInfo) Reset()

func (*FilInfo) String 

func (x *FilInfo) String() string

type FilRenew 

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

func (*FilRenew) Descriptor deprecated 

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

Deprecated: Use FilRenew.ProtoReflect.Descriptor instead.

func (*FilRenew) GetEnabled 

func (x *FilRenew) GetEnabled() bool

func (*FilRenew) GetThreshold 

func (x *FilRenew) GetThreshold() int64

func (*FilRenew) ProtoMessage 

func (*FilRenew) ProtoMessage()

func (*FilRenew) ProtoReflect 

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

func (*FilRenew) Reset 

func (x *FilRenew) Reset()

func (*FilRenew) String 

func (x *FilRenew) String() string

type FilStorage 

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

func (*FilStorage) Descriptor deprecated 

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

Deprecated: Use FilStorage.ProtoReflect.Descriptor instead.

func (*FilStorage) GetActivationEpoch 

func (x *FilStorage) GetActivationEpoch() int64

func (*FilStorage) GetDuration 

func (x *FilStorage) GetDuration() int64

func (*FilStorage) GetEpochPrice 

func (x *FilStorage) GetEpochPrice() uint64

func (*FilStorage) GetMiner 

func (x *FilStorage) GetMiner() string

func (*FilStorage) GetProposalCid 

func (x *FilStorage) GetProposalCid() string

func (*FilStorage) GetRenewed 

func (x *FilStorage) GetRenewed() bool

func (*FilStorage) GetStartEpoch 

func (x *FilStorage) GetStartEpoch() uint64

func (*FilStorage) ProtoMessage 

func (*FilStorage) ProtoMessage()

func (*FilStorage) ProtoReflect 

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

func (*FilStorage) Reset 

func (x *FilStorage) Reset()

func (*FilStorage) String 

func (x *FilStorage) String() string

type GetCidConfigRequest 

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

func (*GetCidConfigRequest) Descriptor deprecated 

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

Deprecated: Use GetCidConfigRequest.ProtoReflect.Descriptor instead.

func (*GetCidConfigRequest) GetCid 

func (x *GetCidConfigRequest) GetCid() string

func (*GetCidConfigRequest) ProtoMessage 

func (*GetCidConfigRequest) ProtoMessage()

func (*GetCidConfigRequest) ProtoReflect 

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

func (*GetCidConfigRequest) Reset 

func (x *GetCidConfigRequest) Reset()

func (*GetCidConfigRequest) String 

func (x *GetCidConfigRequest) String() string

type GetCidConfigResponse 

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

func (*GetCidConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetCidConfigResponse.ProtoReflect.Descriptor instead.

func (*GetCidConfigResponse) GetConfig 

func (x *GetCidConfigResponse) GetConfig() *CidConfig

func (*GetCidConfigResponse) ProtoMessage 

func (*GetCidConfigResponse) ProtoMessage()

func (*GetCidConfigResponse) ProtoReflect 

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

func (*GetCidConfigResponse) Reset 

func (x *GetCidConfigResponse) Reset()

func (*GetCidConfigResponse) String 

func (x *GetCidConfigResponse) String() string

type GetDefaultCidConfigRequest 

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

func (*GetDefaultCidConfigRequest) Descriptor deprecated 

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

Deprecated: Use GetDefaultCidConfigRequest.ProtoReflect.Descriptor instead.

func (*GetDefaultCidConfigRequest) GetCid 

func (x *GetDefaultCidConfigRequest) GetCid() string

func (*GetDefaultCidConfigRequest) ProtoMessage 

func (*GetDefaultCidConfigRequest) ProtoMessage()

func (*GetDefaultCidConfigRequest) ProtoReflect 

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

func (*GetDefaultCidConfigRequest) Reset 

func (x *GetDefaultCidConfigRequest) Reset()

func (*GetDefaultCidConfigRequest) String 

func (x *GetDefaultCidConfigRequest) String() string

type GetDefaultCidConfigResponse 

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

func (*GetDefaultCidConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetDefaultCidConfigResponse.ProtoReflect.Descriptor instead.

func (*GetDefaultCidConfigResponse) GetConfig 

func (x *GetDefaultCidConfigResponse) GetConfig() *CidConfig

func (*GetDefaultCidConfigResponse) ProtoMessage 

func (*GetDefaultCidConfigResponse) ProtoMessage()

func (*GetDefaultCidConfigResponse) ProtoReflect 

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

func (*GetDefaultCidConfigResponse) Reset 

func (x *GetDefaultCidConfigResponse) Reset()

func (*GetDefaultCidConfigResponse) String 

func (x *GetDefaultCidConfigResponse) String() string

type GetRequest 

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

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetCid 

func (x *GetRequest) GetCid() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

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

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetChunk 

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

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type HotConfig 

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

func (*HotConfig) Descriptor deprecated 

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

Deprecated: Use HotConfig.ProtoReflect.Descriptor instead.

func (*HotConfig) GetAllowUnfreeze 

func (x *HotConfig) GetAllowUnfreeze() bool

func (*HotConfig) GetEnabled 

func (x *HotConfig) GetEnabled() bool

func (*HotConfig) GetIpfs 

func (x *HotConfig) GetIpfs() *IpfsConfig

func (*HotConfig) ProtoMessage 

func (*HotConfig) ProtoMessage()

func (*HotConfig) ProtoReflect 

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

func (*HotConfig) Reset 

func (x *HotConfig) Reset()

func (*HotConfig) String 

func (x *HotConfig) String() string

type HotInfo 

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

func (*HotInfo) Descriptor deprecated 

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

Deprecated: Use HotInfo.ProtoReflect.Descriptor instead.

func (*HotInfo) GetEnabled 

func (x *HotInfo) GetEnabled() bool

func (*HotInfo) GetIpfs 

func (x *HotInfo) GetIpfs() *IpfsHotInfo

func (*HotInfo) GetSize 

func (x *HotInfo) GetSize() int64

func (*HotInfo) ProtoMessage 

func (*HotInfo) ProtoMessage()

func (*HotInfo) ProtoReflect 

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

func (*HotInfo) Reset 

func (x *HotInfo) Reset()

func (*HotInfo) String 

func (x *HotInfo) String() string

type IDRequest 

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

func (*IDRequest) Descriptor deprecated 

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

Deprecated: Use IDRequest.ProtoReflect.Descriptor instead.

func (*IDRequest) ProtoMessage 

func (*IDRequest) ProtoMessage()

func (*IDRequest) ProtoReflect 

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

func (*IDRequest) Reset 

func (x *IDRequest) Reset()

func (*IDRequest) String 

func (x *IDRequest) String() string

type IDResponse 

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

func (*IDResponse) Descriptor deprecated 

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

Deprecated: Use IDResponse.ProtoReflect.Descriptor instead.

func (*IDResponse) GetId 

func (x *IDResponse) GetId() string

func (*IDResponse) ProtoMessage 

func (*IDResponse) ProtoMessage()

func (*IDResponse) ProtoReflect 

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

func (*IDResponse) Reset 

func (x *IDResponse) Reset()

func (*IDResponse) String 

func (x *IDResponse) String() string

type InfoRequest 

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

func (*InfoRequest) Descriptor deprecated 

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

Deprecated: Use InfoRequest.ProtoReflect.Descriptor instead.

func (*InfoRequest) ProtoMessage 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) ProtoReflect 

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

func (*InfoRequest) Reset 

func (x *InfoRequest) Reset()

func (*InfoRequest) String 

func (x *InfoRequest) String() string

type InfoResponse 

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

func (*InfoResponse) Descriptor deprecated 

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

Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.

func (*InfoResponse) GetInfo 

func (x *InfoResponse) GetInfo() *InstanceInfo

func (*InfoResponse) ProtoMessage 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) ProtoReflect 

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

func (*InfoResponse) Reset 

func (x *InfoResponse) Reset()

func (*InfoResponse) String 

func (x *InfoResponse) String() string

type InstanceInfo 

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

func (*InstanceInfo) Descriptor deprecated 

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

Deprecated: Use InstanceInfo.ProtoReflect.Descriptor instead.

func (*InstanceInfo) GetBalances 

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

func (*InstanceInfo) GetDefaultConfig 

func (x *InstanceInfo) GetDefaultConfig() *DefaultConfig

func (*InstanceInfo) GetId 

func (x *InstanceInfo) GetId() string

func (*InstanceInfo) GetPins 

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

func (*InstanceInfo) ProtoMessage 

func (*InstanceInfo) ProtoMessage()

func (*InstanceInfo) ProtoReflect 

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

func (*InstanceInfo) Reset 

func (x *InstanceInfo) Reset()

func (*InstanceInfo) String 

func (x *InstanceInfo) String() string

type IpfsConfig 

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

func (*IpfsConfig) Descriptor deprecated 

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

Deprecated: Use IpfsConfig.ProtoReflect.Descriptor instead.

func (*IpfsConfig) GetAddTimeout 

func (x *IpfsConfig) GetAddTimeout() int64

func (*IpfsConfig) ProtoMessage 

func (*IpfsConfig) ProtoMessage()

func (*IpfsConfig) ProtoReflect 

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

func (*IpfsConfig) Reset 

func (x *IpfsConfig) Reset()

func (*IpfsConfig) String 

func (x *IpfsConfig) String() string

type IpfsHotInfo 

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

func (*IpfsHotInfo) Descriptor deprecated 

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

Deprecated: Use IpfsHotInfo.ProtoReflect.Descriptor instead.

func (*IpfsHotInfo) GetCreated 

func (x *IpfsHotInfo) GetCreated() int64

func (*IpfsHotInfo) ProtoMessage 

func (*IpfsHotInfo) ProtoMessage()

func (*IpfsHotInfo) ProtoReflect 

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

func (*IpfsHotInfo) Reset 

func (x *IpfsHotInfo) Reset()

func (*IpfsHotInfo) String 

func (x *IpfsHotInfo) String() string

type Job 

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

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetApiId 

func (x *Job) GetApiId() string

func (*Job) GetCid 

func (x *Job) GetCid() string

func (*Job) GetDealErrors 

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

func (*Job) GetErrCause 

func (x *Job) GetErrCause() string

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetStatus 

func (x *Job) GetStatus() JobStatus

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type JobStatus 

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

func (JobStatus) Descriptor 

func (JobStatus) Descriptor() protoreflect.EnumDescriptor

func (JobStatus) Enum 

func (x JobStatus) Enum() *JobStatus

func (JobStatus) EnumDescriptor deprecated 

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

Deprecated: Use JobStatus.Descriptor instead.

func (JobStatus) Number 

func (x JobStatus) Number() protoreflect.EnumNumber

func (JobStatus) String 

func (x JobStatus) String() string

func (JobStatus) Type 

func (JobStatus) Type() protoreflect.EnumType

type ListAPIRequest 

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

func (*ListAPIRequest) Descriptor deprecated 

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

Deprecated: Use ListAPIRequest.ProtoReflect.Descriptor instead.

func (*ListAPIRequest) ProtoMessage 

func (*ListAPIRequest) ProtoMessage()

func (*ListAPIRequest) ProtoReflect 

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

func (*ListAPIRequest) Reset 

func (x *ListAPIRequest) Reset()

func (*ListAPIRequest) String 

func (x *ListAPIRequest) String() string

type ListAPIResponse 

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

func (*ListAPIResponse) Descriptor deprecated 

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

Deprecated: Use ListAPIResponse.ProtoReflect.Descriptor instead.

func (*ListAPIResponse) GetInstances 

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

func (*ListAPIResponse) ProtoMessage 

func (*ListAPIResponse) ProtoMessage()

func (*ListAPIResponse) ProtoReflect 

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

func (*ListAPIResponse) Reset 

func (x *ListAPIResponse) Reset()

func (*ListAPIResponse) String 

func (x *ListAPIResponse) String() string

type ListDealRecordsConfig added in v0.1.1 

type ListDealRecordsConfig struct {
	FromAddrs      []string `protobuf:"bytes,1,rep,name=from_addrs,json=fromAddrs,proto3" json:"from_addrs,omitempty"`
	DataCids       []string `protobuf:"bytes,2,rep,name=data_cids,json=dataCids,proto3" json:"data_cids,omitempty"`
	IncludePending bool     `protobuf:"varint,3,opt,name=include_pending,json=includePending,proto3" json:"include_pending,omitempty"`
	IncludeFinal   bool     `protobuf:"varint,4,opt,name=include_final,json=includeFinal,proto3" json:"include_final,omitempty"`
	Ascending      bool     `protobuf:"varint,5,opt,name=ascending,proto3" json:"ascending,omitempty"`
	// contains filtered or unexported fields
}

func (*ListDealRecordsConfig) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use ListDealRecordsConfig.ProtoReflect.Descriptor instead.

func (*ListDealRecordsConfig) GetAscending added in v0.1.1 

func (x *ListDealRecordsConfig) GetAscending() bool

func (*ListDealRecordsConfig) GetDataCids added in v0.1.1 

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

func (*ListDealRecordsConfig) GetFromAddrs added in v0.1.1 

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

func (*ListDealRecordsConfig) GetIncludeFinal added in v0.1.1 

func (x *ListDealRecordsConfig) GetIncludeFinal() bool

func (*ListDealRecordsConfig) GetIncludePending added in v0.1.1 

func (x *ListDealRecordsConfig) GetIncludePending() bool

func (*ListDealRecordsConfig) ProtoMessage added in v0.1.1 

func (*ListDealRecordsConfig) ProtoMessage()

func (*ListDealRecordsConfig) ProtoReflect added in v0.1.1 

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

func (*ListDealRecordsConfig) Reset added in v0.1.1 

func (x *ListDealRecordsConfig) Reset()

func (*ListDealRecordsConfig) String added in v0.1.1 

func (x *ListDealRecordsConfig) String() string

type ListPayChannelsRequest 

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

func (*ListPayChannelsRequest) Descriptor deprecated 

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

Deprecated: Use ListPayChannelsRequest.ProtoReflect.Descriptor instead.

func (*ListPayChannelsRequest) ProtoMessage 

func (*ListPayChannelsRequest) ProtoMessage()

func (*ListPayChannelsRequest) ProtoReflect 

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

func (*ListPayChannelsRequest) Reset 

func (x *ListPayChannelsRequest) Reset()

func (*ListPayChannelsRequest) String 

func (x *ListPayChannelsRequest) String() string

type ListPayChannelsResponse 

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

func (*ListPayChannelsResponse) Descriptor deprecated 

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

Deprecated: Use ListPayChannelsResponse.ProtoReflect.Descriptor instead.

func (*ListPayChannelsResponse) GetPayChannels 

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

func (*ListPayChannelsResponse) ProtoMessage 

func (*ListPayChannelsResponse) ProtoMessage()

func (*ListPayChannelsResponse) ProtoReflect 

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

func (*ListPayChannelsResponse) Reset 

func (x *ListPayChannelsResponse) Reset()

func (*ListPayChannelsResponse) String 

func (x *ListPayChannelsResponse) String() string

type ListRetrievalDealRecordsRequest 

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

func (*ListRetrievalDealRecordsRequest) Descriptor deprecated 

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

Deprecated: Use ListRetrievalDealRecordsRequest.ProtoReflect.Descriptor instead.

func (*ListRetrievalDealRecordsRequest) GetConfig 

func (x *ListRetrievalDealRecordsRequest) GetConfig() *ListDealRecordsConfig

func (*ListRetrievalDealRecordsRequest) ProtoMessage 

func (*ListRetrievalDealRecordsRequest) ProtoMessage()

func (*ListRetrievalDealRecordsRequest) ProtoReflect 

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

func (*ListRetrievalDealRecordsRequest) Reset 

func (x *ListRetrievalDealRecordsRequest) Reset()

func (*ListRetrievalDealRecordsRequest) String 

func (x *ListRetrievalDealRecordsRequest) String() string

type ListRetrievalDealRecordsResponse 

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

func (*ListRetrievalDealRecordsResponse) Descriptor deprecated 

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

Deprecated: Use ListRetrievalDealRecordsResponse.ProtoReflect.Descriptor instead.

func (*ListRetrievalDealRecordsResponse) GetRecords 

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

func (*ListRetrievalDealRecordsResponse) ProtoMessage 

func (*ListRetrievalDealRecordsResponse) ProtoMessage()

func (*ListRetrievalDealRecordsResponse) ProtoReflect 

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

func (*ListRetrievalDealRecordsResponse) Reset 

func (x *ListRetrievalDealRecordsResponse) Reset()

func (*ListRetrievalDealRecordsResponse) String 

func (x *ListRetrievalDealRecordsResponse) String() string

type ListStorageDealRecordsRequest 

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

func (*ListStorageDealRecordsRequest) Descriptor deprecated 

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

Deprecated: Use ListStorageDealRecordsRequest.ProtoReflect.Descriptor instead.

func (*ListStorageDealRecordsRequest) GetConfig 

func (x *ListStorageDealRecordsRequest) GetConfig() *ListDealRecordsConfig

func (*ListStorageDealRecordsRequest) ProtoMessage 

func (*ListStorageDealRecordsRequest) ProtoMessage()

func (*ListStorageDealRecordsRequest) ProtoReflect 

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

func (*ListStorageDealRecordsRequest) Reset 

func (x *ListStorageDealRecordsRequest) Reset()

func (*ListStorageDealRecordsRequest) String 

func (x *ListStorageDealRecordsRequest) String() string

type ListStorageDealRecordsResponse 

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

func (*ListStorageDealRecordsResponse) Descriptor deprecated 

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

Deprecated: Use ListStorageDealRecordsResponse.ProtoReflect.Descriptor instead.

func (*ListStorageDealRecordsResponse) GetRecords 

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

func (*ListStorageDealRecordsResponse) ProtoMessage 

func (*ListStorageDealRecordsResponse) ProtoMessage()

func (*ListStorageDealRecordsResponse) ProtoReflect 

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

func (*ListStorageDealRecordsResponse) Reset 

func (x *ListStorageDealRecordsResponse) Reset()

func (*ListStorageDealRecordsResponse) String 

func (x *ListStorageDealRecordsResponse) String() string

type LogEntry 

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

func (*LogEntry) Descriptor deprecated 

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetCid 

func (x *LogEntry) GetCid() string

func (*LogEntry) GetJid 

func (x *LogEntry) GetJid() string

func (*LogEntry) GetMsg 

func (x *LogEntry) GetMsg() string

func (*LogEntry) GetTime 

func (x *LogEntry) GetTime() int64

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect 

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

func (*LogEntry) Reset 

func (x *LogEntry) Reset()

func (*LogEntry) String 

func (x *LogEntry) String() string

type NewAddrRequest 

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

func (*NewAddrRequest) Descriptor deprecated 

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

Deprecated: Use NewAddrRequest.ProtoReflect.Descriptor instead.

func (*NewAddrRequest) GetAddressType 

func (x *NewAddrRequest) GetAddressType() string

func (*NewAddrRequest) GetMakeDefault 

func (x *NewAddrRequest) GetMakeDefault() bool

func (*NewAddrRequest) GetName 

func (x *NewAddrRequest) GetName() string

func (*NewAddrRequest) ProtoMessage 

func (*NewAddrRequest) ProtoMessage()

func (*NewAddrRequest) ProtoReflect 

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

func (*NewAddrRequest) Reset 

func (x *NewAddrRequest) Reset()

func (*NewAddrRequest) String 

func (x *NewAddrRequest) String() string

type NewAddrResponse 

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

func (*NewAddrResponse) Descriptor deprecated 

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

Deprecated: Use NewAddrResponse.ProtoReflect.Descriptor instead.

func (*NewAddrResponse) GetAddr 

func (x *NewAddrResponse) GetAddr() string

func (*NewAddrResponse) ProtoMessage 

func (*NewAddrResponse) ProtoMessage()

func (*NewAddrResponse) ProtoReflect 

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

func (*NewAddrResponse) Reset 

func (x *NewAddrResponse) Reset()

func (*NewAddrResponse) String 

func (x *NewAddrResponse) String() string

type PaychInfo 

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

func (*PaychInfo) Descriptor deprecated 

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

Deprecated: Use PaychInfo.ProtoReflect.Descriptor instead.

func (*PaychInfo) GetAddr 

func (x *PaychInfo) GetAddr() string

func (*PaychInfo) GetCtlAddr 

func (x *PaychInfo) GetCtlAddr() string

func (*PaychInfo) GetDirection 

func (x *PaychInfo) GetDirection() Direction

func (*PaychInfo) ProtoMessage 

func (*PaychInfo) ProtoMessage()

func (*PaychInfo) ProtoReflect 

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

func (*PaychInfo) Reset 

func (x *PaychInfo) Reset()

func (*PaychInfo) String 

func (x *PaychInfo) String() string

type PushConfigRequest 

type PushConfigRequest struct {
	Cid               string     `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Config            *CidConfig `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 (*PushConfigRequest) Descriptor deprecated 

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

Deprecated: Use PushConfigRequest.ProtoReflect.Descriptor instead.

func (*PushConfigRequest) GetCid 

func (x *PushConfigRequest) GetCid() string

func (*PushConfigRequest) GetConfig 

func (x *PushConfigRequest) GetConfig() *CidConfig

func (*PushConfigRequest) GetHasConfig 

func (x *PushConfigRequest) GetHasConfig() bool

func (*PushConfigRequest) GetHasOverrideConfig 

func (x *PushConfigRequest) GetHasOverrideConfig() bool

func (*PushConfigRequest) GetOverrideConfig 

func (x *PushConfigRequest) GetOverrideConfig() bool

func (*PushConfigRequest) ProtoMessage 

func (*PushConfigRequest) ProtoMessage()

func (*PushConfigRequest) ProtoReflect 

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

func (*PushConfigRequest) Reset 

func (x *PushConfigRequest) Reset()

func (*PushConfigRequest) String 

func (x *PushConfigRequest) String() string

type PushConfigResponse 

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

func (*PushConfigResponse) Descriptor deprecated 

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

Deprecated: Use PushConfigResponse.ProtoReflect.Descriptor instead.

func (*PushConfigResponse) GetJobId 

func (x *PushConfigResponse) GetJobId() string

func (*PushConfigResponse) ProtoMessage 

func (*PushConfigResponse) ProtoMessage()

func (*PushConfigResponse) ProtoReflect 

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

func (*PushConfigResponse) Reset 

func (x *PushConfigResponse) Reset()

func (*PushConfigResponse) String 

func (x *PushConfigResponse) String() string

type RPC 

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

RPC implements the proto service definition of FFS.

func New 

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

New creates a new rpc service.

func (*RPC) AddToHot 

func (s *RPC) AddToHot(srv RPCService_AddToHotServer) error

AddToHot stores data in the Hot Storage so the resulting cid can be used in PushConfig.

func (*RPC) Addrs 

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

Addrs calls ffs.Addrs.

func (*RPC) CancelJob 

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

CancelJob calls API.CancelJob.

func (*RPC) Close 

func (s *RPC) Close(ctx context.Context, req *CloseRequest) (*CloseResponse, error)

Close calls API.Close.

func (*RPC) Create 

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

Create creates a new Api.

func (*RPC) CreatePayChannel 

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

CreatePayChannel creates a payment channel.

func (*RPC) DefaultConfig 

func (s *RPC) DefaultConfig(ctx context.Context, req *DefaultConfigRequest) (*DefaultConfigResponse, error)

DefaultConfig calls ffs.DefaultConfig.

func (*RPC) Get 

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

Get gets the data for a stored Cid.

func (*RPC) GetCidConfig 

func (s *RPC) GetCidConfig(ctx context.Context, req *GetCidConfigRequest) (*GetCidConfigResponse, error)

GetCidConfig returns the cid config for the provided cid.

func (*RPC) GetDefaultCidConfig 

func (s *RPC) GetDefaultCidConfig(ctx context.Context, req *GetDefaultCidConfigRequest) (*GetDefaultCidConfigResponse, error)

GetDefaultCidConfig returns the default cid config prepped for the provided cid.

func (*RPC) ID 

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

ID returns the API instance id.

func (*RPC) Info 

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

Info returns an Api information.

func (*RPC) ListAPI 

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

ListAPI returns a list of all existing API instances.

func (*RPC) ListPayChannels 

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

ListPayChannels lists all pay channels.

func (*RPC) ListRetrievalDealRecords 

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

ListRetrievalDealRecords calls ffs.ListRetrievalDealRecords.

func (*RPC) ListStorageDealRecords 

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

ListStorageDealRecords calls ffs.ListStorageDealRecords.

func (*RPC) NewAddr 

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

NewAddr calls ffs.NewAddr.

func (*RPC) PushConfig 

func (s *RPC) PushConfig(ctx context.Context, req *PushConfigRequest) (*PushConfigResponse, error)

PushConfig applies the provided cid config.

func (*RPC) RedeemPayChannel 

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

RedeemPayChannel redeems a payment channel.

func (*RPC) Remove 

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

Remove calls ffs.Remove.

func (*RPC) Replace 

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

Replace calls ffs.Replace.

func (*RPC) SendFil 

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

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

func (*RPC) SetDefaultConfig 

func (s *RPC) SetDefaultConfig(ctx context.Context, req *SetDefaultConfigRequest) (*SetDefaultConfigResponse, error)

SetDefaultConfig sets a new config to be used by default.

func (*RPC) Show 

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

Show returns information about a particular Cid.

func (*RPC) ShowAll 

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

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

func (*RPC) WatchJobs 

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

WatchJobs calls API.WatchJobs.

func (*RPC) WatchLogs 

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

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

type RPCServiceClient 

type RPCServiceClient interface {
	// Admin
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	ListAPI(ctx context.Context, in *ListAPIRequest, opts ...grpc.CallOption) (*ListAPIResponse, error)
	// Instance
	ID(ctx context.Context, in *IDRequest, opts ...grpc.CallOption) (*IDResponse, error)
	Addrs(ctx context.Context, in *AddrsRequest, opts ...grpc.CallOption) (*AddrsResponse, error)
	DefaultConfig(ctx context.Context, in *DefaultConfigRequest, opts ...grpc.CallOption) (*DefaultConfigResponse, error)
	NewAddr(ctx context.Context, in *NewAddrRequest, opts ...grpc.CallOption) (*NewAddrResponse, error)
	GetDefaultCidConfig(ctx context.Context, in *GetDefaultCidConfigRequest, opts ...grpc.CallOption) (*GetDefaultCidConfigResponse, error)
	GetCidConfig(ctx context.Context, in *GetCidConfigRequest, opts ...grpc.CallOption) (*GetCidConfigResponse, error)
	SetDefaultConfig(ctx context.Context, in *SetDefaultConfigRequest, opts ...grpc.CallOption) (*SetDefaultConfigResponse, 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)
	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)
	PushConfig(ctx context.Context, in *PushConfigRequest, opts ...grpc.CallOption) (*PushConfigResponse, 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)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
	AddToHot(ctx context.Context, opts ...grpc.CallOption) (RPCService_AddToHotClient, error)
	ListPayChannels(ctx context.Context, in *ListPayChannelsRequest, opts ...grpc.CallOption) (*ListPayChannelsResponse, error)
	CreatePayChannel(ctx context.Context, in *CreatePayChannelRequest, opts ...grpc.CallOption) (*CreatePayChannelResponse, error)
	RedeemPayChannel(ctx context.Context, in *RedeemPayChannelRequest, opts ...grpc.CallOption) (*RedeemPayChannelResponse, error)
	ListStorageDealRecords(ctx context.Context, in *ListStorageDealRecordsRequest, opts ...grpc.CallOption) (*ListStorageDealRecordsResponse, error)
	ListRetrievalDealRecords(ctx context.Context, in *ListRetrievalDealRecordsRequest, opts ...grpc.CallOption) (*ListRetrievalDealRecordsResponse, error)
	// UI support
	ShowAll(ctx context.Context, in *ShowAllRequest, opts ...grpc.CallOption) (*ShowAllResponse, error)
}

RPCServiceClient is the client API for RPCService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRPCServiceClient 

func NewRPCServiceClient(cc grpc.ClientConnInterface) RPCServiceClient

type RPCServiceServer 

type RPCServiceServer interface {
	// Admin
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	ListAPI(context.Context, *ListAPIRequest) (*ListAPIResponse, error)
	// Instance
	ID(context.Context, *IDRequest) (*IDResponse, error)
	Addrs(context.Context, *AddrsRequest) (*AddrsResponse, error)
	DefaultConfig(context.Context, *DefaultConfigRequest) (*DefaultConfigResponse, error)
	NewAddr(context.Context, *NewAddrRequest) (*NewAddrResponse, error)
	GetDefaultCidConfig(context.Context, *GetDefaultCidConfigRequest) (*GetDefaultCidConfigResponse, error)
	GetCidConfig(context.Context, *GetCidConfigRequest) (*GetCidConfigResponse, error)
	SetDefaultConfig(context.Context, *SetDefaultConfigRequest) (*SetDefaultConfigResponse, error)
	Show(context.Context, *ShowRequest) (*ShowResponse, error)
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)
	WatchJobs(*WatchJobsRequest, RPCService_WatchJobsServer) error
	WatchLogs(*WatchLogsRequest, RPCService_WatchLogsServer) error
	Replace(context.Context, *ReplaceRequest) (*ReplaceResponse, error)
	PushConfig(context.Context, *PushConfigRequest) (*PushConfigResponse, error)
	Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
	Get(*GetRequest, RPCService_GetServer) error
	SendFil(context.Context, *SendFilRequest) (*SendFilResponse, error)
	Close(context.Context, *CloseRequest) (*CloseResponse, error)
	AddToHot(RPCService_AddToHotServer) 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_AddToHotClient 

type RPCService_AddToHotClient interface {
	Send(*AddToHotRequest) error
	CloseAndRecv() (*AddToHotResponse, error)
	grpc.ClientStream
}

type RPCService_AddToHotServer 

type RPCService_AddToHotServer interface {
	SendAndClose(*AddToHotResponse) error
	Recv() (*AddToHotRequest, error)
	grpc.ServerStream
}

type RPCService_GetClient 

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

type RPCService_GetServer 

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

type RPCService_WatchJobsClient 

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

type RPCService_WatchJobsServer 

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

type RPCService_WatchLogsClient 

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

type RPCService_WatchLogsServer 

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

type RedeemPayChannelRequest 

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

func (*RedeemPayChannelRequest) Descriptor deprecated 

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

Deprecated: Use RedeemPayChannelRequest.ProtoReflect.Descriptor instead.

func (*RedeemPayChannelRequest) GetPayChannelAddr 

func (x *RedeemPayChannelRequest) GetPayChannelAddr() string

func (*RedeemPayChannelRequest) ProtoMessage 

func (*RedeemPayChannelRequest) ProtoMessage()

func (*RedeemPayChannelRequest) ProtoReflect 

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

func (*RedeemPayChannelRequest) Reset 

func (x *RedeemPayChannelRequest) Reset()

func (*RedeemPayChannelRequest) String 

func (x *RedeemPayChannelRequest) String() string

type RedeemPayChannelResponse 

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

func (*RedeemPayChannelResponse) Descriptor deprecated 

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

Deprecated: Use RedeemPayChannelResponse.ProtoReflect.Descriptor instead.

func (*RedeemPayChannelResponse) ProtoMessage 

func (*RedeemPayChannelResponse) ProtoMessage()

func (*RedeemPayChannelResponse) ProtoReflect 

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

func (*RedeemPayChannelResponse) Reset 

func (x *RedeemPayChannelResponse) Reset()

func (*RedeemPayChannelResponse) String 

func (x *RedeemPayChannelResponse) String() string

type RemoveRequest 

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

func (*RemoveRequest) Descriptor deprecated 

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

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetCid 

func (x *RemoveRequest) GetCid() string

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect 

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

func (*RemoveRequest) Reset 

func (x *RemoveRequest) Reset()

func (*RemoveRequest) String 

func (x *RemoveRequest) String() string

type RemoveResponse 

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

func (*RemoveResponse) Descriptor deprecated 

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

Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.

func (*RemoveResponse) ProtoMessage 

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) ProtoReflect 

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

func (*RemoveResponse) Reset 

func (x *RemoveResponse) Reset()

func (*RemoveResponse) String 

func (x *RemoveResponse) String() string

type ReplaceRequest 

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

func (*ReplaceRequest) Descriptor deprecated 

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

Deprecated: Use ReplaceRequest.ProtoReflect.Descriptor instead.

func (*ReplaceRequest) GetCid1 

func (x *ReplaceRequest) GetCid1() string

func (*ReplaceRequest) GetCid2 

func (x *ReplaceRequest) GetCid2() string

func (*ReplaceRequest) ProtoMessage 

func (*ReplaceRequest) ProtoMessage()

func (*ReplaceRequest) ProtoReflect 

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

func (*ReplaceRequest) Reset 

func (x *ReplaceRequest) Reset()

func (*ReplaceRequest) String 

func (x *ReplaceRequest) String() string

type ReplaceResponse 

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

func (*ReplaceResponse) Descriptor deprecated 

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

Deprecated: Use ReplaceResponse.ProtoReflect.Descriptor instead.

func (*ReplaceResponse) GetJobId 

func (x *ReplaceResponse) GetJobId() string

func (*ReplaceResponse) ProtoMessage 

func (*ReplaceResponse) ProtoMessage()

func (*ReplaceResponse) ProtoReflect 

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

func (*ReplaceResponse) Reset 

func (x *ReplaceResponse) Reset()

func (*ReplaceResponse) String 

func (x *ReplaceResponse) String() string

type RetrievalDealInfo added in v0.1.1 

type RetrievalDealInfo struct {
	RootCid                 string `protobuf:"bytes,1,opt,name=root_cid,json=rootCid,proto3" json:"root_cid,omitempty"`
	Size                    uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	MinPrice                uint64 `protobuf:"varint,3,opt,name=min_price,json=minPrice,proto3" json:"min_price,omitempty"`
	PaymentInterval         uint64 `protobuf:"varint,4,opt,name=payment_interval,json=paymentInterval,proto3" json:"payment_interval,omitempty"`
	PaymentIntervalIncrease uint64 `` /* 133-byte string literal not displayed */
	Miner                   string `protobuf:"bytes,6,opt,name=miner,proto3" json:"miner,omitempty"`
	MinerPeerId             string `protobuf:"bytes,7,opt,name=miner_peer_id,json=minerPeerId,proto3" json:"miner_peer_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RetrievalDealInfo) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use RetrievalDealInfo.ProtoReflect.Descriptor instead.

func (*RetrievalDealInfo) GetMinPrice added in v0.1.1 

func (x *RetrievalDealInfo) GetMinPrice() uint64

func (*RetrievalDealInfo) GetMiner added in v0.1.1 

func (x *RetrievalDealInfo) GetMiner() string

func (*RetrievalDealInfo) GetMinerPeerId added in v0.1.1 

func (x *RetrievalDealInfo) GetMinerPeerId() string

func (*RetrievalDealInfo) GetPaymentInterval added in v0.1.1 

func (x *RetrievalDealInfo) GetPaymentInterval() uint64

func (*RetrievalDealInfo) GetPaymentIntervalIncrease added in v0.1.1 

func (x *RetrievalDealInfo) GetPaymentIntervalIncrease() uint64

func (*RetrievalDealInfo) GetRootCid added in v0.1.1 

func (x *RetrievalDealInfo) GetRootCid() string

func (*RetrievalDealInfo) GetSize added in v0.1.1 

func (x *RetrievalDealInfo) GetSize() uint64

func (*RetrievalDealInfo) ProtoMessage added in v0.1.1 

func (*RetrievalDealInfo) ProtoMessage()

func (*RetrievalDealInfo) ProtoReflect added in v0.1.1 

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

func (*RetrievalDealInfo) Reset added in v0.1.1 

func (x *RetrievalDealInfo) Reset()

func (*RetrievalDealInfo) String added in v0.1.1 

func (x *RetrievalDealInfo) String() string

type RetrievalDealRecord added in v0.1.1 

type RetrievalDealRecord struct {
	Addr     string             `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	Time     int64              `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	DealInfo *RetrievalDealInfo `protobuf:"bytes,3,opt,name=deal_info,json=dealInfo,proto3" json:"deal_info,omitempty"`
	// contains filtered or unexported fields
}

func (*RetrievalDealRecord) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use RetrievalDealRecord.ProtoReflect.Descriptor instead.

func (*RetrievalDealRecord) GetAddr added in v0.1.1 

func (x *RetrievalDealRecord) GetAddr() string

func (*RetrievalDealRecord) GetDealInfo added in v0.1.1 

func (x *RetrievalDealRecord) GetDealInfo() *RetrievalDealInfo

func (*RetrievalDealRecord) GetTime added in v0.1.1 

func (x *RetrievalDealRecord) GetTime() int64

func (*RetrievalDealRecord) ProtoMessage added in v0.1.1 

func (*RetrievalDealRecord) ProtoMessage()

func (*RetrievalDealRecord) ProtoReflect added in v0.1.1 

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

func (*RetrievalDealRecord) Reset added in v0.1.1 

func (x *RetrievalDealRecord) Reset()

func (*RetrievalDealRecord) String added in v0.1.1 

func (x *RetrievalDealRecord) String() string

type SendFilRequest 

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

func (*SendFilRequest) Descriptor deprecated 

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

Deprecated: Use SendFilRequest.ProtoReflect.Descriptor instead.

func (*SendFilRequest) GetAmount 

func (x *SendFilRequest) GetAmount() int64

func (*SendFilRequest) GetFrom 

func (x *SendFilRequest) GetFrom() string

func (*SendFilRequest) GetTo 

func (x *SendFilRequest) GetTo() string

func (*SendFilRequest) ProtoMessage 

func (*SendFilRequest) ProtoMessage()

func (*SendFilRequest) ProtoReflect 

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

func (*SendFilRequest) Reset 

func (x *SendFilRequest) Reset()

func (*SendFilRequest) String 

func (x *SendFilRequest) String() string

type SendFilResponse 

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

func (*SendFilResponse) Descriptor deprecated 

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

Deprecated: Use SendFilResponse.ProtoReflect.Descriptor instead.

func (*SendFilResponse) ProtoMessage 

func (*SendFilResponse) ProtoMessage()

func (*SendFilResponse) ProtoReflect 

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

func (*SendFilResponse) Reset 

func (x *SendFilResponse) Reset()

func (*SendFilResponse) String 

func (x *SendFilResponse) String() string

type SetDefaultConfigRequest 

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

func (*SetDefaultConfigRequest) Descriptor deprecated 

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

Deprecated: Use SetDefaultConfigRequest.ProtoReflect.Descriptor instead.

func (*SetDefaultConfigRequest) GetConfig 

func (x *SetDefaultConfigRequest) GetConfig() *DefaultConfig

func (*SetDefaultConfigRequest) ProtoMessage 

func (*SetDefaultConfigRequest) ProtoMessage()

func (*SetDefaultConfigRequest) ProtoReflect 

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

func (*SetDefaultConfigRequest) Reset 

func (x *SetDefaultConfigRequest) Reset()

func (*SetDefaultConfigRequest) String 

func (x *SetDefaultConfigRequest) String() string

type SetDefaultConfigResponse 

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

func (*SetDefaultConfigResponse) Descriptor deprecated 

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

Deprecated: Use SetDefaultConfigResponse.ProtoReflect.Descriptor instead.

func (*SetDefaultConfigResponse) ProtoMessage 

func (*SetDefaultConfigResponse) ProtoMessage()

func (*SetDefaultConfigResponse) ProtoReflect 

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

func (*SetDefaultConfigResponse) Reset 

func (x *SetDefaultConfigResponse) Reset()

func (*SetDefaultConfigResponse) String 

func (x *SetDefaultConfigResponse) String() string

type ShowAllRequest 

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

func (*ShowAllRequest) Descriptor deprecated 

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

Deprecated: Use ShowAllRequest.ProtoReflect.Descriptor instead.

func (*ShowAllRequest) ProtoMessage 

func (*ShowAllRequest) ProtoMessage()

func (*ShowAllRequest) ProtoReflect 

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

func (*ShowAllRequest) Reset 

func (x *ShowAllRequest) Reset()

func (*ShowAllRequest) String 

func (x *ShowAllRequest) String() string

type ShowAllResponse 

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

func (*ShowAllResponse) Descriptor deprecated 

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

Deprecated: Use ShowAllResponse.ProtoReflect.Descriptor instead.

func (*ShowAllResponse) GetCidInfos 

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

func (*ShowAllResponse) ProtoMessage 

func (*ShowAllResponse) ProtoMessage()

func (*ShowAllResponse) ProtoReflect 

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

func (*ShowAllResponse) Reset 

func (x *ShowAllResponse) Reset()

func (*ShowAllResponse) String 

func (x *ShowAllResponse) String() string

type ShowRequest 

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

func (*ShowRequest) Descriptor deprecated 

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

Deprecated: Use ShowRequest.ProtoReflect.Descriptor instead.

func (*ShowRequest) GetCid 

func (x *ShowRequest) GetCid() string

func (*ShowRequest) ProtoMessage 

func (*ShowRequest) ProtoMessage()

func (*ShowRequest) ProtoReflect 

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

func (*ShowRequest) Reset 

func (x *ShowRequest) Reset()

func (*ShowRequest) String 

func (x *ShowRequest) String() string

type ShowResponse 

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

func (*ShowResponse) Descriptor deprecated 

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

Deprecated: Use ShowResponse.ProtoReflect.Descriptor instead.

func (*ShowResponse) GetCidInfo 

func (x *ShowResponse) GetCidInfo() *CidInfo

func (*ShowResponse) ProtoMessage 

func (*ShowResponse) ProtoMessage()

func (*ShowResponse) ProtoReflect 

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

func (*ShowResponse) Reset 

func (x *ShowResponse) Reset()

func (*ShowResponse) String 

func (x *ShowResponse) String() string

type StorageDealInfo added in v0.1.1 

type StorageDealInfo struct {
	ProposalCid     string `protobuf:"bytes,1,opt,name=proposal_cid,json=proposalCid,proto3" json:"proposal_cid,omitempty"`
	StateId         uint64 `protobuf:"varint,2,opt,name=state_id,json=stateId,proto3" json:"state_id,omitempty"`
	StateName       string `protobuf:"bytes,3,opt,name=state_name,json=stateName,proto3" json:"state_name,omitempty"`
	Miner           string `protobuf:"bytes,4,opt,name=miner,proto3" json:"miner,omitempty"`
	PieceCid        string `protobuf:"bytes,5,opt,name=piece_cid,json=pieceCid,proto3" json:"piece_cid,omitempty"`
	Size            uint64 `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
	PricePerEpoch   uint64 `protobuf:"varint,7,opt,name=price_per_epoch,json=pricePerEpoch,proto3" json:"price_per_epoch,omitempty"`
	StartEpoch      uint64 `protobuf:"varint,8,opt,name=start_epoch,json=startEpoch,proto3" json:"start_epoch,omitempty"`
	Duration        uint64 `protobuf:"varint,9,opt,name=duration,proto3" json:"duration,omitempty"`
	DealId          uint64 `protobuf:"varint,10,opt,name=deal_id,json=dealId,proto3" json:"deal_id,omitempty"`
	ActivationEpoch int64  `protobuf:"varint,11,opt,name=activation_epoch,json=activationEpoch,proto3" json:"activation_epoch,omitempty"`
	Msg             string `protobuf:"bytes,12,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageDealInfo) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use StorageDealInfo.ProtoReflect.Descriptor instead.

func (*StorageDealInfo) GetActivationEpoch added in v0.1.1 

func (x *StorageDealInfo) GetActivationEpoch() int64

func (*StorageDealInfo) GetDealId added in v0.1.1 

func (x *StorageDealInfo) GetDealId() uint64

func (*StorageDealInfo) GetDuration added in v0.1.1 

func (x *StorageDealInfo) GetDuration() uint64

func (*StorageDealInfo) GetMiner added in v0.1.1 

func (x *StorageDealInfo) GetMiner() string

func (*StorageDealInfo) GetMsg added in v0.1.1 

func (x *StorageDealInfo) GetMsg() string

func (*StorageDealInfo) GetPieceCid added in v0.1.1 

func (x *StorageDealInfo) GetPieceCid() string

func (*StorageDealInfo) GetPricePerEpoch added in v0.1.1 

func (x *StorageDealInfo) GetPricePerEpoch() uint64

func (*StorageDealInfo) GetProposalCid added in v0.1.1 

func (x *StorageDealInfo) GetProposalCid() string

func (*StorageDealInfo) GetSize added in v0.1.1 

func (x *StorageDealInfo) GetSize() uint64

func (*StorageDealInfo) GetStartEpoch added in v0.1.1 

func (x *StorageDealInfo) GetStartEpoch() uint64

func (*StorageDealInfo) GetStateId added in v0.1.1 

func (x *StorageDealInfo) GetStateId() uint64

func (*StorageDealInfo) GetStateName added in v0.1.1 

func (x *StorageDealInfo) GetStateName() string

func (*StorageDealInfo) ProtoMessage added in v0.1.1 

func (*StorageDealInfo) ProtoMessage()

func (*StorageDealInfo) ProtoReflect added in v0.1.1 

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

func (*StorageDealInfo) Reset added in v0.1.1 

func (x *StorageDealInfo) Reset()

func (*StorageDealInfo) String added in v0.1.1 

func (x *StorageDealInfo) String() string

type StorageDealRecord added in v0.1.1 

type StorageDealRecord struct {
	RootCid  string           `protobuf:"bytes,1,opt,name=root_cid,json=rootCid,proto3" json:"root_cid,omitempty"`
	Addr     string           `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Time     int64            `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	Pending  bool             `protobuf:"varint,4,opt,name=pending,proto3" json:"pending,omitempty"`
	DealInfo *StorageDealInfo `protobuf:"bytes,5,opt,name=deal_info,json=dealInfo,proto3" json:"deal_info,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageDealRecord) Descriptor deprecated added in v0.1.1 

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

Deprecated: Use StorageDealRecord.ProtoReflect.Descriptor instead.

func (*StorageDealRecord) GetAddr added in v0.1.1 

func (x *StorageDealRecord) GetAddr() string

func (*StorageDealRecord) GetDealInfo added in v0.1.1 

func (x *StorageDealRecord) GetDealInfo() *StorageDealInfo

func (*StorageDealRecord) GetPending added in v0.1.1 

func (x *StorageDealRecord) GetPending() bool

func (*StorageDealRecord) GetRootCid added in v0.1.1 

func (x *StorageDealRecord) GetRootCid() string

func (*StorageDealRecord) GetTime added in v0.1.1 

func (x *StorageDealRecord) GetTime() int64

func (*StorageDealRecord) ProtoMessage added in v0.1.1 

func (*StorageDealRecord) ProtoMessage()

func (*StorageDealRecord) ProtoReflect added in v0.1.1 

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

func (*StorageDealRecord) Reset added in v0.1.1 

func (x *StorageDealRecord) Reset()

func (*StorageDealRecord) String added in v0.1.1 

func (x *StorageDealRecord) String() string

type UnimplementedRPCServiceServer 

type UnimplementedRPCServiceServer struct {
}

UnimplementedRPCServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedRPCServiceServer) AddToHot 

func (*UnimplementedRPCServiceServer) AddToHot(RPCService_AddToHotServer) error

func (*UnimplementedRPCServiceServer) Addrs 

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

func (*UnimplementedRPCServiceServer) CancelJob 

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

func (*UnimplementedRPCServiceServer) Close 

func (*UnimplementedRPCServiceServer) Close(context.Context, *CloseRequest) (*CloseResponse, error)

func (*UnimplementedRPCServiceServer) Create 

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

func (*UnimplementedRPCServiceServer) CreatePayChannel 

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

func (*UnimplementedRPCServiceServer) DefaultConfig 

func (*UnimplementedRPCServiceServer) DefaultConfig(context.Context, *DefaultConfigRequest) (*DefaultConfigResponse, error)

func (*UnimplementedRPCServiceServer) Get 

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

func (*UnimplementedRPCServiceServer) GetCidConfig 

func (*UnimplementedRPCServiceServer) GetCidConfig(context.Context, *GetCidConfigRequest) (*GetCidConfigResponse, error)

func (*UnimplementedRPCServiceServer) GetDefaultCidConfig 

func (*UnimplementedRPCServiceServer) GetDefaultCidConfig(context.Context, *GetDefaultCidConfigRequest) (*GetDefaultCidConfigResponse, error)

func (*UnimplementedRPCServiceServer) ID 

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

func (*UnimplementedRPCServiceServer) Info 

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

func (*UnimplementedRPCServiceServer) ListAPI 

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

func (*UnimplementedRPCServiceServer) ListPayChannels 

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

func (*UnimplementedRPCServiceServer) ListRetrievalDealRecords 

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

func (*UnimplementedRPCServiceServer) ListStorageDealRecords 

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

func (*UnimplementedRPCServiceServer) NewAddr 

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

func (*UnimplementedRPCServiceServer) PushConfig 

func (*UnimplementedRPCServiceServer) PushConfig(context.Context, *PushConfigRequest) (*PushConfigResponse, error)

func (*UnimplementedRPCServiceServer) RedeemPayChannel 

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

func (*UnimplementedRPCServiceServer) Remove 

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

func (*UnimplementedRPCServiceServer) Replace 

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

func (*UnimplementedRPCServiceServer) SendFil 

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

func (*UnimplementedRPCServiceServer) SetDefaultConfig 

func (*UnimplementedRPCServiceServer) SetDefaultConfig(context.Context, *SetDefaultConfigRequest) (*SetDefaultConfigResponse, error)

func (*UnimplementedRPCServiceServer) Show 

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

func (*UnimplementedRPCServiceServer) ShowAll 

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

func (*UnimplementedRPCServiceServer) WatchJobs 

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

func (*UnimplementedRPCServiceServer) WatchLogs 

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

type WatchJobsRequest 

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

func (*WatchJobsRequest) Descriptor deprecated 

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

Deprecated: Use WatchJobsRequest.ProtoReflect.Descriptor instead.

func (*WatchJobsRequest) GetJids 

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

func (*WatchJobsRequest) ProtoMessage 

func (*WatchJobsRequest) ProtoMessage()

func (*WatchJobsRequest) ProtoReflect 

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

func (*WatchJobsRequest) Reset 

func (x *WatchJobsRequest) Reset()

func (*WatchJobsRequest) String 

func (x *WatchJobsRequest) String() string

type WatchJobsResponse 

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

func (*WatchJobsResponse) Descriptor deprecated 

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

Deprecated: Use WatchJobsResponse.ProtoReflect.Descriptor instead.

func (*WatchJobsResponse) GetJob 

func (x *WatchJobsResponse) GetJob() *Job

func (*WatchJobsResponse) ProtoMessage 

func (*WatchJobsResponse) ProtoMessage()

func (*WatchJobsResponse) ProtoReflect 

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

func (*WatchJobsResponse) Reset 

func (x *WatchJobsResponse) Reset()

func (*WatchJobsResponse) String 

func (x *WatchJobsResponse) String() string

type WatchLogsRequest 

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

func (*WatchLogsRequest) Descriptor deprecated 

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

Deprecated: Use WatchLogsRequest.ProtoReflect.Descriptor instead.

func (*WatchLogsRequest) GetCid 

func (x *WatchLogsRequest) GetCid() string

func (*WatchLogsRequest) GetHistory 

func (x *WatchLogsRequest) GetHistory() bool

func (*WatchLogsRequest) GetJid 

func (x *WatchLogsRequest) GetJid() string

func (*WatchLogsRequest) ProtoMessage 

func (*WatchLogsRequest) ProtoMessage()

func (*WatchLogsRequest) ProtoReflect 

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

func (*WatchLogsRequest) Reset 

func (x *WatchLogsRequest) Reset()

func (*WatchLogsRequest) String 

func (x *WatchLogsRequest) String() string

type WatchLogsResponse 

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

func (*WatchLogsResponse) Descriptor deprecated 

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

Deprecated: Use WatchLogsResponse.ProtoReflect.Descriptor instead.

func (*WatchLogsResponse) GetLogEntry 

func (x *WatchLogsResponse) GetLogEntry() *LogEntry

func (*WatchLogsResponse) ProtoMessage 

func (*WatchLogsResponse) ProtoMessage()

func (*WatchLogsResponse) ProtoReflect 

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

func (*WatchLogsResponse) Reset 

func (x *WatchLogsResponse) Reset()

func (*WatchLogsResponse) String 

func (x *WatchLogsResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

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