rpc

package
v0.0.1-beta.0 Latest Latest
Warning

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

 Go to latest Published: May 18, 2020 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 JobStatus_name = map[int32]string{
	0: "Queued",
	1: "Executing",
	2: "Failed",
	3: "Canceled",
	4: "Success",
}
View Source 
var JobStatus_value = map[string]int32{
	"Queued":    0,
	"Executing": 1,
	"Failed":    2,
	"Canceled":  3,
	"Success":   4,
}

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddToHotReply) Descriptor 

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

func (*AddToHotReply) GetCid 

func (m *AddToHotReply) GetCid() string

func (*AddToHotReply) ProtoMessage 

func (*AddToHotReply) ProtoMessage()

func (*AddToHotReply) Reset 

func (m *AddToHotReply) Reset()

func (*AddToHotReply) String 

func (m *AddToHotReply) String() string

func (*AddToHotReply) XXX_DiscardUnknown 

func (m *AddToHotReply) XXX_DiscardUnknown()

func (*AddToHotReply) XXX_Marshal 

func (m *AddToHotReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddToHotReply) XXX_Merge 

func (m *AddToHotReply) XXX_Merge(src proto.Message)

func (*AddToHotReply) XXX_Size 

func (m *AddToHotReply) XXX_Size() int

func (*AddToHotReply) XXX_Unmarshal 

func (m *AddToHotReply) XXX_Unmarshal(b []byte) error

type AddToHotRequest 

type AddToHotRequest struct {
	Chunk                []byte   `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddToHotRequest) Descriptor 

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

func (*AddToHotRequest) GetChunk 

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

func (*AddToHotRequest) ProtoMessage 

func (*AddToHotRequest) ProtoMessage()

func (*AddToHotRequest) Reset 

func (m *AddToHotRequest) Reset()

func (*AddToHotRequest) String 

func (m *AddToHotRequest) String() string

func (*AddToHotRequest) XXX_DiscardUnknown 

func (m *AddToHotRequest) XXX_DiscardUnknown()

func (*AddToHotRequest) XXX_Marshal 

func (m *AddToHotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddToHotRequest) XXX_Merge 

func (m *AddToHotRequest) XXX_Merge(src proto.Message)

func (*AddToHotRequest) XXX_Size 

func (m *AddToHotRequest) XXX_Size() int

func (*AddToHotRequest) XXX_Unmarshal 

func (m *AddToHotRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddrInfo) Descriptor 

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

func (*AddrInfo) GetAddr 

func (m *AddrInfo) GetAddr() string

func (*AddrInfo) GetName 

func (m *AddrInfo) GetName() string

func (*AddrInfo) GetType 

func (m *AddrInfo) GetType() string

func (*AddrInfo) ProtoMessage 

func (*AddrInfo) ProtoMessage()

func (*AddrInfo) Reset 

func (m *AddrInfo) Reset()

func (*AddrInfo) String 

func (m *AddrInfo) String() string

func (*AddrInfo) XXX_DiscardUnknown 

func (m *AddrInfo) XXX_DiscardUnknown()

func (*AddrInfo) XXX_Marshal 

func (m *AddrInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddrInfo) XXX_Merge 

func (m *AddrInfo) XXX_Merge(src proto.Message)

func (*AddrInfo) XXX_Size 

func (m *AddrInfo) XXX_Size() int

func (*AddrInfo) XXX_Unmarshal 

func (m *AddrInfo) XXX_Unmarshal(b []byte) error

type AddrsReply 

type AddrsReply struct {
	Addrs                []*AddrInfo `protobuf:"bytes,1,rep,name=addrs,proto3" json:"addrs,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*AddrsReply) Descriptor 

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

func (*AddrsReply) GetAddrs 

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

func (*AddrsReply) ProtoMessage 

func (*AddrsReply) ProtoMessage()

func (*AddrsReply) Reset 

func (m *AddrsReply) Reset()

func (*AddrsReply) String 

func (m *AddrsReply) String() string

func (*AddrsReply) XXX_DiscardUnknown 

func (m *AddrsReply) XXX_DiscardUnknown()

func (*AddrsReply) XXX_Marshal 

func (m *AddrsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddrsReply) XXX_Merge 

func (m *AddrsReply) XXX_Merge(src proto.Message)

func (*AddrsReply) XXX_Size 

func (m *AddrsReply) XXX_Size() int

func (*AddrsReply) XXX_Unmarshal 

func (m *AddrsReply) XXX_Unmarshal(b []byte) error

type AddrsRequest 

type AddrsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddrsRequest) Descriptor 

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

func (*AddrsRequest) ProtoMessage 

func (*AddrsRequest) ProtoMessage()

func (*AddrsRequest) Reset 

func (m *AddrsRequest) Reset()

func (*AddrsRequest) String 

func (m *AddrsRequest) String() string

func (*AddrsRequest) XXX_DiscardUnknown 

func (m *AddrsRequest) XXX_DiscardUnknown()

func (*AddrsRequest) XXX_Marshal 

func (m *AddrsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AddrsRequest) XXX_Merge 

func (m *AddrsRequest) XXX_Merge(src proto.Message)

func (*AddrsRequest) XXX_Size 

func (m *AddrsRequest) XXX_Size() int

func (*AddrsRequest) XXX_Unmarshal 

func (m *AddrsRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*BalanceInfo) Descriptor 

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

func (*BalanceInfo) GetAddr 

func (m *BalanceInfo) GetAddr() *AddrInfo

func (*BalanceInfo) GetBalance 

func (m *BalanceInfo) GetBalance() int64

func (*BalanceInfo) ProtoMessage 

func (*BalanceInfo) ProtoMessage()

func (*BalanceInfo) Reset 

func (m *BalanceInfo) Reset()

func (*BalanceInfo) String 

func (m *BalanceInfo) String() string

func (*BalanceInfo) XXX_DiscardUnknown 

func (m *BalanceInfo) XXX_DiscardUnknown()

func (*BalanceInfo) XXX_Marshal 

func (m *BalanceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BalanceInfo) XXX_Merge 

func (m *BalanceInfo) XXX_Merge(src proto.Message)

func (*BalanceInfo) XXX_Size 

func (m *BalanceInfo) XXX_Size() int

func (*BalanceInfo) XXX_Unmarshal 

func (m *BalanceInfo) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*CidConfig) Descriptor 

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

func (*CidConfig) GetCid 

func (m *CidConfig) GetCid() string

func (*CidConfig) GetCold 

func (m *CidConfig) GetCold() *ColdConfig

func (*CidConfig) GetHot 

func (m *CidConfig) GetHot() *HotConfig

func (*CidConfig) GetRepairable 

func (m *CidConfig) GetRepairable() bool

func (*CidConfig) ProtoMessage 

func (*CidConfig) ProtoMessage()

func (*CidConfig) Reset 

func (m *CidConfig) Reset()

func (*CidConfig) String 

func (m *CidConfig) String() string

func (*CidConfig) XXX_DiscardUnknown 

func (m *CidConfig) XXX_DiscardUnknown()

func (*CidConfig) XXX_Marshal 

func (m *CidConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CidConfig) XXX_Merge 

func (m *CidConfig) XXX_Merge(src proto.Message)

func (*CidConfig) XXX_Size 

func (m *CidConfig) XXX_Size() int

func (*CidConfig) XXX_Unmarshal 

func (m *CidConfig) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*CidInfo) Descriptor 

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

func (*CidInfo) GetCid 

func (m *CidInfo) GetCid() string

func (*CidInfo) GetCold 

func (m *CidInfo) GetCold() *ColdInfo

func (*CidInfo) GetCreated 

func (m *CidInfo) GetCreated() int64

func (*CidInfo) GetHot 

