Documentation ¶
Index ¶
- type AdminClient
- type Client
- type FileInfo
- type KeyValue
- type KvClient
- func (c *KvClient) GetFirst(streamId common.Hash, startIndex, length uint64, version ...uint64) (val *KeyValue, err error)
- func (c *KvClient) GetHoldingStreamIds() (streamIds []common.Hash, err error)
- func (c *KvClient) GetLast(streamId common.Hash, startIndex, length uint64, version ...uint64) (val *KeyValue, err error)
- func (c *KvClient) GetNext(streamId common.Hash, key []byte, startIndex, length uint64, inclusive bool, ...) (val *KeyValue, err error)
- func (c *KvClient) GetPrev(streamId common.Hash, key []byte, startIndex, length uint64, inclusive bool, ...) (val *KeyValue, err error)
- func (c *KvClient) GetTransactionResult(txSeq uint64) (result string, err error)
- func (c *KvClient) GetValue(streamId common.Hash, key []byte, startIndex, length uint64, version ...uint64) (val *Value, err error)
- func (c *KvClient) HasWritePermission(account common.Address, streamId common.Hash, key []byte, version ...uint64) (hasPermission bool, err error)
- func (c *KvClient) IsAdmin(account common.Address, streamId common.Hash, version ...uint64) (isAdmin bool, err error)
- func (c *KvClient) IsSpecialKey(streamId common.Hash, key []byte, version ...uint64) (isSpecialKey bool, err error)
- func (c *KvClient) IsWriterOfKey(account common.Address, streamId common.Hash, key []byte, version ...uint64) (isWriter bool, err error)
- func (c *KvClient) IsWriterOfStream(account common.Address, streamId common.Hash, version ...uint64) (isWriter bool, err error)
- type SegmentWithProof
- type Status
- type Transaction
- type Value
- type ZeroGStorageClient
- func (c *ZeroGStorageClient) DownloadSegment(root common.Hash, startIndex, endIndex uint64) (data []byte, err error)
- func (c *ZeroGStorageClient) DownloadSegmentWithProof(root common.Hash, index uint64) (segment *SegmentWithProof, err error)
- func (c *ZeroGStorageClient) GetFileInfo(root common.Hash) (file *FileInfo, err error)
- func (c *ZeroGStorageClient) GetFileInfoByTxSeq(txSeq uint64) (file *FileInfo, err error)
- func (c *ZeroGStorageClient) GetStatus() (status Status, err error)
- func (c *ZeroGStorageClient) UploadSegment(segment SegmentWithProof) (ret int, err error)
- func (c *ZeroGStorageClient) UploadSegments(segments []SegmentWithProof) (ret int, err error)
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(txSeq uint64) (status string, err error)
func (*AdminClient) Shutdown ¶
func (c *AdminClient) Shutdown() (ret int, err error)
func (*AdminClient) StartSyncFile ¶
func (c *AdminClient) StartSyncFile(txSeq uint64) (ret int, err error)
type Client ¶
type Client struct { *providers.MiddlewarableProvider // contains filtered or unexported fields }
func (*Client) Admin ¶
func (c *Client) Admin() *AdminClient
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 KvClient ¶
type KvClient struct {
// contains filtered or unexported fields
}
func (*KvClient) GetHoldingStreamIds ¶
func (*KvClient) GetTransactionResult ¶
func (*KvClient) HasWritePermission ¶
func (*KvClient) IsSpecialKey ¶
func (*KvClient) IsWriterOfKey ¶
type SegmentWithProof ¶
type Transaction ¶
type ZeroGStorageClient ¶
type ZeroGStorageClient struct {
// contains filtered or unexported fields
}
ZeroGStorage RPCs
func (*ZeroGStorageClient) DownloadSegment ¶
func (*ZeroGStorageClient) DownloadSegmentWithProof ¶
func (c *ZeroGStorageClient) DownloadSegmentWithProof(root common.Hash, index uint64) (segment *SegmentWithProof, err error)
func (*ZeroGStorageClient) GetFileInfo ¶
func (c *ZeroGStorageClient) GetFileInfo(root common.Hash) (file *FileInfo, err error)
func (*ZeroGStorageClient) GetFileInfoByTxSeq ¶
func (c *ZeroGStorageClient) GetFileInfoByTxSeq(txSeq uint64) (file *FileInfo, err error)
func (*ZeroGStorageClient) GetStatus ¶
func (c *ZeroGStorageClient) GetStatus() (status Status, err error)
func (*ZeroGStorageClient) UploadSegment ¶
func (c *ZeroGStorageClient) UploadSegment(segment SegmentWithProof) (ret int, err error)
func (*ZeroGStorageClient) UploadSegments ¶
func (c *ZeroGStorageClient) UploadSegments(segments []SegmentWithProof) (ret int, err error)
Click to show internal directories.
Click to hide internal directories.