knodemanager

type CommonResp struct {
	Status ErrorCode
}

type Config struct {
	config.Saver

	// Host/Port for the IPFS daemon.
	NodeAddr []ma.Multiaddr

	// ConnectSwarmsDelay specifies how long to wait after startup before
	// attempting to open connections from this peer's IPFS daemon to the
	// IPFS daemons of other peers.
	ConnectSwarmsDelay time.Duration

	// knode Daemon HTTP Client POST timeout
	KnodeRequestTimeout time.Duration

	// Pin Operation timeout
	PinTimeout time.Duration

	// Unpin Operation timeout
	UnpinTimeout time.Duration

	// RepoGC Operation timeout
	RepoGCTimeout time.Duration

	// How many pin and block/put operations need to happen before we do a
	// special broadcast informer metrics to the network. 0 to disable.
	InformerTriggerInterval int

	// Disables the unpin operation and returns an error.
	UnpinDisable bool

	// Tracing flag used to skip tracing specific paths when not enabled.
	Tracing bool
}

type ErrorCode int

type IpfsIDResp struct {
	ID        peer.ID  `json:"id,omitempty" codec:"i,omitempty"`
	Addresses []string `json:"addresses" codec:"a,omitempty"`
	Error     string   `json:"error" codec:"e,omitempty"`
}

type Knode struct {
	PeerID  peer.ID
	Version string
	Ip      string
	Port    string
	// contains filtered or unexported fields
}

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

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

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

type NodeStatus int

type PinArgs struct {
	Operation string
	Cid       string
	Param     url.Values
}

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

type PinLsArgs struct {
	Operation string
	Param     url.Values
	Cid       string //如果为空就查询所有 pin ls

}

type PinLsResp struct {
	Pins []api.IPFSPinInfo
}

type PinResp struct {
	PinStatus api.IPFSPinStatus
	Pins      []api.IPFSPinInfo
}

type RMMetric struct {
	Name          string
	Peer          peer.ID           //RM节点id
	Group         string            //该RM节点所属分组
	Tag           string            //标签，与分组一样，用于节点分配
	Value         string            //RM管理的所有knode总可用空间
	Expire        int64             //本条信息过期时间
	Valid         bool              //是否可用，既该节点是否可分配
	Weight        int64             //权重
	Partitionable bool              //是否可分区（暂不明白用法）
	ReceivedAt    int64             //时间
	KnodeList     []api.KnodeMetric //  该RM管理下的knode列表）
}

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

type RawIPFSPinInfo struct {
	PeerId  string    `json:"PeerId" codec:"peerId"`
	Cid     string    `json:"Cid" codec:"cid"`
	Type    string    `json:"Type" codec:"type"`
	Message string    `json:"Message" codec:"message"`
	Code    int       `json:"Code" codec:"code"`
	Pins    []string  `json:"Pins" codec:"pins"`
	Status  ErrorCode `json:"Status" codec:"status"`
}

type RegisArgs struct {
	PeerID  string
	Version string
	Ip      string
	Port    string
}

type UploadFileArgs struct {
	PeerID  string //节点id
	OrderID string //controller上传订单号
	Cid     string // cid
	Name    string //file name
	Fid     string //文件id
	Region  string
	Origins string
}