func (m *CidInfo) GetHot() *HotInfo

func (*CidInfo) GetJobID 

func (m *CidInfo) GetJobID() string

func (*CidInfo) ProtoMessage 

func (*CidInfo) ProtoMessage()

func (*CidInfo) Reset 

func (m *CidInfo) Reset()

func (*CidInfo) String 

func (m *CidInfo) String() string

func (*CidInfo) XXX_DiscardUnknown 

func (m *CidInfo) XXX_DiscardUnknown()

func (*CidInfo) XXX_Marshal 

func (m *CidInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CidInfo) XXX_Merge 

func (m *CidInfo) XXX_Merge(src proto.Message)

func (*CidInfo) XXX_Size 

func (m *CidInfo) XXX_Size() int

func (*CidInfo) XXX_Unmarshal 

func (m *CidInfo) XXX_Unmarshal(b []byte) error

type CloseReply 

type CloseReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseReply) Descriptor 

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

func (*CloseReply) ProtoMessage 

func (*CloseReply) ProtoMessage()

func (*CloseReply) Reset 

func (m *CloseReply) Reset()

func (*CloseReply) String 

func (m *CloseReply) String() string

func (*CloseReply) XXX_DiscardUnknown 

func (m *CloseReply) XXX_DiscardUnknown()

func (*CloseReply) XXX_Marshal 

func (m *CloseReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseReply) XXX_Merge 

func (m *CloseReply) XXX_Merge(src proto.Message)

func (*CloseReply) XXX_Size 

func (m *CloseReply) XXX_Size() int

func (*CloseReply) XXX_Unmarshal 

func (m *CloseReply) XXX_Unmarshal(b []byte) error

type CloseRequest 

type CloseRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseRequest) Descriptor 

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

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) Reset 

func (m *CloseRequest) Reset()

func (*CloseRequest) String 

func (m *CloseRequest) String() string

func (*CloseRequest) XXX_DiscardUnknown 

func (m *CloseRequest) XXX_DiscardUnknown()

func (*CloseRequest) XXX_Marshal 

func (m *CloseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CloseRequest) XXX_Merge 

func (m *CloseRequest) XXX_Merge(src proto.Message)

func (*CloseRequest) XXX_Size 

func (m *CloseRequest) XXX_Size() int

func (*CloseRequest) XXX_Unmarshal 

func (m *CloseRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ColdConfig) Descriptor 

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

func (*ColdConfig) GetEnabled 

func (m *ColdConfig) GetEnabled() bool

func (*ColdConfig) GetFilecoin 

func (m *ColdConfig) GetFilecoin() *FilConfig

func (*ColdConfig) ProtoMessage 

func (*ColdConfig) ProtoMessage()

func (*ColdConfig) Reset 

func (m *ColdConfig) Reset()

func (*ColdConfig) String 

func (m *ColdConfig) String() string

func (*ColdConfig) XXX_DiscardUnknown 

func (m *ColdConfig) XXX_DiscardUnknown()

func (*ColdConfig) XXX_Marshal 

func (m *ColdConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ColdConfig) XXX_Merge 

func (m *ColdConfig) XXX_Merge(src proto.Message)

func (*ColdConfig) XXX_Size 

func (m *ColdConfig) XXX_Size() int

func (*ColdConfig) XXX_Unmarshal 

func (m *ColdConfig) XXX_Unmarshal(b []byte) error

type ColdInfo 

type ColdInfo struct {
	Filecoin             *FilInfo `protobuf:"bytes,1,opt,name=filecoin,proto3" json:"filecoin,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ColdInfo) Descriptor 

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

func (*ColdInfo) GetFilecoin 

func (m *ColdInfo) GetFilecoin() *FilInfo

func (*ColdInfo) ProtoMessage 

func (*ColdInfo) ProtoMessage()

func (*ColdInfo) Reset 

func (m *ColdInfo) Reset()

func (*ColdInfo) String 

func (m *ColdInfo) String() string

func (*ColdInfo) XXX_DiscardUnknown 

func (m *ColdInfo) XXX_DiscardUnknown()

func (*ColdInfo) XXX_Marshal 

func (m *ColdInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ColdInfo) XXX_Merge 

func (m *ColdInfo) XXX_Merge(src proto.Message)

func (*ColdInfo) XXX_Size 

func (m *ColdInfo) XXX_Size() int

func (*ColdInfo) XXX_Unmarshal 

func (m *ColdInfo) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateReply) Descriptor 

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

func (*CreateReply) GetID 

func (m *CreateReply) GetID() string

func (*CreateReply) GetToken 

func (m *CreateReply) GetToken() string

func (*CreateReply) ProtoMessage 

func (*CreateReply) ProtoMessage()

func (*CreateReply) Reset 

func (m *CreateReply) Reset()

func (*CreateReply) String 

func (m *CreateReply) String() string

func (*CreateReply) XXX_DiscardUnknown 

func (m *CreateReply) XXX_DiscardUnknown()

func (*CreateReply) XXX_Marshal 

func (m *CreateReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateReply) XXX_Merge 

func (m *CreateReply) XXX_Merge(src proto.Message)

func (*CreateReply) XXX_Size 

func (m *CreateReply) XXX_Size() int

func (*CreateReply) XXX_Unmarshal 

func (m *CreateReply) XXX_Unmarshal(b []byte) error

type CreateRequest 

type CreateRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) String 

func (m *CreateRequest) String() string

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateRequest) XXX_Merge 

func (m *CreateRequest) XXX_Merge(src proto.Message)

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

func (m *CreateRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DealError) Descriptor 

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

func (*DealError) GetMessage 

func (m *DealError) GetMessage() string

func (*DealError) GetMiner 

func (m *DealError) GetMiner() string

func (*DealError) GetProposalCid 

func (m *DealError) GetProposalCid() string

func (*DealError) ProtoMessage 

func (*DealError) ProtoMessage()

func (*DealError) Reset 

func (m *DealError) Reset()

func (*DealError) String 

func (m *DealError) String() string

func (*DealError) XXX_DiscardUnknown 

func (m *DealError) XXX_DiscardUnknown()

func (*DealError) XXX_Marshal 

func (m *DealError) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DealError) XXX_Merge 

func (m *DealError) XXX_Merge(src proto.Message)

func (*DealError) XXX_Size 

func (m *DealError) XXX_Size() int

func (*DealError) XXX_Unmarshal 

func (m *DealError) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*DefaultConfig) Descriptor 

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

func (*DefaultConfig) GetCold 

func (m *DefaultConfig) GetCold() *ColdConfig

func (*DefaultConfig) GetHot 

func (m *DefaultConfig) GetHot() *HotConfig

func (*DefaultConfig) GetRepairable 

func (m *DefaultConfig) GetRepairable() bool

func (*DefaultConfig) ProtoMessage 

func (*DefaultConfig) ProtoMessage()

func (*DefaultConfig) Reset 

func (m *DefaultConfig) Reset()

func (*DefaultConfig) String 

func (m *DefaultConfig) String() string

func (*DefaultConfig) XXX_DiscardUnknown 

func (m *DefaultConfig) XXX_DiscardUnknown()

func (*DefaultConfig) XXX_Marshal 

func (m *DefaultConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DefaultConfig) XXX_Merge 

func (m *DefaultConfig) XXX_Merge(src proto.Message)

func (*DefaultConfig) XXX_Size 

func (m *DefaultConfig) XXX_Size() int

func (*DefaultConfig) XXX_Unmarshal 

func (m *DefaultConfig) XXX_Unmarshal(b []byte) error

type DefaultConfigReply 

type DefaultConfigReply struct {
	DefaultConfig        *DefaultConfig `protobuf:"bytes,1,opt,name=defaultConfig,proto3" json:"defaultConfig,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*DefaultConfigReply) Descriptor 

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

func (*DefaultConfigReply) GetDefaultConfig 

func (m *DefaultConfigReply) GetDefaultConfig() *DefaultConfig

func (*DefaultConfigReply) ProtoMessage 

func (*DefaultConfigReply) ProtoMessage()

func (*DefaultConfigReply) Reset 

func (m *DefaultConfigReply) Reset()

func (*DefaultConfigReply) String 

func (m *DefaultConfigReply) String() string

func (*DefaultConfigReply) XXX_DiscardUnknown 

func (m *DefaultConfigReply) XXX_DiscardUnknown()

func (*DefaultConfigReply) XXX_Marshal 

func (m *DefaultConfigReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DefaultConfigReply) XXX_Merge 

func (m *DefaultConfigReply) XXX_Merge(src proto.Message)

func (*DefaultConfigReply) XXX_Size 

func (m *DefaultConfigReply) XXX_Size() int

func (*DefaultConfigReply) XXX_Unmarshal 

func (m *DefaultConfigReply) XXX_Unmarshal(b []byte) error

type DefaultConfigRequest 

type DefaultConfigRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DefaultConfigRequest) Descriptor 

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

func (*DefaultConfigRequest) ProtoMessage 

func (*DefaultConfigRequest) ProtoMessage()

func (*DefaultConfigRequest) Reset 

func (m *DefaultConfigRequest) Reset()

func (*DefaultConfigRequest) String 

func (m *DefaultConfigRequest) String() string

func (*DefaultConfigRequest) XXX_DiscardUnknown 

func (m *DefaultConfigRequest) XXX_DiscardUnknown()

func (*DefaultConfigRequest) XXX_Marshal 

func (m *DefaultConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DefaultConfigRequest) XXX_Merge 

func (m *DefaultConfigRequest) XXX_Merge(src proto.Message)

func (*DefaultConfigRequest) XXX_Size 

func (m *DefaultConfigRequest) XXX_Size() int

func (*DefaultConfigRequest) XXX_Unmarshal 

func (m *DefaultConfigRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*FilConfig) Descriptor 

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

func (*FilConfig) GetAddr 

func (m *FilConfig) GetAddr() string

func (*FilConfig) GetCountryCodes 

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

func (*FilConfig) GetDealDuration 

func (m *FilConfig) GetDealDuration() int64

func (*FilConfig) GetExcludedMiners 

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

func (*FilConfig) GetRenew 

func (m *FilConfig) GetRenew() *FilRenew

func (*FilConfig) GetRepFactor 

func (m *FilConfig) GetRepFactor() int64

func (*FilConfig) GetTrustedMiners 

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

func (*FilConfig) ProtoMessage 

func (*FilConfig) ProtoMessage()

func (*FilConfig) Reset 

func (m *FilConfig) Reset()

func (*FilConfig) String 

func (m *FilConfig) String() string

func (*FilConfig) XXX_DiscardUnknown 

func (m *FilConfig) XXX_DiscardUnknown()

func (*FilConfig) XXX_Marshal 

func (m *FilConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FilConfig) XXX_Merge 

func (m *FilConfig) XXX_Merge(src proto.Message)

func (*FilConfig) XXX_Size 

func (m *FilConfig) XXX_Size() int

func (*FilConfig) XXX_Unmarshal 

func (m *FilConfig) XXX_Unmarshal(b []byte) error

type FilInfo 

type FilInfo struct {
	DataCid              string        `protobuf:"bytes,1,opt,name=dataCid,proto3" json:"dataCid,omitempty"`
	Proposals            []*FilStorage `protobuf:"bytes,2,rep,name=proposals,proto3" json:"proposals,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*FilInfo) Descriptor 

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

func (*FilInfo) GetDataCid 

func (m *FilInfo) GetDataCid() string

func (*FilInfo) GetProposals 

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

func (*FilInfo) ProtoMessage 

func (*FilInfo) ProtoMessage()

func (*FilInfo) Reset 

func (m *FilInfo) Reset()

func (*FilInfo) String 

func (m *FilInfo) String() string

func (*FilInfo) XXX_DiscardUnknown 

func (m *FilInfo) XXX_DiscardUnknown()

func (*FilInfo) XXX_Marshal 

func (m *FilInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FilInfo) XXX_Merge 

func (m *FilInfo) XXX_Merge(src proto.Message)

func (*FilInfo) XXX_Size 

func (m *FilInfo) XXX_Size() int

func (*FilInfo) XXX_Unmarshal 

func (m *FilInfo) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FilRenew) Descriptor 

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

func (*FilRenew) GetEnabled 

func (m *FilRenew) GetEnabled() bool

func (*FilRenew) GetThreshold 

func (m *FilRenew) GetThreshold() int64

func (*FilRenew) ProtoMessage 

func (*FilRenew) ProtoMessage()

func (*FilRenew) Reset 

func (m *FilRenew) Reset()

func (*FilRenew) String 

func (m *FilRenew) String() string

func (*FilRenew) XXX_DiscardUnknown 

func (m *FilRenew) XXX_DiscardUnknown()

func (*FilRenew) XXX_Marshal 

func (m *FilRenew) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FilRenew) XXX_Merge 

func (m *FilRenew) XXX_Merge(src proto.Message)

func (*FilRenew) XXX_Size 

func (m *FilRenew) XXX_Size() int

func (*FilRenew) XXX_Unmarshal 

func (m *FilRenew) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FilStorage) Descriptor 

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

func (*FilStorage) GetActivationEpoch 

func (m *FilStorage) GetActivationEpoch() int64

func (*FilStorage) GetDuration 

func (m *FilStorage) GetDuration() int64

func (*FilStorage) GetMiner 

func (m *FilStorage) GetMiner() string

func (*FilStorage) GetProposalCid 

func (m *FilStorage) GetProposalCid() string

func (*FilStorage) GetRenewed 

func (m *FilStorage) GetRenewed() bool

func (*FilStorage) ProtoMessage 

func (*FilStorage) ProtoMessage()

func (*FilStorage) Reset 

func (m *FilStorage) Reset()

func (*FilStorage) String 

func (m *FilStorage) String() string

func (*FilStorage) XXX_DiscardUnknown 

func (m *FilStorage) XXX_DiscardUnknown()

func (*FilStorage) XXX_Marshal 

func (m *FilStorage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FilStorage) XXX_Merge 

func (m *FilStorage) XXX_Merge(src proto.Message)

func (*FilStorage) XXX_Size 

func (m *FilStorage) XXX_Size() int

func (*FilStorage) XXX_Unmarshal 

func (m *FilStorage) XXX_Unmarshal(b []byte) error

type GetCidConfigReply 

type GetCidConfigReply struct {
	Config               *CidConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetCidConfigReply) Descriptor 

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

func (*GetCidConfigReply) GetConfig 

func (m *GetCidConfigReply) GetConfig() *CidConfig

func (*GetCidConfigReply) ProtoMessage 

func (*GetCidConfigReply) ProtoMessage()

func (*GetCidConfigReply) Reset 

func (m *GetCidConfigReply) Reset()

func (*GetCidConfigReply) String 

func (m *GetCidConfigReply) String() string

func (*GetCidConfigReply) XXX_DiscardUnknown 

func (m *GetCidConfigReply) XXX_DiscardUnknown()

func (*GetCidConfigReply) XXX_Marshal 

func (m *GetCidConfigReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCidConfigReply) XXX_Merge 

func (m *GetCidConfigReply) XXX_Merge(src proto.Message)

func (*GetCidConfigReply) XXX_Size 

func (m *GetCidConfigReply) XXX_Size() int

func (*GetCidConfigReply) XXX_Unmarshal 

func (m *GetCidConfigReply) XXX_Unmarshal(b []byte) error

type GetCidConfigRequest 

type GetCidConfigRequest struct {
	Cid                  string   `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetCidConfigRequest) Descriptor 

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

