client

package

v0.0.15 Latest Latest Go to latest Published: Apr 11, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/CESSProject/sdk-go

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func ExtractSegmenthash(segment []SegmentInfo) []string
type Cli
type Client
- func NewBasicCli(rpc []string, name, phase, workspace, addr string, port int, ...) (Client, error)
type SegmentInfo

Constants ¶

View Source

const PrivatekeyFile = ".private"

Variables ¶

This section is empty.

Functions ¶

func ExtractSegmenthash ¶

func ExtractSegmenthash(segment []SegmentInfo) []string

Types ¶

type Cli ¶

type Cli struct {
	chain.Chain
	*protocol.Protocol
}

func (*Cli) CheckBucketName ¶ added in v0.0.2

func (c *Cli) CheckBucketName(bucketname string) bool

func (*Cli) CreateBucket ¶

func (c *Cli) CreateBucket(owner []byte, bucketname string) (string, error)

func (*Cli) DeleteBucket ¶

func (c *Cli) DeleteBucket(owner []byte, bucketName string) (string, error)

func (*Cli) DeleteFile ¶

func (c *Cli) DeleteFile(owner []byte, roothash string) (string, chain.FileHash, error)

func (*Cli) GenerateStorageOrder ¶

func (c *Cli) GenerateStorageOrder(roothash string, segment []SegmentInfo, owner []byte, filename, buckname string) error

func (*Cli) ProcessingData ¶

func (c *Cli) ProcessingData(path string) ([]SegmentInfo, string, error)

func (*Cli) PutFile ¶

func (c *Cli) PutFile(owner []byte, segmentInfo []SegmentInfo, roothash, filename, bucketname string) (string, error)

func (*Cli) QueryAssignedMiner ¶

func (c *Cli) QueryAssignedMiner(minerTaskList []chain.MinerTaskList) ([]string, error)

func (*Cli) QueryBucket ¶

func (c *Cli) QueryBucket(owner []byte, bucketname string) (chain.BucketInfo, error)

func (*Cli) QueryBuckets ¶

func (c *Cli) QueryBuckets(owner []byte) ([]string, error)

func (*Cli) QueryDeoss ¶

func (c *Cli) QueryDeoss(pubkey []byte) (string, error)

func (*Cli) QueryFile ¶

func (c *Cli) QueryFile(roothash string) (chain.FileMetaInfo, error)

func (*Cli) QueryGrantor ¶ added in v0.0.2

func (c *Cli) QueryGrantor(pubkey []byte) (bool, error)

func (*Cli) QueryStorageMiner ¶

func (c *Cli) QueryStorageMiner(pubkey []byte) (chain.MinerInfo, error)

func (*Cli) QueryStorageOrder ¶ added in v0.0.15

func (c *Cli) QueryStorageOrder(roothash string) (chain.StorageOrder, error)

func (*Cli) Register ¶

func (c *Cli) Register(name string, income string, pledge uint64) (string, error)

func (*Cli) ReportFile ¶ added in v0.0.13

func (c *Cli) ReportFile(roothash []string) (string, []chain.FileHash, error)

func (*Cli) StorageData ¶

func (c *Cli) StorageData(roothash string, segment []SegmentInfo, minerTaskList []chain.MinerTaskList) error

func (*Cli) SubmitIdleFile ¶ added in v0.0.6

func (c *Cli) SubmitIdleFile(size uint64, blockNum, blocksize, scansize uint32, pubkey []byte, hash string) (string, error)

func (*Cli) Update ¶ added in v0.0.5

func (c *Cli) Update(name string) (string, error)

func (*Cli) Workspace ¶ added in v0.0.4

func (c *Cli) Workspace() string

type Client ¶

type Client interface {
	Workspace() string
	Register(name string, income string, pledge uint64) (string, error)
	QueryStorageMiner(pubkey []byte) (chain.MinerInfo, error)
	QueryDeoss(pubkey []byte) (string, error)
	QueryFile(roothash string) (chain.FileMetaInfo, error)
	QueryBucket(owner []byte, bucketname string) (chain.BucketInfo, error)
	QueryBuckets(owner []byte) ([]string, error)
	QueryGrantor(pubkey []byte) (bool, error)
	QueryStorageOrder(roothash string) (chain.StorageOrder, error)
	CheckBucketName(bucketname string) bool
	CreateBucket(owner []byte, bucketname string) (string, error)
	ProcessingData(path string) ([]SegmentInfo, string, error)
	PutFile(owner []byte, segmentInfo []SegmentInfo, roothash, filename, bucketname string) (string, error)
	DeleteFile(owner []byte, roothash string) (string, chain.FileHash, error)
	DeleteBucket(owner []byte, bucketName string) (string, error)
	Update(name string) (string, error)
	SubmitIdleFile(size uint64, blockNum, blocksize, scansize uint32, pubkey []byte, hash string) (string, error)
	ReportFile(roothash []string) (string, []chain.FileHash, error)
}

func NewBasicCli ¶

func NewBasicCli(rpc []string, name, phase, workspace, addr string, port int, timeout time.Duration) (Client, error)

type SegmentInfo ¶

type SegmentInfo struct {
	SegmentHash  string
	FragmentHash []string
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL