Versions in this module Expand all Collapse all v2 v2.16.0 Sep 14, 2023 Changes in this version type Operation + const NOT type PlacementPolicy + func (p *PlacementPolicy) GetUnique() bool + func (p *PlacementPolicy) SetUnique(unique bool) v2.15.0 Apr 11, 2023 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 + 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 + 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 + 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 + func (l *LocalNodeInfoResponseBody) StableSize() (size int) + func (l *LocalNodeInfoResponseBody) ToGRPCMessage() grpc.Message + func (l *LocalNodeInfoResponseBody) Unmarshal(data []byte) error + 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 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 + 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 + 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 + 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 + 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 + 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 + 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 Maintenance + 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 + 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 + 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 + 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 + 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