rpc

package
v0.0.1-beta.5 Latest Latest
Warning

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

 Go to latest Published: May 29, 2020 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	JobStatus_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "QUEUED",
		2: "EXECUTING",
		3: "FAILED",
		4: "CANCELED",
		5: "SUCCESS",
	}
	JobStatus_value = map[string]int32{
		"UNSPECIFIED": 0,
		"QUEUED":      1,
		"EXECUTING":   2,
		"FAILED":      3,
		"CANCELED":    4,
		"SUCCESS":     5,
	}
)

Enum value maps for JobStatus.

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 RegisterRPCServer 

func RegisterRPCServer(s *grpc.Server, srv RPCServer)

Types

type AddToHotReply 

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

func (*AddToHotReply) Descriptor deprecated 

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

Deprecated: Use AddToHotReply.ProtoReflect.Descriptor instead.

func (*AddToHotReply) GetCid 

func (x *AddToHotReply) GetCid() string

func (*AddToHotReply) ProtoMessage 

func (*AddToHotReply) ProtoMessage()

func (*AddToHotReply) ProtoReflect 

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

func (*AddToHotReply) Reset 

func (x *AddToHotReply) Reset()

func (*AddToHotReply) String 

func (x *AddToHotReply) String() string

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 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 AddrsReply 

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

func (*AddrsReply) Descriptor deprecated 

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

Deprecated: Use AddrsReply.ProtoReflect.Descriptor instead.

func (*AddrsReply) GetAddrs 

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

func (*AddrsReply) ProtoMessage 

func (*AddrsReply) ProtoMessage()

func (*AddrsReply) ProtoReflect 

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

func (*AddrsReply) Reset 

func (x *AddrsReply) Reset()

func (*AddrsReply) String 

func (x *AddrsReply) 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 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 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=jobID,proto3" json:"jobID,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 CloseReply 

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

func (*CloseReply) Descriptor deprecated 

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

Deprecated: Use CloseReply.ProtoReflect.Descriptor instead.

func (*CloseReply) ProtoMessage 

func (*CloseReply) ProtoMessage()

func (*CloseReply) ProtoReflect 

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

func (*CloseReply) Reset 

func (x *CloseReply) Reset()

func (*CloseReply) String 

