node

Sep 13, 2024

Changes in this version

+ type NetworkIdentity struct

+ ChainId uint64

+ FlowContractAddress common.Address

+ NetworkProtocolVersion NetworkProtocolVersion

+ type NetworkProtocolVersion struct

+ Build uint8

+ Major uint8

+ Minor uint8

type Status

+ NetworkIdentity NetworkIdentity

Aug 17, 2024

Changes in this version

+ type RPCError struct

+ Message string

+ Method string

+ URL string

+ func (e *RPCError) Error() string

Jul 29, 2024

Changes in this version

type AdminClient

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

+ func (c *AdminClient) GetFileLocation(ctx context.Context, txSeq uint64, allShards bool) (locations []LocationInfo, err error)

+ type LocationInfo struct

+ Ip string

+ ShardConfig shard.ShardConfig

Jul 18, 2024

Changes in this version

type AdminClient

+ func MustNewAdminClient(url string, option ...providers.Option) *AdminClient

+ func NewAdminClient(url string, option ...providers.Option) (*AdminClient, error)

+ func (c *AdminClient) GetNetworkInfo(ctx context.Context) (info NetworkInfo, err error)

+ func (c *AdminClient) GetPeers(ctx context.Context) (peers map[string]*PeerInfo, err error)

+ func (c *AdminClient) GetSyncInfo(ctx context.Context, tx_seq ...uint64) (files map[uint64]FileSyncInfo, err error)

+ func (c *AdminClient) StartSyncChunks(ctx context.Context, txSeq, startIndex, endIndex uint64) (ret int, err error)

+ func (c *AdminClient) TerminateSync(ctx context.Context, txSeq uint64) (terminated bool, err error)

+ func (c AdminClient) Close()

+ func (c AdminClient) URL() string

+ type ClientInfo struct

+ Agent string

+ OS string

+ Protocol string

+ Version string

+ type FileSyncGoal struct

+ IndexEnd uint64

+ IndexStart uint64

+ NumChunks uint64

+ type FileSyncInfo struct

+ ElapsedSecs uint64

+ Goal FileSyncGoal

+ NextChunks uint64

+ Peers map[PeerState]uint64

+ State string

type KvClient

+ func MustNewKvClient(url string, option ...providers.Option) *KvClient

+ func NewKvClient(url string, option ...providers.Option) (*KvClient, error)

+ func (c KvClient) Close()

+ func (c KvClient) URL() string

+ type NetworkInfo struct

+ BannedPeers uint64

+ ConnectedIncomingPeers uint64

+ ConnectedOutgoingPeers uint64

+ ConnectedPeers uint64

+ DisconnectedPeers uint64

+ ListenAddresses []string

+ PeerId string

+ TotalPeers uint64

+ type PeerConnectionStatus struct

+ ConnectionsIn uint8

+ ConnectionsOut uint8

+ LastSeenSecs uint64

+ Status string

+ type PeerInfo struct

+ Client ClientInfo

+ ConnectionDirection string

+ ConnectionStatus PeerConnectionStatus

+ Enr string

+ IsTrusted bool

+ ListeningAddresses []string

+ SeenIps []string

+ type PeerState string

+ const PeerStateConnected

+ const PeerStateConnecting

+ const PeerStateDisconnected

+ const PeerStateDisconnecting

+ const PeerStateFound

+ type ZgsClient struct

+ func MustNewZgsClient(url string, option ...providers.Option) *ZgsClient

+ func MustNewZgsClients(urls []string, option ...providers.Option) []*ZgsClient

+ func NewZgsClient(url string, option ...providers.Option) (*ZgsClient, error)

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

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

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

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

+ func (c *ZgsClient) GetShardConfig(ctx context.Context) (shardConfig shard.ShardConfig, err error)

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

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

+ func (c *ZgsClient) UploadSegments(ctx context.Context, segments []SegmentWithProof) (ret int, err error)

+ func (c ZgsClient) Close()

+ func (c ZgsClient) URL() string

Jul 5, 2024

Changes in this version

type ShardConfig

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

+ func (config *ShardConfig) IsValid() bool

Jun 7, 2024

Changes in this version

+ type ShardConfig struct

+ NumShard uint64

+ ShardId uint64

type ZeroGStorageClient

+ func (c *ZeroGStorageClient) GetShardConfig() (shardConfig *ShardConfig, err error)

Mar 10, 2024

Changes in this version

+ type AdminClient struct

+ func (c *AdminClient) GetSyncStatus(txSeq uint64) (status string, err error)

+ func (c *AdminClient) Shutdown() (ret int, err error)

+ func (c *AdminClient) StartSyncFile(txSeq uint64) (ret int, err error)

+ type Client struct

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

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

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

+ func (c *Client) Admin() *AdminClient

+ func (c *Client) KV() *KvClient

+ func (c *Client) URL() string

+ func (c *Client) ZeroGStorage() *ZeroGStorageClient

+ type FileInfo struct

+ Finalized bool

+ IsCached bool

+ Tx Transaction

+ UploadedSegNum uint64

+ type KeyValue struct

+ Data []byte

+ Key []byte

+ Size uint64

+ Version uint64

+ type KvClient struct

+ 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 struct

+ Data []byte

+ FileSize uint64

+ Index uint64

+ Proof merkle.Proof

+ Root common.Hash

+ type Status struct

+ ConnectedPeers uint

+ LogSyncBlock common.Hash

+ LogSyncHeight uint64

+ type Transaction struct

+ Data []byte

+ DataMerkleRoot common.Hash

+ Seq uint64

+ Size uint64

+ StartEntryIndex uint64

+ StreamIds []*hexutil.Big

+ type Value struct

+ Data []byte

+ Size uint64

+ Version uint64

+ type ZeroGStorageClient struct

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