func (*GetCidConfigRequest) GetCid 

func (m *GetCidConfigRequest) GetCid() string

func (*GetCidConfigRequest) ProtoMessage 

func (*GetCidConfigRequest) ProtoMessage()

func (*GetCidConfigRequest) Reset 

func (m *GetCidConfigRequest) Reset()

func (*GetCidConfigRequest) String 

func (m *GetCidConfigRequest) String() string

func (*GetCidConfigRequest) XXX_DiscardUnknown 

func (m *GetCidConfigRequest) XXX_DiscardUnknown()

func (*GetCidConfigRequest) XXX_Marshal 

func (m *GetCidConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetCidConfigRequest) XXX_Merge 

func (m *GetCidConfigRequest) XXX_Merge(src proto.Message)

func (*GetCidConfigRequest) XXX_Size 

func (m *GetCidConfigRequest) XXX_Size() int

func (*GetCidConfigRequest) XXX_Unmarshal 

func (m *GetCidConfigRequest) XXX_Unmarshal(b []byte) error

type GetDefaultCidConfigReply 

type GetDefaultCidConfigReply struct {
	Config               *CidConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*GetDefaultCidConfigReply) Descriptor 

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

func (*GetDefaultCidConfigReply) GetConfig 

func (m *GetDefaultCidConfigReply) GetConfig() *CidConfig

func (*GetDefaultCidConfigReply) ProtoMessage 

func (*GetDefaultCidConfigReply) ProtoMessage()

func (*GetDefaultCidConfigReply) Reset 

func (m *GetDefaultCidConfigReply) Reset()

func (*GetDefaultCidConfigReply) String 

func (m *GetDefaultCidConfigReply) String() string

func (*GetDefaultCidConfigReply) XXX_DiscardUnknown 

func (m *GetDefaultCidConfigReply) XXX_DiscardUnknown()

func (*GetDefaultCidConfigReply) XXX_Marshal 

func (m *GetDefaultCidConfigReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDefaultCidConfigReply) XXX_Merge 

func (m *GetDefaultCidConfigReply) XXX_Merge(src proto.Message)

func (*GetDefaultCidConfigReply) XXX_Size 

func (m *GetDefaultCidConfigReply) XXX_Size() int

func (*GetDefaultCidConfigReply) XXX_Unmarshal 

func (m *GetDefaultCidConfigReply) XXX_Unmarshal(b []byte) error

type GetDefaultCidConfigRequest 

type GetDefaultCidConfigRequest struct {
	Cid                  string   `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetDefaultCidConfigRequest) Descriptor 

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

func (*GetDefaultCidConfigRequest) GetCid 

func (m *GetDefaultCidConfigRequest) GetCid() string

func (*GetDefaultCidConfigRequest) ProtoMessage 

func (*GetDefaultCidConfigRequest) ProtoMessage()

func (*GetDefaultCidConfigRequest) Reset 

func (m *GetDefaultCidConfigRequest) Reset()

func (*GetDefaultCidConfigRequest) String 

func (m *GetDefaultCidConfigRequest) String() string

func (*GetDefaultCidConfigRequest) XXX_DiscardUnknown 

func (m *GetDefaultCidConfigRequest) XXX_DiscardUnknown()

func (*GetDefaultCidConfigRequest) XXX_Marshal 

func (m *GetDefaultCidConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetDefaultCidConfigRequest) XXX_Merge 

func (m *GetDefaultCidConfigRequest) XXX_Merge(src proto.Message)

func (*GetDefaultCidConfigRequest) XXX_Size 

func (m *GetDefaultCidConfigRequest) XXX_Size() int

func (*GetDefaultCidConfigRequest) XXX_Unmarshal 

func (m *GetDefaultCidConfigRequest) XXX_Unmarshal(b []byte) error

type GetReply 

type GetReply struct {
	Chunk                []byte   `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetReply) Descriptor 

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

func (*GetReply) GetChunk 

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

func (*GetReply) ProtoMessage 

func (*GetReply) ProtoMessage()

func (*GetReply) Reset 

func (m *GetReply) Reset()

func (*GetReply) String 

func (m *GetReply) String() string

func (*GetReply) XXX_DiscardUnknown 

func (m *GetReply) XXX_DiscardUnknown()

func (*GetReply) XXX_Marshal 

func (m *GetReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetReply) XXX_Merge 

func (m *GetReply) XXX_Merge(src proto.Message)

func (*GetReply) XXX_Size 

func (m *GetReply) XXX_Size() int

func (*GetReply) XXX_Unmarshal 

func (m *GetReply) XXX_Unmarshal(b []byte) error

type GetRequest 

type GetRequest struct {
	Cid                  string   `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetCid 

func (m *GetRequest) GetCid() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

func (*GetRequest) XXX_DiscardUnknown 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal 

func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetRequest) XXX_Merge 

func (m *GetRequest) XXX_Merge(src proto.Message)

func (*GetRequest) XXX_Size 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal 

func (m *GetRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*HotConfig) Descriptor 

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

func (*HotConfig) GetAllowUnfreeze 

func (m *HotConfig) GetAllowUnfreeze() bool

func (*HotConfig) GetEnabled 

func (m *HotConfig) GetEnabled() bool

func (*HotConfig) GetIpfs 

func (m *HotConfig) GetIpfs() *IpfsConfig

func (*HotConfig) ProtoMessage 

func (*HotConfig) ProtoMessage()

func (*HotConfig) Reset 

func (m *HotConfig) Reset()

func (*HotConfig) String 

func (m *HotConfig) String() string

func (*HotConfig) XXX_DiscardUnknown 

func (m *HotConfig) XXX_DiscardUnknown()

func (*HotConfig) XXX_Marshal 

func (m *HotConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HotConfig) XXX_Merge 

func (m *HotConfig) XXX_Merge(src proto.Message)

func (*HotConfig) XXX_Size 

func (m *HotConfig) XXX_Size() int

func (*HotConfig) XXX_Unmarshal 

func (m *HotConfig) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*HotInfo) Descriptor 

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

func (*HotInfo) GetEnabled 

func (m *HotInfo) GetEnabled() bool

func (*HotInfo) GetIpfs 

func (m *HotInfo) GetIpfs() *IpfsHotInfo

func (*HotInfo) GetSize 

func (m *HotInfo) GetSize() int64

func (*HotInfo) ProtoMessage 

func (*HotInfo) ProtoMessage()

func (*HotInfo) Reset 

func (m *HotInfo) Reset()

func (*HotInfo) String 

func (m *HotInfo) String() string

func (*HotInfo) XXX_DiscardUnknown 

func (m *HotInfo) XXX_DiscardUnknown()

func (*HotInfo) XXX_Marshal 

func (m *HotInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HotInfo) XXX_Merge 

func (m *HotInfo) XXX_Merge(src proto.Message)

func (*HotInfo) XXX_Size 

func (m *HotInfo) XXX_Size() int

func (*HotInfo) XXX_Unmarshal 

func (m *HotInfo) XXX_Unmarshal(b []byte) error

type IDReply 

type IDReply struct {
	ID                   string   `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IDReply) Descriptor 

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

func (*IDReply) GetID 

func (m *IDReply) GetID() string

func (*IDReply) ProtoMessage 

func (*IDReply) ProtoMessage()

func (*IDReply) Reset 

func (m *IDReply) Reset()

func (*IDReply) String 

func (m *IDReply) String() string

func (*IDReply) XXX_DiscardUnknown 

func (m *IDReply) XXX_DiscardUnknown()

func (*IDReply) XXX_Marshal 