func (x *CloseReply) 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 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 {
	Filecoin *FilInfo `protobuf:"bytes,1,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) 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 CreateReply 

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

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

Deprecated: Use CreateReply.ProtoReflect.Descriptor instead.

func (*CreateReply) GetID 

func (x *CreateReply) GetID() string

func (*CreateReply) GetToken 

func (x *CreateReply) GetToken() string

func (*CreateReply) ProtoMessage 

func (*CreateReply) ProtoMessage()

func (*CreateReply) ProtoReflect 

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

func (*CreateReply) Reset 

func (x *CreateReply) Reset()

func (*CreateReply) String 

func (x *CreateReply) 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 DealError 

type DealError struct {
	ProposalCid string `protobuf:"bytes,1,opt,name=ProposalCid,proto3" json:"ProposalCid,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 DefaultConfigReply 

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

func (*DefaultConfigReply) Descriptor deprecated 

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

Deprecated: Use DefaultConfigReply.ProtoReflect.Descriptor instead.

func (*DefaultConfigReply) GetDefaultConfig 

func (x *DefaultConfigReply) GetDefaultConfig() *DefaultConfig

func (*DefaultConfigReply) ProtoMessage 

func (*DefaultConfigReply) ProtoMessage()

func (*DefaultConfigReply) ProtoReflect 

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

func (*DefaultConfigReply) Reset 

func (x *DefaultConfigReply) Reset()

func (*DefaultConfigReply) String 

func (x *DefaultConfigReply) 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 FilConfig 

type FilConfig struct {
	RepFactor      int64     `protobuf:"varint,1,opt,name=repFactor,proto3" json:"repFactor,omitempty"`
	DealDuration   int64     `protobuf:"varint,2,opt,name=dealDuration,proto3" json:"dealDuration,omitempty"`
	ExcludedMiners []string  `protobuf:"bytes,3,rep,name=excludedMiners,proto3" json:"excludedMiners,omitempty"`
	TrustedMiners  []string  `protobuf:"bytes,4,rep,name=trustedMiners,proto3" json:"trustedMiners,omitempty"`
	CountryCodes   []string  `protobuf:"bytes,5,rep,name=countryCodes,proto3" json:"countryCodes,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=maxPrice,proto3" json:"maxPrice,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) GetDealDuration 

func (x *FilConfig) GetDealDuration() 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=dataCid,proto3" json:"dataCid,omitempty"`
	Size      int64         `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() int64

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=proposalCid,proto3" json:"proposalCid,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=activationEpoch,proto3" json:"activationEpoch,omitempty"`
	Miner           string `protobuf:"bytes,5,opt,name=miner,proto3" json:"miner,omitempty"`
	EpochPrice      uint64 `protobuf:"varint,6,opt,name=epochPrice,proto3" json:"epochPrice,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) 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 GetCidConfigReply 

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

func (*GetCidConfigReply) Descriptor deprecated 

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

Deprecated: Use GetCidConfigReply.ProtoReflect.Descriptor instead.

func (*GetCidConfigReply) GetConfig 

func (x *GetCidConfigReply) GetConfig() *CidConfig

func (*GetCidConfigReply) ProtoMessage 

func (*GetCidConfigReply) ProtoMessage()

func (*GetCidConfigReply) ProtoReflect 

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

func (*GetCidConfigReply) Reset 

func (x *GetCidConfigReply) Reset()

func (*GetCidConfigReply) String 

func (x *GetCidConfigReply) 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 GetDefaultCidConfigReply 

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

func (*GetDefaultCidConfigReply) Descriptor deprecated 

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

Deprecated: Use GetDefaultCidConfigReply.ProtoReflect.Descriptor instead.

func (*GetDefaultCidConfigReply) GetConfig 

func (x *GetDefaultCidConfigReply) GetConfig() *CidConfig

func (*GetDefaultCidConfigReply) ProtoMessage 

func (*GetDefaultCidConfigReply) ProtoMessage()

func (*GetDefaultCidConfigReply) ProtoReflect 

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

func (*GetDefaultCidConfigReply) Reset 

func (x *GetDefaultCidConfigReply) Reset()

func (*GetDefaultCidConfigReply) String 

func (x *GetDefaultCidConfigReply) 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 GetReply 

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

func (*GetReply) Descriptor deprecated 

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

Deprecated: Use GetReply.ProtoReflect.Descriptor instead.

func (*GetReply) GetChunk 

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

func (*GetReply) ProtoMessage 

func (*GetReply) ProtoMessage()

func (*GetReply) ProtoReflect 

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

func (*GetReply) Reset 

func (x *GetReply) Reset()

func (*GetReply) String 

func (x *GetReply) 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 HotConfig 

type HotConfig struct {
	Enabled       bool        `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	AllowUnfreeze bool        `protobuf:"varint,2,opt,name=allowUnfreeze,proto3" json:"allowUnfreeze,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 IDReply 

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

func (*IDReply) Descriptor deprecated 

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

Deprecated: Use IDReply.ProtoReflect.Descriptor instead.

func (*IDReply) GetID 

func (x *IDReply) GetID() string

func (*IDReply) ProtoMessage 

func (*IDReply) ProtoMessage()

func (*IDReply) ProtoReflect 

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

func (*IDReply) Reset 

func (x *IDReply) Reset()

func (*IDReply) String 

func (x *IDReply) 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 InfoReply 

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

func (*InfoReply) Descriptor deprecated 

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

Deprecated: Use InfoReply.ProtoReflect.Descriptor instead.

func (*InfoReply) GetInfo 

func (x *InfoReply) GetInfo() *InstanceInfo

func (*InfoReply) ProtoMessage 

func (*InfoReply) ProtoMessage()

func (*InfoReply) ProtoReflect 

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

func (*InfoReply) Reset 

func (x *InfoReply) Reset()

func (*InfoReply) String 

func (x *InfoReply) 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 InstanceInfo 

type InstanceInfo struct {
	ID            string         `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	DefaultConfig *DefaultConfig `protobuf:"bytes,2,opt,name=defaultConfig,proto3" json:"defaultConfig,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=addTimeout,proto3" json:"addTimeout,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=apiID,proto3" json:"apiID,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=errCause,proto3" json:"errCause,omitempty"`
	DealErrors []*DealError `protobuf:"bytes,6,rep,name=dealErrors,proto3" json:"dealErrors,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_UNSPECIFIED JobStatus = 0
	JobStatus_QUEUED      JobStatus = 1
	JobStatus_EXECUTING   JobStatus = 2
	JobStatus_FAILED      JobStatus = 3
	JobStatus_CANCELED    JobStatus = 4
	JobStatus_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 ListAPIReply 

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

func (*ListAPIReply) Descriptor deprecated 

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

Deprecated: Use ListAPIReply.ProtoReflect.Descriptor instead.

func (*ListAPIReply) GetInstances 

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

func (*ListAPIReply) ProtoMessage 

func (*ListAPIReply) ProtoMessage()

func (*ListAPIReply) ProtoReflect 

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

func (*ListAPIReply) Reset 

func (x *ListAPIReply) Reset()

func (*ListAPIReply) String 

func (x *ListAPIReply) String() string

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 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 NewAddrReply 

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

func (*NewAddrReply) Descriptor deprecated 

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

Deprecated: Use NewAddrReply.ProtoReflect.Descriptor instead.

func (*NewAddrReply) GetAddr 

func (x *NewAddrReply) GetAddr() string

func (*NewAddrReply) ProtoMessage 

func (*NewAddrReply) ProtoMessage()

func (*NewAddrReply) ProtoReflect 

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

func (*NewAddrReply) Reset 

func (x *NewAddrReply) Reset()

func (*NewAddrReply) String 

func (x *NewAddrReply) 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=addressType,proto3" json:"addressType,omitempty"`
	MakeDefault bool   `protobuf:"varint,3,opt,name=makeDefault,proto3" json:"makeDefault,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 PushConfigReply 

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

func (*PushConfigReply) Descriptor deprecated 

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

Deprecated: Use PushConfigReply.ProtoReflect.Descriptor instead.

func (*PushConfigReply) GetJobID 

func (x *PushConfigReply) GetJobID() string

func (*PushConfigReply) ProtoMessage 

func (*PushConfigReply) ProtoMessage()

func (*PushConfigReply) ProtoReflect 

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

func (*PushConfigReply) Reset 

func (x *PushConfigReply) Reset()

func (*PushConfigReply) String 

func (x *PushConfigReply) 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=hasConfig,proto3" json:"hasConfig,omitempty"`
	OverrideConfig    bool       `protobuf:"varint,4,opt,name=overrideConfig,proto3" json:"overrideConfig,omitempty"`
	HasOverrideConfig bool       `protobuf:"varint,5,opt,name=hasOverrideConfig,proto3" json:"hasOverrideConfig,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 RPC 

type RPC struct {
	UnimplementedRPCServer
	// 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 RPC_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) (*AddrsReply, error)

Addrs calls ffs.Addrs

func (*RPC) Close 

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

Close calls API.Close

func (*RPC) Create 

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

Create creates a new Api.

func (*RPC) DefaultConfig 

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

DefaultConfig calls ffs.DefaultConfig

func (*RPC) Get 

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

Get gets the data for a stored Cid.

func (*RPC) GetCidConfig 

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

GetCidConfig returns the cid config for the provided cid

func (*RPC) GetDefaultCidConfig 

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

GetDefaultCidConfig returns the default cid config prepped for the provided cid

func (*RPC) ID 

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

ID returns the API instance id

func (*RPC) Info 

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

Info returns an Api information.

func (*RPC) ListAPI 

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

ListAPI returns a list of all existing API instances.

func (*RPC) NewAddr 

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

NewAddr calls ffs.NewAddr

func (*RPC) PushConfig 

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

PushConfig applies the provided cid config

func (*RPC) Remove 

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

Remove calls ffs.Remove

func (*RPC) Replace 

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

Replace calls ffs.Replace

func (*RPC) SendFil 

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

SendFil sends fil from a managed address to any other address

func (*RPC) SetDefaultConfig 

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

SetDefaultConfig sets a new config to be used by default

func (*RPC) Show 

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

Show returns information about a particular Cid.

func (*RPC) ShowAll 

func (s *RPC) ShowAll(ctx context.Context, req *ShowAllRequest) (*ShowAllReply, 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 RPC_WatchJobsServer) error

WatchJobs calls API.WatchJobs

func (*RPC) WatchLogs 

func (s *RPC) WatchLogs(req *WatchLogsRequest, srv RPC_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 RPCClient 

type RPCClient interface {
	// Admin
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateReply, error)
	ListAPI(ctx context.Context, in *ListAPIRequest, opts ...grpc.CallOption) (*ListAPIReply, error)
	// Instance
	ID(ctx context.Context, in *IDRequest, opts ...grpc.CallOption) (*IDReply, error)
	Addrs(ctx context.Context, in *AddrsRequest, opts ...grpc.CallOption) (*AddrsReply, error)
	DefaultConfig(ctx context.Context, in *DefaultConfigRequest, opts ...grpc.CallOption) (*DefaultConfigReply, error)
	NewAddr(ctx context.Context, in *NewAddrRequest, opts ...grpc.CallOption) (*NewAddrReply, error)
	GetDefaultCidConfig(ctx context.Context, in *GetDefaultCidConfigRequest, opts ...grpc.CallOption) (*GetDefaultCidConfigReply, error)
	GetCidConfig(ctx context.Context, in *GetCidConfigRequest, opts ...grpc.CallOption) (*GetCidConfigReply, error)
	SetDefaultConfig(ctx context.Context, in *SetDefaultConfigRequest, opts ...grpc.CallOption) (*SetDefaultConfigReply, error)
	Show(ctx context.Context, in *ShowRequest, opts ...grpc.CallOption) (*ShowReply, error)
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoReply, error)
	WatchJobs(ctx context.Context, in *WatchJobsRequest, opts ...grpc.CallOption) (RPC_WatchJobsClient, error)
	WatchLogs(ctx context.Context, in *WatchLogsRequest, opts ...grpc.CallOption) (RPC_WatchLogsClient, error)
	Replace(ctx context.Context, in *ReplaceRequest, opts ...grpc.CallOption) (*ReplaceReply, error)
	PushConfig(ctx context.Context, in *PushConfigRequest, opts ...grpc.CallOption) (*PushConfigReply, error)
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveReply, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (RPC_GetClient, error)
	SendFil(ctx context.Context, in *SendFilRequest, opts ...grpc.CallOption) (*SendFilReply, error)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseReply, error)
	AddToHot(ctx context.Context, opts ...grpc.CallOption) (RPC_AddToHotClient, error)
	// UI support
	ShowAll(ctx context.Context, in *ShowAllRequest, opts ...grpc.CallOption) (*ShowAllReply, error)
}

RPCClient is the client API for RPC service.

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

func NewRPCClient 

func NewRPCClient(cc grpc.ClientConnInterface) RPCClient

type RPCServer 

type RPCServer interface {
	// Admin
	Create(context.Context, *CreateRequest) (*CreateReply, error)
	ListAPI(context.Context, *ListAPIRequest) (*ListAPIReply, error)
	// Instance
	ID(context.Context, *IDRequest) (*IDReply, error)
	Addrs(context.Context, *AddrsRequest) (*AddrsReply, error)
	DefaultConfig(context.Context, *DefaultConfigRequest) (*DefaultConfigReply, error)
	NewAddr(context.Context, *NewAddrRequest) (*NewAddrReply, error)
	GetDefaultCidConfig(context.Context, *GetDefaultCidConfigRequest) (*GetDefaultCidConfigReply, error)
	GetCidConfig(context.Context, *GetCidConfigRequest) (*GetCidConfigReply, error)
	SetDefaultConfig(context.Context, *SetDefaultConfigRequest) (*SetDefaultConfigReply, error)
	Show(context.Context, *ShowRequest) (*ShowReply, error)
	Info(context.Context, *InfoRequest) (*InfoReply, error)
	WatchJobs(*WatchJobsRequest, RPC_WatchJobsServer) error
	WatchLogs(*WatchLogsRequest, RPC_WatchLogsServer) error
	Replace(context.Context, *ReplaceRequest) (*ReplaceReply, error)
	PushConfig(context.Context, *PushConfigRequest) (*PushConfigReply, error)
	Remove(context.Context, *RemoveRequest) (*RemoveReply, error)
	Get(*GetRequest, RPC_GetServer) error
	SendFil(context.Context, *SendFilRequest) (*SendFilReply, error)
	Close(context.Context, *CloseRequest) (*CloseReply, error)
	AddToHot(RPC_AddToHotServer) error
	// UI support
	ShowAll(context.Context, *ShowAllRequest) (*ShowAllReply, error)
}

RPCServer is the server API for RPC service.

type RPC_AddToHotClient 

type RPC_AddToHotClient interface {
	Send(*AddToHotRequest) error
	CloseAndRecv() (*AddToHotReply, error)
	grpc.ClientStream
}

type RPC_AddToHotServer 

type RPC_AddToHotServer interface {
	SendAndClose(*AddToHotReply) error
	Recv() (*AddToHotRequest, error)
	grpc.ServerStream
}

type RPC_GetClient 

type RPC_GetClient interface {
	Recv() (*GetReply, error)
	grpc.ClientStream
}

type RPC_GetServer 

type RPC_GetServer interface {
	Send(*GetReply) error
	grpc.ServerStream
}

type RPC_WatchJobsClient 

type RPC_WatchJobsClient interface {
	Recv() (*WatchJobsReply, error)
	grpc.ClientStream
}

type RPC_WatchJobsServer 

type RPC_WatchJobsServer interface {
	Send(*WatchJobsReply) error
	grpc.ServerStream
}

type RPC_WatchLogsClient 

type RPC_WatchLogsClient interface {
	Recv() (*WatchLogsReply, error)
	grpc.ClientStream
}

type RPC_WatchLogsServer 

type RPC_WatchLogsServer interface {
	Send(*WatchLogsReply) error
	grpc.ServerStream
}

type RemoveReply 

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

func (*RemoveReply) Descriptor deprecated 

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

Deprecated: Use RemoveReply.ProtoReflect.Descriptor instead.

func (*RemoveReply) ProtoMessage 

func (*RemoveReply) ProtoMessage()

func (*RemoveReply) ProtoReflect 

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

func (*RemoveReply) Reset 

func (x *RemoveReply) Reset()

func (*RemoveReply) String 

func (x *RemoveReply) 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 ReplaceReply 

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

func (*ReplaceReply) Descriptor deprecated 

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

Deprecated: Use ReplaceReply.ProtoReflect.Descriptor instead.

func (*ReplaceReply) GetJobID 

func (x *ReplaceReply) GetJobID() string

func (*ReplaceReply) ProtoMessage 

func (*ReplaceReply) ProtoMessage()

func (*ReplaceReply) ProtoReflect 

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

func (*ReplaceReply) Reset 

func (x *ReplaceReply) Reset()

func (*ReplaceReply) String 

func (x *ReplaceReply) 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 SendFilReply 

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

func (*SendFilReply) Descriptor deprecated 

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

Deprecated: Use SendFilReply.ProtoReflect.Descriptor instead.

func (*SendFilReply) ProtoMessage 

func (*SendFilReply) ProtoMessage()

func (*SendFilReply) ProtoReflect 

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

func (*SendFilReply) Reset 

func (x *SendFilReply) Reset()

func (*SendFilReply) String 

func (x *SendFilReply) 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 SetDefaultConfigReply 

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

func (*SetDefaultConfigReply) Descriptor deprecated 

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

Deprecated: Use SetDefaultConfigReply.ProtoReflect.Descriptor instead.

func (*SetDefaultConfigReply) ProtoMessage 

func (*SetDefaultConfigReply) ProtoMessage()

func (*SetDefaultConfigReply) ProtoReflect 

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

func (*SetDefaultConfigReply) Reset 

func (x *SetDefaultConfigReply) Reset()

func (*SetDefaultConfigReply) String 

func (x *SetDefaultConfigReply) 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 ShowAllReply 

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

func (*ShowAllReply) Descriptor deprecated 

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

Deprecated: Use ShowAllReply.ProtoReflect.Descriptor instead.

func (*ShowAllReply) GetCidInfos 

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

func (*ShowAllReply) ProtoMessage 

func (*ShowAllReply) ProtoMessage()

func (*ShowAllReply) ProtoReflect 

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

func (*ShowAllReply) Reset 

func (x *ShowAllReply) Reset()

func (*ShowAllReply) String 

func (x *ShowAllReply) 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 ShowReply 

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

func (*ShowReply) Descriptor deprecated 

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

Deprecated: Use ShowReply.ProtoReflect.Descriptor instead.

func (*ShowReply) GetCidInfo 

func (x *ShowReply) GetCidInfo() *CidInfo

func (*ShowReply) ProtoMessage 

func (*ShowReply) ProtoMessage()

func (*ShowReply) ProtoReflect 

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

func (*ShowReply) Reset 

func (x *ShowReply) Reset()

func (*ShowReply) String 

func (x *ShowReply) 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 UnimplementedRPCServer 

type UnimplementedRPCServer struct {
}

UnimplementedRPCServer can be embedded to have forward compatible implementations.

func (*UnimplementedRPCServer) AddToHot 

func (*UnimplementedRPCServer) AddToHot(RPC_AddToHotServer) error

func (*UnimplementedRPCServer) Addrs 

func (*UnimplementedRPCServer) Addrs(context.Context, *AddrsRequest) (*AddrsReply, error)

func (*UnimplementedRPCServer) Close 

func (*UnimplementedRPCServer) Close(context.Context, *CloseRequest) (*CloseReply, error)

func (*UnimplementedRPCServer) Create 

func (*UnimplementedRPCServer) Create(context.Context, *CreateRequest) (*CreateReply, error)

func (*UnimplementedRPCServer) DefaultConfig 

func (*UnimplementedRPCServer) DefaultConfig(context.Context, *DefaultConfigRequest) (*DefaultConfigReply, error)

func (*UnimplementedRPCServer) Get 

func (*UnimplementedRPCServer) Get(*GetRequest, RPC_GetServer) error

func (*UnimplementedRPCServer) GetCidConfig 

func (*UnimplementedRPCServer) GetCidConfig(context.Context, *GetCidConfigRequest) (*GetCidConfigReply, error)

func (*UnimplementedRPCServer) GetDefaultCidConfig 

func (*UnimplementedRPCServer) GetDefaultCidConfig(context.Context, *GetDefaultCidConfigRequest) (*GetDefaultCidConfigReply, error)

func (*UnimplementedRPCServer) ID 

func (*UnimplementedRPCServer) ID(context.Context, *IDRequest) (*IDReply, error)

func (*UnimplementedRPCServer) Info 

func (*UnimplementedRPCServer) Info(context.Context, *InfoRequest) (*InfoReply, error)

func (*UnimplementedRPCServer) ListAPI 

func (*UnimplementedRPCServer) ListAPI(context.Context, *ListAPIRequest) (*ListAPIReply, error)

func (*UnimplementedRPCServer) NewAddr 

func (*UnimplementedRPCServer) NewAddr(context.Context, *NewAddrRequest) (*NewAddrReply, error)

func (*UnimplementedRPCServer) PushConfig 

func (*UnimplementedRPCServer) PushConfig(context.Context, *PushConfigRequest) (*PushConfigReply, error)

func (*UnimplementedRPCServer) Remove 

func (*UnimplementedRPCServer) Remove(context.Context, *RemoveRequest) (*RemoveReply, error)

func (*UnimplementedRPCServer) Replace 

func (*UnimplementedRPCServer) Replace(context.Context, *ReplaceRequest) (*ReplaceReply, error)

func (*UnimplementedRPCServer) SendFil 

func (*UnimplementedRPCServer) SendFil(context.Context, *SendFilRequest) (*SendFilReply, error)

func (*UnimplementedRPCServer) SetDefaultConfig 

func (*UnimplementedRPCServer) SetDefaultConfig(context.Context, *SetDefaultConfigRequest) (*SetDefaultConfigReply, error)

func (*UnimplementedRPCServer) Show 

func (*UnimplementedRPCServer) Show(context.Context, *ShowRequest) (*ShowReply, error)

func (*UnimplementedRPCServer) ShowAll 

func (*UnimplementedRPCServer) ShowAll(context.Context, *ShowAllRequest) (*ShowAllReply, error)

func (*UnimplementedRPCServer) WatchJobs 

func (*UnimplementedRPCServer) WatchJobs(*WatchJobsRequest, RPC_WatchJobsServer) error

func (*UnimplementedRPCServer) WatchLogs 

func (*UnimplementedRPCServer) WatchLogs(*WatchLogsRequest, RPC_WatchLogsServer) error

type WatchJobsReply 

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

func (*WatchJobsReply) Descriptor deprecated 

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

Deprecated: Use WatchJobsReply.ProtoReflect.Descriptor instead.

func (*WatchJobsReply) GetJob 

func (x *WatchJobsReply) GetJob() *Job

func (*WatchJobsReply) ProtoMessage 

func (*WatchJobsReply) ProtoMessage()

func (*WatchJobsReply) ProtoReflect 

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

func (*WatchJobsReply) Reset 

func (x *WatchJobsReply) Reset()

func (*WatchJobsReply) String 

func (x *WatchJobsReply) String() string

type WatchJobsRequest 

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

func (*WatchJobsRequest) Descriptor deprecated 

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

Deprecated: Use WatchJobsRequest.ProtoReflect.Descriptor instead.

func (*WatchJobsRequest) GetJids 

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

func (*WatchJobsRequest) ProtoMessage 

func (*WatchJobsRequest) ProtoMessage()

func (*WatchJobsRequest) ProtoReflect 

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

func (*WatchJobsRequest) Reset 

func (x *WatchJobsRequest) Reset()

func (*WatchJobsRequest) String 

func (x *WatchJobsRequest) String() string

type WatchLogsReply 

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

func (*WatchLogsReply) Descriptor deprecated 

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

Deprecated: Use WatchLogsReply.ProtoReflect.Descriptor instead.

func (*WatchLogsReply) GetLogEntry 

func (x *WatchLogsReply) GetLogEntry() *LogEntry

func (*WatchLogsReply) ProtoMessage 

func (*WatchLogsReply) ProtoMessage()

func (*WatchLogsReply) ProtoReflect 

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

func (*WatchLogsReply) Reset 

func (x *WatchLogsReply) Reset()

func (*WatchLogsReply) String 

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

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.