Versions in this module Expand all Collapse all v2 v2.14.0 Oct 17, 2022 Changes in this version + type NetMap struct + func (x *NetMap) Epoch() uint64 + func (x *NetMap) FromGRPCMessage(m grpc.Message) error + func (x *NetMap) Nodes() []NodeInfo + func (x *NetMap) SetEpoch(v uint64) + func (x *NetMap) SetNodes(v []NodeInfo) + func (x *NetMap) StableMarshal(buf []byte) []byte + func (x *NetMap) StableSize() (size int) + func (x *NetMap) ToGRPCMessage() grpc.Message type NodeState + const Maintenance + type SnapshotRequest struct + func (x *SnapshotRequest) FromGRPCMessage(m grpc.Message) error + func (x *SnapshotRequest) GetBody() *SnapshotRequestBody + func (x *SnapshotRequest) SetBody(body *SnapshotRequestBody) + func (x *SnapshotRequest) ToGRPCMessage() grpc.Message + type SnapshotRequestBody struct + func (x *SnapshotRequestBody) FromGRPCMessage(m grpc.Message) error + func (x *SnapshotRequestBody) StableMarshal([]byte) []byte + func (x *SnapshotRequestBody) StableSize() int + func (x *SnapshotRequestBody) ToGRPCMessage() grpc.Message + type SnapshotResponse struct + func (x *SnapshotResponse) FromGRPCMessage(m grpc.Message) error + func (x *SnapshotResponse) GetBody() *SnapshotResponseBody + func (x *SnapshotResponse) SetBody(body *SnapshotResponseBody) + func (x *SnapshotResponse) ToGRPCMessage() grpc.Message + type SnapshotResponseBody struct + func (x *SnapshotResponseBody) FromGRPCMessage(m grpc.Message) error + func (x *SnapshotResponseBody) NetMap() *NetMap + func (x *SnapshotResponseBody) SetNetMap(netMap *NetMap) + func (x *SnapshotResponseBody) StableMarshal(buf []byte) []byte + func (x *SnapshotResponseBody) StableSize() (size int) + func (x *SnapshotResponseBody) ToGRPCMessage() grpc.Message v2.13.1 Aug 1, 2022 v2.13.0 Jul 4, 2022 v2.12.2 Jun 3, 2022 v2.12.1 Mar 15, 2022 v2.12.0 Feb 25, 2022retracted v2.11.1 Dec 28, 2021 v2.11.0 Dec 2, 2021 Changes in this version + var ErrRemoveSubnet = errors.New("remove subnet") + func AttributesToGRPC(as []*Attribute) (res []*netmap.NodeInfo_Attribute) + func ClauseToGRPCMessage(n Clause) netmap.Clause + func FiltersToGRPC(fs []*Filter) (res []*netmap.Filter) + func IterateSubnets(node *NodeInfo, f func(refs.SubnetID) error) error + func NodeStateToGRPCMessage(n NodeState) netmap.NodeInfo_State + func OperationToGRPCMessage(n Operation) netmap.Operation + func ReplicasToGRPC(rs []*Replica) (res []*netmap.Replica) + func SelectorsToGRPC(ss []*Selector) (res []*netmap.Selector) + func WriteSubnetInfo(node *NodeInfo, info NodeSubnetInfo) + type Attribute struct + func AttributesFromGRPC(as []*netmap.NodeInfo_Attribute) (res []*Attribute, err error) + func (a *Attribute) FromGRPCMessage(m grpc.Message) error + func (a *Attribute) GetKey() string + func (a *Attribute) GetParents() []string + func (a *Attribute) GetValue() string + func (a *Attribute) MarshalJSON() ([]byte, error) + func (a *Attribute) SetKey(v string) + func (a *Attribute) SetParents(parent []string) + func (a *Attribute) SetValue(v string) + func (a *Attribute) StableMarshal(buf []byte) ([]byte, error) + func (a *Attribute) StableSize() (size int) + func (a *Attribute) ToGRPCMessage() grpc.Message + func (a *Attribute) Unmarshal(data []byte) error + func (a *Attribute) UnmarshalJSON(data []byte) error + type Clause uint32 + const Distinct + const Same + const UnspecifiedClause + func ClauseFromGRPCMessage(n netmap.Clause) Clause + func (x *Clause) FromString(s string) bool + func (x Clause) String() string + type Filter struct + func FiltersFromGRPC(fs []*netmap.Filter) (res []*Filter, err error) + func (f *Filter) FromGRPCMessage(m grpc.Message) error + func (f *Filter) GetFilters() []*Filter + func (f *Filter) GetKey() string + func (f *Filter) GetName() string + func (f *Filter) GetOp() Operation + func (f *Filter) GetValue() string + func (f *Filter) MarshalJSON() ([]byte, error) + func (f *Filter) SetFilters(filters []*Filter) + func (f *Filter) SetKey(key string) + func (f *Filter) SetName(name string) + func (f *Filter) SetOp(op Operation) + func (f *Filter) SetValue(value string) + func (f *Filter) StableMarshal(buf []byte) ([]byte, error) + func (f *Filter) StableSize() (size int) + func (f *Filter) ToGRPCMessage() grpc.Message + func (f *Filter) Unmarshal(data []byte) error + func (f *Filter) UnmarshalJSON(data []byte) error + type LocalNodeInfoRequest struct + func (l *LocalNodeInfoRequest) FromGRPCMessage(m grpc.Message) error + func (l *LocalNodeInfoRequest) GetBody() *LocalNodeInfoRequestBody + func (l *LocalNodeInfoRequest) SetBody(body *LocalNodeInfoRequestBody) + func (l *LocalNodeInfoRequest) ToGRPCMessage() grpc.Message + type LocalNodeInfoRequestBody struct + func (l *LocalNodeInfoRequestBody) FromGRPCMessage(m grpc.Message) error + func (l *LocalNodeInfoRequestBody) StableMarshal(buf []byte) ([]byte, error) + func (l *LocalNodeInfoRequestBody) StableSize() (size int) + func (l *LocalNodeInfoRequestBody) ToGRPCMessage() grpc.Message + func (l *LocalNodeInfoRequestBody) Unmarshal([]byte) error + type LocalNodeInfoResponse struct + func (l *LocalNodeInfoResponse) FromGRPCMessage(m grpc.Message) error + func (l *LocalNodeInfoResponse) GetBody() *LocalNodeInfoResponseBody + func (l *LocalNodeInfoResponse) SetBody(body *LocalNodeInfoResponseBody) + func (l *LocalNodeInfoResponse) ToGRPCMessage() grpc.Message + type LocalNodeInfoResponseBody struct + func (l *LocalNodeInfoResponseBody) FromGRPCMessage(m grpc.Message) error + func (l *LocalNodeInfoResponseBody) GetNodeInfo() *NodeInfo + func (l *LocalNodeInfoResponseBody) GetVersion() *refs.Version + func (l *LocalNodeInfoResponseBody) SetNodeInfo(nodeInfo *NodeInfo) + func (l *LocalNodeInfoResponseBody) SetVersion(version *refs.Version) + func (l *LocalNodeInfoResponseBody) StableMarshal(buf []byte) ([]byte, error) + func (l *LocalNodeInfoResponseBody) StableSize() (size int) + func (l *LocalNodeInfoResponseBody) ToGRPCMessage() grpc.Message + func (l *LocalNodeInfoResponseBody) Unmarshal(data []byte) error + type NetworkConfig struct + func (x *NetworkConfig) FromGRPCMessage(m grpc.Message) error + func (x *NetworkConfig) IterateParameters(f func(*NetworkParameter) bool) + func (x *NetworkConfig) NumberOfParameters() int + func (x *NetworkConfig) SetParameters(v ...*NetworkParameter) + func (x *NetworkConfig) StableMarshal(buf []byte) ([]byte, error) + func (x *NetworkConfig) StableSize() (size int) + func (x *NetworkConfig) ToGRPCMessage() grpc.Message + type NetworkInfo struct + func (i *NetworkInfo) FromGRPCMessage(m grpc.Message) error + func (i *NetworkInfo) GetCurrentEpoch() uint64 + func (i *NetworkInfo) GetMagicNumber() uint64 + func (i *NetworkInfo) GetMsPerBlock() int64 + func (i *NetworkInfo) GetNetworkConfig() *NetworkConfig + func (i *NetworkInfo) MarshalJSON() ([]byte, error) + func (i *NetworkInfo) SetCurrentEpoch(epoch uint64) + func (i *NetworkInfo) SetMagicNumber(magic uint64) + func (i *NetworkInfo) SetMsPerBlock(v int64) + func (i *NetworkInfo) SetNetworkConfig(v *NetworkConfig) + func (i *NetworkInfo) StableMarshal(buf []byte) ([]byte, error) + func (i *NetworkInfo) StableSize() (size int) + func (i *NetworkInfo) ToGRPCMessage() grpc.Message + func (i *NetworkInfo) Unmarshal(data []byte) error + func (i *NetworkInfo) UnmarshalJSON(data []byte) error + type NetworkInfoRequest struct + func (l *NetworkInfoRequest) FromGRPCMessage(m grpc.Message) error + func (l *NetworkInfoRequest) GetBody() *NetworkInfoRequestBody + func (l *NetworkInfoRequest) SetBody(body *NetworkInfoRequestBody) + func (l *NetworkInfoRequest) ToGRPCMessage() grpc.Message + type NetworkInfoRequestBody struct + func (l *NetworkInfoRequestBody) FromGRPCMessage(m grpc.Message) error + func (l *NetworkInfoRequestBody) StableMarshal(buf []byte) ([]byte, error) + func (l *NetworkInfoRequestBody) StableSize() (size int) + func (l *NetworkInfoRequestBody) ToGRPCMessage() grpc.Message + func (l *NetworkInfoRequestBody) Unmarshal(data []byte) error + type NetworkInfoResponse struct + func (l *NetworkInfoResponse) FromGRPCMessage(m grpc.Message) error + func (l *NetworkInfoResponse) GetBody() *NetworkInfoResponseBody + func (l *NetworkInfoResponse) SetBody(body *NetworkInfoResponseBody) + func (l *NetworkInfoResponse) ToGRPCMessage() grpc.Message + type NetworkInfoResponseBody struct + func (i *NetworkInfoResponseBody) FromGRPCMessage(m grpc.Message) error + func (i *NetworkInfoResponseBody) GetNetworkInfo() *NetworkInfo + func (i *NetworkInfoResponseBody) SetNetworkInfo(netInfo *NetworkInfo) + func (i *NetworkInfoResponseBody) StableMarshal(buf []byte) ([]byte, error) + func (i *NetworkInfoResponseBody) StableSize() (size int) + func (i *NetworkInfoResponseBody) ToGRPCMessage() grpc.Message + func (i *NetworkInfoResponseBody) Unmarshal(data []byte) error + type NetworkParameter struct + func (x *NetworkParameter) FromGRPCMessage(m grpc.Message) error + func (x *NetworkParameter) GetKey() []byte + func (x *NetworkParameter) GetValue() []byte + func (x *NetworkParameter) SetKey(k []byte) + func (x *NetworkParameter) SetValue(v []byte) + func (x *NetworkParameter) StableMarshal(buf []byte) ([]byte, error) + func (x *NetworkParameter) StableSize() (size int) + func (x *NetworkParameter) ToGRPCMessage() grpc.Message + type NodeInfo struct + func (ni *NodeInfo) FromGRPCMessage(m grpc.Message) error + func (ni *NodeInfo) GetAddress() (addr string) + func (ni *NodeInfo) GetAttributes() []*Attribute + func (ni *NodeInfo) GetPublicKey() []byte + func (ni *NodeInfo) GetState() NodeState + func (ni *NodeInfo) IterateAddresses(f func(string) bool) + func (ni *NodeInfo) MarshalJSON() ([]byte, error) + func (ni *NodeInfo) NumberOfAddresses() int + func (ni *NodeInfo) SetAddress(v string) + func (ni *NodeInfo) SetAddresses(v ...string) + func (ni *NodeInfo) SetAttributes(v []*Attribute) + func (ni *NodeInfo) SetPublicKey(v []byte) + func (ni *NodeInfo) SetState(state NodeState) + func (ni *NodeInfo) StableMarshal(buf []byte) ([]byte, error) + func (ni *NodeInfo) StableSize() (size int) + func (ni *NodeInfo) ToGRPCMessage() grpc.Message + func (ni *NodeInfo) Unmarshal(data []byte) error + func (ni *NodeInfo) UnmarshalJSON(data []byte) error + type NodeState uint32 + const Offline + const Online + const UnspecifiedState + func NodeStateFromRPCMessage(n netmap.NodeInfo_State) NodeState + func (x *NodeState) FromString(s string) bool + func (x NodeState) String() string + type NodeSubnetInfo struct + func (x *NodeSubnetInfo) SetEntryFlag(enters bool) + func (x *NodeSubnetInfo) SetID(id *refs.SubnetID) + func (x NodeSubnetInfo) Enabled() bool + func (x NodeSubnetInfo) ID() *refs.SubnetID + type Operation uint32 + const AND + const EQ + const GE + const GT + const LE + const LT + const NE + const OR + const UnspecifiedOperation + func OperationFromGRPCMessage(n netmap.Operation) Operation + func (x *Operation) FromString(s string) bool + func (x Operation) String() string + type PlacementPolicy struct + func (p *PlacementPolicy) FromGRPCMessage(m grpc.Message) error + func (p *PlacementPolicy) GetContainerBackupFactor() uint32 + func (p *PlacementPolicy) GetFilters() []*Filter + func (p *PlacementPolicy) GetReplicas() []*Replica + func (p *PlacementPolicy) GetSelectors() []*Selector + func (p *PlacementPolicy) GetSubnetID() *refs.SubnetID + func (p *PlacementPolicy) MarshalJSON() ([]byte, error) + func (p *PlacementPolicy) SetContainerBackupFactor(backupFactor uint32) + func (p *PlacementPolicy) SetFilters(filters []*Filter) + func (p *PlacementPolicy) SetReplicas(replicas []*Replica) + func (p *PlacementPolicy) SetSelectors(selectors []*Selector) + func (p *PlacementPolicy) SetSubnetID(id *refs.SubnetID) + func (p *PlacementPolicy) StableMarshal(buf []byte) ([]byte, error) + func (p *PlacementPolicy) StableSize() (size int) + func (p *PlacementPolicy) ToGRPCMessage() grpc.Message + func (p *PlacementPolicy) Unmarshal(data []byte) error + func (p *PlacementPolicy) UnmarshalJSON(data []byte) error + type Replica struct + func ReplicasFromGRPC(rs []*netmap.Replica) (res []*Replica, err error) + func (r *Replica) FromGRPCMessage(m grpc.Message) error + func (r *Replica) GetCount() uint32 + func (r *Replica) GetSelector() string + func (r *Replica) MarshalJSON() ([]byte, error) + func (r *Replica) SetCount(count uint32) + func (r *Replica) SetSelector(selector string) + func (r *Replica) StableMarshal(buf []byte) ([]byte, error) + func (r *Replica) StableSize() (size int) + func (r *Replica) ToGRPCMessage() grpc.Message + func (r *Replica) Unmarshal(data []byte) error + func (r *Replica) UnmarshalJSON(data []byte) error + type Selector struct + func SelectorsFromGRPC(ss []*netmap.Selector) (res []*Selector, err error) + func (s *Selector) FromGRPCMessage(m grpc.Message) error + func (s *Selector) GetAttribute() string + func (s *Selector) GetClause() Clause + func (s *Selector) GetCount() uint32 + func (s *Selector) GetFilter() string + func (s *Selector) GetName() string + func (s *Selector) MarshalJSON() ([]byte, error) + func (s *Selector) SetAttribute(attribute string) + func (s *Selector) SetClause(clause Clause) + func (s *Selector) SetCount(count uint32) + func (s *Selector) SetFilter(filter string) + func (s *Selector) SetName(name string) + func (s *Selector) StableMarshal(buf []byte) ([]byte, error) + func (s *Selector) StableSize() (size int) + func (s *Selector) ToGRPCMessage() grpc.Message + func (s *Selector) Unmarshal(data []byte) error + func (s *Selector) UnmarshalJSON(data []byte) error v2.11.0-pre Nov 17, 2021
Go to main page