node

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Jul 5, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AdminClient 

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

Admin RPCs

func (*AdminClient) GetSyncStatus 

func (c *AdminClient) GetSyncStatus(ctx context.Context, txSeq uint64) (status string, err error)

func (*AdminClient) Shutdown 

func (c *AdminClient) Shutdown(ctx context.Context) (ret int, err error)

func (*AdminClient) StartSyncFile 

func (c *AdminClient) StartSyncFile(ctx context.Context, txSeq uint64) (ret int, err error)

type Client 

type Client struct {
	*providers.MiddlewarableProvider
	// contains filtered or unexported fields
}

func MustNewClient 

func MustNewClient(url string, option ...providers.Option) *Client

func MustNewClients 

func MustNewClients(urls []string, option ...providers.Option) []*Client

func NewClient 

func NewClient(url string, option ...providers.Option) (*Client, error)

func (*Client) Admin 

func (c *Client) Admin() *AdminClient

func (*Client) KV 

func (c *Client) KV() *KvClient

func (*Client) URL 

func (c *Client) URL() string

func (*Client) ZeroGStorage 

func (c *Client) ZeroGStorage() *ZeroGStorageClient

type FileInfo 

type FileInfo struct {
	Tx             Transaction `json:"tx"`
	Finalized      bool        `json:"finalized"`
	IsCached       bool        `json:"isCached"`
	UploadedSegNum uint64      `json:"uploadedSegNum"`
}

type KeyValue 

type KeyValue struct {
	Version uint64 `json:"version"` // key version
	Key     []byte `json:"key"`     // value key
	Data    []byte `json:"data"`    // value data
	Size    uint64 `json:"size"`    // value total size
}

type KvClient 

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

func (*KvClient) GetFirst 

func (c *KvClient) GetFirst(ctx context.Context, streamId common.Hash, startIndex, length uint64, version ...uint64) (val *KeyValue, err error)

func (*KvClient) GetHoldingStreamIds 

func (c *KvClient) GetHoldingStreamIds(ctx context.Context) (streamIds []common.Hash, err error)

func (*KvClient) GetLast 

func (c *KvClient) GetLast(ctx context.Context, streamId common.Hash, startIndex, length uint64, version ...uint64) (val *KeyValue, err error)

func (*KvClient) GetNext 

func (c *KvClient) GetNext(ctx context.Context, streamId common.Hash, key []byte, startIndex, length uint64, inclusive bool, version ...uint64) (val *KeyValue, err error)

func (*KvClient) GetPrev 

func (c *KvClient) GetPrev(ctx context.Context, streamId common.Hash, key []byte, startIndex, length uint64, inclusive bool, version ...uint64) (val *KeyValue, err error)

func (*KvClient) GetTransactionResult 

func (c *KvClient) GetTransactionResult(ctx context.Context, txSeq uint64) (result string, err error)

func (*KvClient) GetValue 

func (c *KvClient) GetValue(ctx context.Context, streamId common.Hash, key []byte, startIndex, length uint64, version ...uint64) (val *Value, err error)

func (*KvClient) HasWritePermission 

func (c *KvClient) HasWritePermission(ctx context.Context, account common.Address, streamId common.Hash, key []byte, version ...uint64) (hasPermission bool, err error)

func (*KvClient) IsAdmin 

func (c *KvClient) IsAdmin(ctx context.Context, account common.Address, streamId common.Hash, version ...uint64) (isAdmin bool, err error)

func (*KvClient) IsSpecialKey 

func (c *KvClient) IsSpecialKey(ctx context.Context, streamId common.Hash, key []byte, version ...uint64) (isSpecialKey bool, err error)

func (*KvClient) IsWriterOfKey 

func (c *KvClient) IsWriterOfKey(ctx context.Context, account common.Address, streamId common.Hash, key []byte, version ...uint64) (isWriter bool, err error)

func (*KvClient) IsWriterOfStream 

func (c *KvClient) IsWriterOfStream(ctx context.Context, account common.Address, streamId common.Hash, version ...uint64) (isWriter bool, err error)

type SegmentWithProof 

type SegmentWithProof struct {
	Root     common.Hash  `json:"root"`     // file merkle root
	Data     []byte       `json:"data"`     // segment data
	Index    uint64       `json:"index"`    // segment index
	Proof    merkle.Proof `json:"proof"`    // segment merkle proof
	FileSize uint64       `json:"fileSize"` // file size
}

type ShardConfig added in v0.2.0 

type ShardConfig struct {
	ShardId  uint64 `json:"shardId"`
	NumShard uint64 `json:"numShard"`
}

func (*ShardConfig) HasSegment added in v0.3.0 

func (config *ShardConfig) HasSegment(segmentIndex uint64) bool

func (*ShardConfig) IsValid added in v0.3.0 

func (config *ShardConfig) IsValid() bool

type Status 

type Status struct {
	ConnectedPeers uint        `json:"connectedPeers"`
	LogSyncHeight  uint64      `json:"logSyncHeight"`
	LogSyncBlock   common.Hash `json:"logSyncBlock"`
}

type Transaction 

type Transaction struct {
	StreamIds       []*hexutil.Big `json:"streamIds"`
	Data            []byte         `json:"data"` // in-place data
	DataMerkleRoot  common.Hash    `json:"dataMerkleRoot"`
	StartEntryIndex uint64         `json:"startEntryIndex"`
	Size            uint64         `json:"size"` // file size in bytes
	Seq             uint64         `json:"seq"`
}

type Value 

type Value struct {
	Version uint64 `json:"version"` // key version
	Data    []byte `json:"data"`    // value data
	Size    uint64 `json:"size"`    // value total size
}

type ZeroGStorageClient 

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

ZeroGStorage RPCs

func (*ZeroGStorageClient) DownloadSegment 

func (c *ZeroGStorageClient) DownloadSegment(ctx context.Context, root common.Hash, startIndex, endIndex uint64) (data []byte, err error)

func (*ZeroGStorageClient) DownloadSegmentWithProof 

func (c *ZeroGStorageClient) DownloadSegmentWithProof(ctx context.Context, root common.Hash, index uint64) (segment *SegmentWithProof, err error)

func (*ZeroGStorageClient) GetFileInfo 

func (c *ZeroGStorageClient) GetFileInfo(ctx context.Context, root common.Hash) (file *FileInfo, err error)

func (*ZeroGStorageClient) GetFileInfoByTxSeq 

func (c *ZeroGStorageClient) GetFileInfoByTxSeq(ctx context.Context, txSeq uint64) (file *FileInfo, err error)

func (*ZeroGStorageClient) GetShardConfig added in v0.2.0 

func (c *ZeroGStorageClient) GetShardConfig(ctx context.Context) (shardConfig ShardConfig, err error)

func (*ZeroGStorageClient) GetStatus 

func (c *ZeroGStorageClient) GetStatus(ctx context.Context) (status Status, err error)

func (*ZeroGStorageClient) UploadSegment 

func (c *ZeroGStorageClient) UploadSegment(ctx context.Context, segment SegmentWithProof) (ret int, err error)

func (*ZeroGStorageClient) UploadSegments 

func (c *ZeroGStorageClient) UploadSegments(ctx context.Context, segments []SegmentWithProof) (ret int, err 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.