func (m *IDReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IDReply) XXX_Merge 

func (m *IDReply) XXX_Merge(src proto.Message)

func (*IDReply) XXX_Size 

func (m *IDReply) XXX_Size() int

func (*IDReply) XXX_Unmarshal 

func (m *IDReply) XXX_Unmarshal(b []byte) error

type IDRequest 

type IDRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IDRequest) Descriptor 

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

func (*IDRequest) ProtoMessage 

func (*IDRequest) ProtoMessage()

func (*IDRequest) Reset 

func (m *IDRequest) Reset()

func (*IDRequest) String 

func (m *IDRequest) String() string

func (*IDRequest) XXX_DiscardUnknown 

func (m *IDRequest) XXX_DiscardUnknown()

func (*IDRequest) XXX_Marshal 

func (m *IDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IDRequest) XXX_Merge 

func (m *IDRequest) XXX_Merge(src proto.Message)

func (*IDRequest) XXX_Size 

func (m *IDRequest) XXX_Size() int

func (*IDRequest) XXX_Unmarshal 

func (m *IDRequest) XXX_Unmarshal(b []byte) error

type InfoReply 

type InfoReply struct {
	Info                 *InstanceInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*InfoReply) Descriptor 

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

func (*InfoReply) GetInfo 

func (m *InfoReply) GetInfo() *InstanceInfo

func (*InfoReply) ProtoMessage 

func (*InfoReply) ProtoMessage()

func (*InfoReply) Reset 

func (m *InfoReply) Reset()

func (*InfoReply) String 

func (m *InfoReply) String() string

func (*InfoReply) XXX_DiscardUnknown 

func (m *InfoReply) XXX_DiscardUnknown()

func (*InfoReply) XXX_Marshal 

func (m *InfoReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InfoReply) XXX_Merge 

func (m *InfoReply) XXX_Merge(src proto.Message)

func (*InfoReply) XXX_Size 

func (m *InfoReply) XXX_Size() int

func (*InfoReply) XXX_Unmarshal 

func (m *InfoReply) XXX_Unmarshal(b []byte) error

type InfoRequest 

type InfoRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InfoRequest) Descriptor 

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

func (*InfoRequest) ProtoMessage 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) Reset 

func (m *InfoRequest) Reset()

func (*InfoRequest) String 

func (m *InfoRequest) String() string

func (*InfoRequest) XXX_DiscardUnknown 

func (m *InfoRequest) XXX_DiscardUnknown()

func (*InfoRequest) XXX_Marshal 

func (m *InfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InfoRequest) XXX_Merge 

func (m *InfoRequest) XXX_Merge(src proto.Message)

func (*InfoRequest) XXX_Size 

func (m *InfoRequest) XXX_Size() int

func (*InfoRequest) XXX_Unmarshal 

func (m *InfoRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*InstanceInfo) Descriptor 

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

func (*InstanceInfo) GetBalances 

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

func (*InstanceInfo) GetDefaultConfig 

func (m *InstanceInfo) GetDefaultConfig() *DefaultConfig

func (*InstanceInfo) GetID 

func (m *InstanceInfo) GetID() string

func (*InstanceInfo) GetPins 

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

func (*InstanceInfo) ProtoMessage 

func (*InstanceInfo) ProtoMessage()

func (*InstanceInfo) Reset 

func (m *InstanceInfo) Reset()

func (*InstanceInfo) String 

func (m *InstanceInfo) String() string

func (*InstanceInfo) XXX_DiscardUnknown 

func (m *InstanceInfo) XXX_DiscardUnknown()

func (*InstanceInfo) XXX_Marshal 

func (m *InstanceInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InstanceInfo) XXX_Merge 

func (m *InstanceInfo) XXX_Merge(src proto.Message)

func (*InstanceInfo) XXX_Size 

func (m *InstanceInfo) XXX_Size() int

func (*InstanceInfo) XXX_Unmarshal 

func (m *InstanceInfo) XXX_Unmarshal(b []byte) error

type IpfsConfig 

type IpfsConfig struct {
	AddTimeout           int64    `protobuf:"varint,1,opt,name=addTimeout,proto3" json:"addTimeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IpfsConfig) Descriptor 

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

func (*IpfsConfig) GetAddTimeout 

func (m *IpfsConfig) GetAddTimeout() int64

func (*IpfsConfig) ProtoMessage 

func (*IpfsConfig) ProtoMessage()

func (*IpfsConfig) Reset 

func (m *IpfsConfig) Reset()

func (*IpfsConfig) String 

func (m *IpfsConfig) String() string

func (*IpfsConfig) XXX_DiscardUnknown 

func (m *IpfsConfig) XXX_DiscardUnknown()

func (*IpfsConfig) XXX_Marshal 

func (m *IpfsConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IpfsConfig) XXX_Merge 

func (m *IpfsConfig) XXX_Merge(src proto.Message)

func (*IpfsConfig) XXX_Size 

func (m *IpfsConfig) XXX_Size() int

func (*IpfsConfig) XXX_Unmarshal 

func (m *IpfsConfig) XXX_Unmarshal(b []byte) error

type IpfsHotInfo 

type IpfsHotInfo struct {
	Created              int64    `protobuf:"varint,1,opt,name=created,proto3" json:"created,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IpfsHotInfo) Descriptor 

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

func (*IpfsHotInfo) GetCreated 

func (m *IpfsHotInfo) GetCreated() int64

func (*IpfsHotInfo) ProtoMessage 

func (*IpfsHotInfo) ProtoMessage()

func (*IpfsHotInfo) Reset 

func (m *IpfsHotInfo) Reset()

func (*IpfsHotInfo) String 

func (m *IpfsHotInfo) String() string

func (*IpfsHotInfo) XXX_DiscardUnknown 

func (m *IpfsHotInfo) XXX_DiscardUnknown()

func (*IpfsHotInfo) XXX_Marshal 

func (m *IpfsHotInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*IpfsHotInfo) XXX_Merge 

func (m *IpfsHotInfo) XXX_Merge(src proto.Message)

func (*IpfsHotInfo) XXX_Size 

func (m *IpfsHotInfo) XXX_Size() int

func (*IpfsHotInfo) XXX_Unmarshal 

func (m *IpfsHotInfo) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*Job) Descriptor 

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

func (*Job) GetApiID 

func (m *Job) GetApiID() string

func (*Job) GetCid 

func (m *Job) GetCid() string

func (*Job) GetDealErrors 

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

func (*Job) GetErrCause 

func (m *Job) GetErrCause() string

func (*Job) GetID 

func (m *Job) GetID() string

func (*Job) GetStatus 

func (m *Job) GetStatus() JobStatus

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) Reset 

func (m *Job) Reset()

func (*Job) String 

func (m *Job) String() string

func (*Job) XXX_DiscardUnknown 

func (m *Job) XXX_DiscardUnknown()

func (*Job) XXX_Marshal 

func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Job) XXX_Merge 

func (m *Job) XXX_Merge(src proto.Message)

func (*Job) XXX_Size 

func (m *Job) XXX_Size() int

func (*Job) XXX_Unmarshal 

func (m *Job) XXX_Unmarshal(b []byte) error

type JobStatus 

type JobStatus int32
const (
	JobStatus_Queued    JobStatus = 0
	JobStatus_Executing JobStatus = 1
	JobStatus_Failed    JobStatus = 2
	JobStatus_Canceled  JobStatus = 3
	JobStatus_Success   JobStatus = 4
)

func (JobStatus) EnumDescriptor 

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

func (JobStatus) String 

func (x JobStatus) String() string

type ListAPIReply 

type ListAPIReply struct {
	Instances            []string `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListAPIReply) Descriptor 

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

func (*ListAPIReply) GetInstances 

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

func (*ListAPIReply) ProtoMessage 

func (*ListAPIReply) ProtoMessage()

func (*ListAPIReply) Reset 

func (m *ListAPIReply) Reset()

func (*ListAPIReply) String 

func (m *ListAPIReply) String() string

func (*ListAPIReply) XXX_DiscardUnknown 

func (m *ListAPIReply) XXX_DiscardUnknown()

func (*ListAPIReply) XXX_Marshal 

func (m *ListAPIReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListAPIReply) XXX_Merge 

func (m *ListAPIReply) XXX_Merge(src proto.Message)

func (*ListAPIReply) XXX_Size 

func (m *ListAPIReply) XXX_Size() int

func (*ListAPIReply) XXX_Unmarshal 

func (m *ListAPIReply) XXX_Unmarshal(b []byte) error

type ListAPIRequest 

type ListAPIRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListAPIRequest) Descriptor 

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

func (*ListAPIRequest) ProtoMessage 

func (*ListAPIRequest) ProtoMessage()

func (*ListAPIRequest) Reset 

func (m *ListAPIRequest) Reset()

func (*ListAPIRequest) String 

func (m *ListAPIRequest) String() string

func (*ListAPIRequest) XXX_DiscardUnknown 

func (m *ListAPIRequest) XXX_DiscardUnknown()

func (*ListAPIRequest) XXX_Marshal 

func (m *ListAPIRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListAPIRequest) XXX_Merge 

func (m *ListAPIRequest) XXX_Merge(src proto.Message)

func (*ListAPIRequest) XXX_Size 

func (m *ListAPIRequest) XXX_Size() int

func (*ListAPIRequest) XXX_Unmarshal 

func (m *ListAPIRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogEntry) Descriptor 

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

func (*LogEntry) GetCid 

func (m *LogEntry) GetCid() string

func (*LogEntry) GetJid 

func (m *LogEntry) GetJid() string

func (*LogEntry) GetMsg 

func (m *LogEntry) GetMsg() string

func (*LogEntry) GetTime 

func (m *LogEntry) GetTime() int64

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) String 

func (m *LogEntry) String() string

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

func (m *LogEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogEntry) XXX_Merge 

func (m *LogEntry) XXX_Merge(src proto.Message)

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

func (m *LogEntry) XXX_Unmarshal(b []byte) error

type NewAddrReply 

type NewAddrReply struct {
	Addr                 string   `protobuf:"bytes,1,opt,name=addr,proto3" json:"addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewAddrReply) Descriptor 

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

func (*NewAddrReply) GetAddr 

func (m *NewAddrReply) GetAddr() string

func (*NewAddrReply) ProtoMessage 

func (*NewAddrReply) ProtoMessage()

func (*NewAddrReply) Reset 

func (m *NewAddrReply) Reset()

func (*NewAddrReply) String 

func (m *NewAddrReply) String() string

func (*NewAddrReply) XXX_DiscardUnknown 

func (m *NewAddrReply) XXX_DiscardUnknown()

func (*NewAddrReply) XXX_Marshal 

func (m *NewAddrReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewAddrReply) XXX_Merge 

func (m *NewAddrReply) XXX_Merge(src proto.Message)

func (*NewAddrReply) XXX_Size 

func (m *NewAddrReply) XXX_Size() int

func (*NewAddrReply) XXX_Unmarshal 

func (m *NewAddrReply) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewAddrRequest) Descriptor 

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

func (*NewAddrRequest) GetAddressType 

func (m *NewAddrRequest) GetAddressType() string

func (*NewAddrRequest) GetMakeDefault 

func (m *NewAddrRequest) GetMakeDefault() bool

func (*NewAddrRequest) GetName 

func (m *NewAddrRequest) GetName() string

func (*NewAddrRequest) ProtoMessage 

func (*NewAddrRequest) ProtoMessage()

func (*NewAddrRequest) Reset 

func (m *NewAddrRequest) Reset()

func (*NewAddrRequest) String 

func (m *NewAddrRequest) String() string

func (*NewAddrRequest) XXX_DiscardUnknown 

func (m *NewAddrRequest) XXX_DiscardUnknown()

func (*NewAddrRequest) XXX_Marshal 

func (m *NewAddrRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NewAddrRequest) XXX_Merge 

func (m *NewAddrRequest) XXX_Merge(src proto.Message)

func (*NewAddrRequest) XXX_Size 

func (m *NewAddrRequest) XXX_Size() int

func (*NewAddrRequest) XXX_Unmarshal 

func (m *NewAddrRequest) XXX_Unmarshal(b []byte) error

type PushConfigReply 

type PushConfigReply struct {
	JobID                string   `protobuf:"bytes,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushConfigReply) Descriptor 

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

func (*PushConfigReply) GetJobID 

func (m *PushConfigReply) GetJobID() string

func (*PushConfigReply) ProtoMessage 

func (*PushConfigReply) ProtoMessage()

func (*PushConfigReply) Reset 

func (m *PushConfigReply) Reset()

func (*PushConfigReply) String 

func (m *PushConfigReply) String() string

func (*PushConfigReply) XXX_DiscardUnknown 

func (m *PushConfigReply) XXX_DiscardUnknown()

func (*PushConfigReply) XXX_Marshal 

func (m *PushConfigReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushConfigReply) XXX_Merge 

func (m *PushConfigReply) XXX_Merge(src proto.Message)

func (*PushConfigReply) XXX_Size 

func (m *PushConfigReply) XXX_Size() int

func (*PushConfigReply) XXX_Unmarshal 

func (m *PushConfigReply) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*PushConfigRequest) Descriptor 

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

func (*PushConfigRequest) GetCid 

func (m *PushConfigRequest) GetCid() string

func (*PushConfigRequest) GetConfig 

func (m *PushConfigRequest) GetConfig() *CidConfig

func (*PushConfigRequest) GetHasConfig 

func (m *PushConfigRequest) GetHasConfig() bool

func (*PushConfigRequest) GetHasOverrideConfig 

func (m *PushConfigRequest) GetHasOverrideConfig() bool

func (*PushConfigRequest) GetOverrideConfig 

func (m *PushConfigRequest) GetOverrideConfig() bool

func (*PushConfigRequest) ProtoMessage 

func (*PushConfigRequest) ProtoMessage()

func (*PushConfigRequest) Reset 

func (m *PushConfigRequest) Reset()

func (*PushConfigRequest) String 

func (m *PushConfigRequest) String() string

func (*PushConfigRequest) XXX_DiscardUnknown 

func (m *PushConfigRequest) XXX_DiscardUnknown()

func (*PushConfigRequest) XXX_Marshal 

func (m *PushConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushConfigRequest) XXX_Merge 

func (m *PushConfigRequest) XXX_Merge(src proto.Message)

func (*PushConfigRequest) XXX_Size 

func (m *PushConfigRequest) XXX_Size() int

func (*PushConfigRequest) XXX_Unmarshal 

func (m *PushConfigRequest) XXX_Unmarshal(b []byte) error

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

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.ClientConn) 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
}

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 {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveReply) Descriptor 

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

func (*RemoveReply) ProtoMessage 

func (*RemoveReply) ProtoMessage()

func (*RemoveReply) Reset 

func (m *RemoveReply) Reset()

func (*RemoveReply) String 

func (m *RemoveReply) String() string

func (*RemoveReply) XXX_DiscardUnknown 

func (m *RemoveReply) XXX_DiscardUnknown()

func (*RemoveReply) XXX_Marshal 

func (m *RemoveReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveReply) XXX_Merge 

func (m *RemoveReply) XXX_Merge(src proto.Message)

func (*RemoveReply) XXX_Size 

func (m *RemoveReply) XXX_Size() int

func (*RemoveReply) XXX_Unmarshal 

func (m *RemoveReply) XXX_Unmarshal(b []byte) error

type RemoveRequest 

type RemoveRequest struct {
	Cid                  string   `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveRequest) Descriptor 

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

func (*RemoveRequest) GetCid 

func (m *RemoveRequest) GetCid() string

func (*RemoveRequest) ProtoMessage 

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) Reset 

func (m *RemoveRequest) Reset()

func (*RemoveRequest) String 

func (m *RemoveRequest) String() string

func (*RemoveRequest) XXX_DiscardUnknown 

func (m *RemoveRequest) XXX_DiscardUnknown()

func (*RemoveRequest) XXX_Marshal 

func (m *RemoveRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveRequest) XXX_Merge 

func (m *RemoveRequest) XXX_Merge(src proto.Message)

func (*RemoveRequest) XXX_Size 

func (m *RemoveRequest) XXX_Size() int

func (*RemoveRequest) XXX_Unmarshal 

func (m *RemoveRequest) XXX_Unmarshal(b []byte) error

type ReplaceReply 

type ReplaceReply struct {
	JobID                string   `protobuf:"bytes,1,opt,name=jobID,proto3" json:"jobID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplaceReply) Descriptor 

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

func (*ReplaceReply) GetJobID 

func (m *ReplaceReply) GetJobID() string

func (*ReplaceReply) ProtoMessage 

func (*ReplaceReply) ProtoMessage()

func (*ReplaceReply) Reset 

func (m *ReplaceReply) Reset()

func (*ReplaceReply) String 

func (m *ReplaceReply) String() string

func (*ReplaceReply) XXX_DiscardUnknown 

func (m *ReplaceReply) XXX_DiscardUnknown()

func (*ReplaceReply) XXX_Marshal 

func (m *ReplaceReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplaceReply) XXX_Merge 

func (m *ReplaceReply) XXX_Merge(src proto.Message)

func (*ReplaceReply) XXX_Size 

func (m *ReplaceReply) XXX_Size() int

func (*ReplaceReply) XXX_Unmarshal 

func (m *ReplaceReply) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReplaceRequest) Descriptor 

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

func (*ReplaceRequest) GetCid1 

func (m *ReplaceRequest) GetCid1() string

func (*ReplaceRequest) GetCid2 

func (m *ReplaceRequest) GetCid2() string

func (*ReplaceRequest) ProtoMessage 

func (*ReplaceRequest) ProtoMessage()

func (*ReplaceRequest) Reset 

func (m *ReplaceRequest) Reset()

func (*ReplaceRequest) String 

func (m *ReplaceRequest) String() string

func (*ReplaceRequest) XXX_DiscardUnknown 

func (m *ReplaceRequest) XXX_DiscardUnknown()

func (*ReplaceRequest) XXX_Marshal 

func (m *ReplaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReplaceRequest) XXX_Merge 

func (m *ReplaceRequest) XXX_Merge(src proto.Message)

func (*ReplaceRequest) XXX_Size 

func (m *ReplaceRequest) XXX_Size() int

func (*ReplaceRequest) XXX_Unmarshal 

func (m *ReplaceRequest) XXX_Unmarshal(b []byte) error

type SendFilReply 

type SendFilReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendFilReply) Descriptor 

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

func (*SendFilReply) ProtoMessage 

func (*SendFilReply) ProtoMessage()

func (*SendFilReply) Reset 

func (m *SendFilReply) Reset()

func (*SendFilReply) String 

func (m *SendFilReply) String() string

func (*SendFilReply) XXX_DiscardUnknown 

func (m *SendFilReply) XXX_DiscardUnknown()

func (*SendFilReply) XXX_Marshal 

func (m *SendFilReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendFilReply) XXX_Merge 

func (m *SendFilReply) XXX_Merge(src proto.Message)

func (*SendFilReply) XXX_Size 

func (m *SendFilReply) XXX_Size() int

func (*SendFilReply) XXX_Unmarshal 

func (m *SendFilReply) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendFilRequest) Descriptor 

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

func (*SendFilRequest) GetAmount 

func (m *SendFilRequest) GetAmount() int64

func (*SendFilRequest) GetFrom 

func (m *SendFilRequest) GetFrom() string

func (*SendFilRequest) GetTo 

func (m *SendFilRequest) GetTo() string

func (*SendFilRequest) ProtoMessage 

func (*SendFilRequest) ProtoMessage()

func (*SendFilRequest) Reset 

func (m *SendFilRequest) Reset()

func (*SendFilRequest) String 

func (m *SendFilRequest) String() string

func (*SendFilRequest) XXX_DiscardUnknown 

func (m *SendFilRequest) XXX_DiscardUnknown()

func (*SendFilRequest) XXX_Marshal 

func (m *SendFilRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendFilRequest) XXX_Merge 

func (m *SendFilRequest) XXX_Merge(src proto.Message)

func (*SendFilRequest) XXX_Size 

func (m *SendFilRequest) XXX_Size() int

func (*SendFilRequest) XXX_Unmarshal 

func (m *SendFilRequest) XXX_Unmarshal(b []byte) error

type SetDefaultConfigReply 

type SetDefaultConfigReply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetDefaultConfigReply) Descriptor 

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

func (*SetDefaultConfigReply) ProtoMessage 

func (*SetDefaultConfigReply) ProtoMessage()

func (*SetDefaultConfigReply) Reset 

func (m *SetDefaultConfigReply) Reset()

func (*SetDefaultConfigReply) String 

func (m *SetDefaultConfigReply) String() string

func (*SetDefaultConfigReply) XXX_DiscardUnknown 

func (m *SetDefaultConfigReply) XXX_DiscardUnknown()

func (*SetDefaultConfigReply) XXX_Marshal 

func (m *SetDefaultConfigReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetDefaultConfigReply) XXX_Merge 

func (m *SetDefaultConfigReply) XXX_Merge(src proto.Message)

func (*SetDefaultConfigReply) XXX_Size 

func (m *SetDefaultConfigReply) XXX_Size() int

func (*SetDefaultConfigReply) XXX_Unmarshal 

func (m *SetDefaultConfigReply) XXX_Unmarshal(b []byte) error

type SetDefaultConfigRequest 

type SetDefaultConfigRequest struct {
	Config               *DefaultConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*SetDefaultConfigRequest) Descriptor 

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

func (*SetDefaultConfigRequest) GetConfig 

func (m *SetDefaultConfigRequest) GetConfig() *DefaultConfig

func (*SetDefaultConfigRequest) ProtoMessage 

func (*SetDefaultConfigRequest) ProtoMessage()

func (*SetDefaultConfigRequest) Reset 

func (m *SetDefaultConfigRequest) Reset()

func (*SetDefaultConfigRequest) String 

func (m *SetDefaultConfigRequest) String() string

func (*SetDefaultConfigRequest) XXX_DiscardUnknown 

func (m *SetDefaultConfigRequest) XXX_DiscardUnknown()

func (*SetDefaultConfigRequest) XXX_Marshal 

func (m *SetDefaultConfigRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SetDefaultConfigRequest) XXX_Merge 

func (m *SetDefaultConfigRequest) XXX_Merge(src proto.Message)

func (*SetDefaultConfigRequest) XXX_Size 

func (m *SetDefaultConfigRequest) XXX_Size() int

func (*SetDefaultConfigRequest) XXX_Unmarshal 

func (m *SetDefaultConfigRequest) XXX_Unmarshal(b []byte) error

type ShowReply 

type ShowReply struct {
	CidInfo              *CidInfo `protobuf:"bytes,1,opt,name=cidInfo,proto3" json:"cidInfo,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShowReply) Descriptor 

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

func (*ShowReply) GetCidInfo 

func (m *ShowReply) GetCidInfo() *CidInfo

func (*ShowReply) ProtoMessage 

func (*ShowReply) ProtoMessage()

func (*ShowReply) Reset 

func (m *ShowReply) Reset()

func (*ShowReply) String 

func (m *ShowReply) String() string

func (*ShowReply) XXX_DiscardUnknown 

func (m *ShowReply) XXX_DiscardUnknown()

func (*ShowReply) XXX_Marshal 

func (m *ShowReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShowReply) XXX_Merge 

func (m *ShowReply) XXX_Merge(src proto.Message)

func (*ShowReply) XXX_Size 

func (m *ShowReply) XXX_Size() int

func (*ShowReply) XXX_Unmarshal 

func (m *ShowReply) XXX_Unmarshal(b []byte) error

type ShowRequest 

type ShowRequest struct {
	Cid                  string   `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShowRequest) Descriptor 

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

func (*ShowRequest) GetCid 

func (m *ShowRequest) GetCid() string

func (*ShowRequest) ProtoMessage 

func (*ShowRequest) ProtoMessage()

func (*ShowRequest) Reset 

func (m *ShowRequest) Reset()

func (*ShowRequest) String 

func (m *ShowRequest) String() string

func (*ShowRequest) XXX_DiscardUnknown 

func (m *ShowRequest) XXX_DiscardUnknown()

func (*ShowRequest) XXX_Marshal 

func (m *ShowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ShowRequest) XXX_Merge 

func (m *ShowRequest) XXX_Merge(src proto.Message)

func (*ShowRequest) XXX_Size 

func (m *ShowRequest) XXX_Size() int

func (*ShowRequest) XXX_Unmarshal 

func (m *ShowRequest) XXX_Unmarshal(b []byte) error

type UnimplementedRPCServer 

type UnimplementedRPCServer struct {
}

UnimplementedRPCServer can be embedded to have forward compatible implementations.

func (*UnimplementedRPCServer) AddToHot 

func (*UnimplementedRPCServer) AddToHot(srv RPC_AddToHotServer) error

func (*UnimplementedRPCServer) Addrs 

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

func (*UnimplementedRPCServer) Close 

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

func (*UnimplementedRPCServer) Create 

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

func (*UnimplementedRPCServer) DefaultConfig 

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

func (*UnimplementedRPCServer) Get 

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

func (*UnimplementedRPCServer) GetCidConfig 

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

func (*UnimplementedRPCServer) GetDefaultCidConfig 

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

func (*UnimplementedRPCServer) ID 

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

func (*UnimplementedRPCServer) Info 

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

func (*UnimplementedRPCServer) ListAPI 

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

func (*UnimplementedRPCServer) NewAddr 

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

func (*UnimplementedRPCServer) PushConfig 

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

func (*UnimplementedRPCServer) Remove 

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

func (*UnimplementedRPCServer) Replace 

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

func (*UnimplementedRPCServer) SendFil 

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

func (*UnimplementedRPCServer) SetDefaultConfig 

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

func (*UnimplementedRPCServer) Show 

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

func (*UnimplementedRPCServer) WatchJobs 

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

func (*UnimplementedRPCServer) WatchLogs 

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

type WatchJobsReply 

type WatchJobsReply struct {
	Job                  *Job     `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchJobsReply) Descriptor 

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

func (*WatchJobsReply) GetJob 

func (m *WatchJobsReply) GetJob() *Job

func (*WatchJobsReply) ProtoMessage 

func (*WatchJobsReply) ProtoMessage()

func (*WatchJobsReply) Reset 

func (m *WatchJobsReply) Reset()

func (*WatchJobsReply) String 

func (m *WatchJobsReply) String() string

func (*WatchJobsReply) XXX_DiscardUnknown 

func (m *WatchJobsReply) XXX_DiscardUnknown()

func (*WatchJobsReply) XXX_Marshal 

func (m *WatchJobsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchJobsReply) XXX_Merge 

func (m *WatchJobsReply) XXX_Merge(src proto.Message)

func (*WatchJobsReply) XXX_Size 

func (m *WatchJobsReply) XXX_Size() int

func (*WatchJobsReply) XXX_Unmarshal 

func (m *WatchJobsReply) XXX_Unmarshal(b []byte) error

type WatchJobsRequest 

type WatchJobsRequest struct {
	Jids                 []string `protobuf:"bytes,1,rep,name=jids,proto3" json:"jids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchJobsRequest) Descriptor 

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

func (*WatchJobsRequest) GetJids 

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

func (*WatchJobsRequest) ProtoMessage 

func (*WatchJobsRequest) ProtoMessage()

func (*WatchJobsRequest) Reset 

func (m *WatchJobsRequest) Reset()

func (*WatchJobsRequest) String 

func (m *WatchJobsRequest) String() string

func (*WatchJobsRequest) XXX_DiscardUnknown 

func (m *WatchJobsRequest) XXX_DiscardUnknown()

func (*WatchJobsRequest) XXX_Marshal 

func (m *WatchJobsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchJobsRequest) XXX_Merge 

func (m *WatchJobsRequest) XXX_Merge(src proto.Message)

func (*WatchJobsRequest) XXX_Size 

func (m *WatchJobsRequest) XXX_Size() int

func (*WatchJobsRequest) XXX_Unmarshal 

func (m *WatchJobsRequest) XXX_Unmarshal(b []byte) error

type WatchLogsReply 

type WatchLogsReply struct {
	LogEntry             *LogEntry `protobuf:"bytes,1,opt,name=logEntry,proto3" json:"logEntry,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*WatchLogsReply) Descriptor 

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

func (*WatchLogsReply) GetLogEntry 

func (m *WatchLogsReply) GetLogEntry() *LogEntry

func (*WatchLogsReply) ProtoMessage 

func (*WatchLogsReply) ProtoMessage()

func (*WatchLogsReply) Reset 

func (m *WatchLogsReply) Reset()

func (*WatchLogsReply) String 

func (m *WatchLogsReply) String() string

func (*WatchLogsReply) XXX_DiscardUnknown 

func (m *WatchLogsReply) XXX_DiscardUnknown()

func (*WatchLogsReply) XXX_Marshal 

func (m *WatchLogsReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchLogsReply) XXX_Merge 

func (m *WatchLogsReply) XXX_Merge(src proto.Message)

func (*WatchLogsReply) XXX_Size 

func (m *WatchLogsReply) XXX_Size() int

func (*WatchLogsReply) XXX_Unmarshal 

func (m *WatchLogsReply) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WatchLogsRequest) Descriptor 

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

func (*WatchLogsRequest) GetCid 

func (m *WatchLogsRequest) GetCid() string

func (*WatchLogsRequest) GetHistory 

func (m *WatchLogsRequest) GetHistory() bool

func (*WatchLogsRequest) GetJid 

func (m *WatchLogsRequest) GetJid() string

func (*WatchLogsRequest) ProtoMessage 

func (*WatchLogsRequest) ProtoMessage()

func (*WatchLogsRequest) Reset 

func (m *WatchLogsRequest) Reset()

func (*WatchLogsRequest) String 

func (m *WatchLogsRequest) String() string

func (*WatchLogsRequest) XXX_DiscardUnknown 

func (m *WatchLogsRequest) XXX_DiscardUnknown()

func (*WatchLogsRequest) XXX_Marshal 

func (m *WatchLogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WatchLogsRequest) XXX_Merge 

func (m *WatchLogsRequest) XXX_Merge(src proto.Message)

func (*WatchLogsRequest) XXX_Size 

func (m *WatchLogsRequest) XXX_Size() int

func (*WatchLogsRequest) XXX_Unmarshal 

func (m *WatchLogsRequest) XXX_Unmarshal(b []byte) error

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.