netmap

package
v1.28.3 Latest Latest
Warning

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

 Go to latest Published: Jul 7, 2021 License: Apache-2.0 Imports: 7 Imported by: 10

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AttributesToGRPC added in v1.25.0 

func AttributesToGRPC(as []*Attribute) (res []*netmap.NodeInfo_Attribute)

func ClauseToGRPCMessage 

func ClauseToGRPCMessage(n Clause) netmap.Clause

func FiltersToGRPC added in v1.25.0 

func FiltersToGRPC(fs []*Filter) (res []*netmap.Filter)

func NodeStateToGRPCMessage 

func NodeStateToGRPCMessage(n NodeState) netmap.NodeInfo_State

func OperationToGRPCMessage 

func OperationToGRPCMessage(n Operation) netmap.Operation

func ReplicasToGRPC added in v1.25.0 

func ReplicasToGRPC(rs []*Replica) (res []*netmap.Replica)

func SelectorsToGRPC added in v1.25.0 

func SelectorsToGRPC(ss []*Selector) (res []*netmap.Selector)

Types

type Attribute 

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

Attribute of storage node.

func AttributesFromGRPC added in v1.25.0 

func AttributesFromGRPC(as []*netmap.NodeInfo_Attribute) (res []*Attribute, err error)

func (*Attribute) FromGRPCMessage added in v1.25.0 

func (a *Attribute) FromGRPCMessage(m grpc.Message) error

func (*Attribute) GetKey 

func (a *Attribute) GetKey() string

func (*Attribute) GetParents 

func (a *Attribute) GetParents() []string

func (*Attribute) GetValue 

func (a *Attribute) GetValue() string

func (*Attribute) MarshalJSON 

func (a *Attribute) MarshalJSON() ([]byte, error)

func (*Attribute) SetKey 

func (a *Attribute) SetKey(v string)

func (*Attribute) SetParents 

func (a *Attribute) SetParents(parent []string)

func (*Attribute) SetValue 

func (a *Attribute) SetValue(v string)

func (*Attribute) StableMarshal 

func (a *Attribute) StableMarshal(buf []byte) ([]byte, error)

func (*Attribute) StableSize 

func (a *Attribute) StableSize() (size int)

func (*Attribute) ToGRPCMessage added in v1.25.0 

func (a *Attribute) ToGRPCMessage() grpc.Message

func (*Attribute) Unmarshal 

func (a *Attribute) Unmarshal(data []byte) error

func (*Attribute) UnmarshalJSON 

func (a *Attribute) UnmarshalJSON(data []byte) error

type Clause 

type Clause uint32

Clause of placement selector. 

const (
	UnspecifiedClause Clause = iota
	Same
	Distinct
)

func ClauseFromGRPCMessage 

func ClauseFromGRPCMessage(n netmap.Clause) Clause

func (*Clause) FromString added in v1.28.0 

func (x *Clause) FromString(s string) bool

FromString parses Clause from a string representation. It is a reverse action to String().

Returns true if s was parsed successfully.

func (Clause) String added in v1.28.0 

func (x Clause) String() string

String returns string representation of Clause.

type Filter 

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

func FiltersFromGRPC added in v1.25.0 

func FiltersFromGRPC(fs []*netmap.Filter) (res []*Filter, err error)

func (*Filter) FromGRPCMessage added in v1.25.0 

func (f *Filter) FromGRPCMessage(m grpc.Message) error

func (*Filter) GetFilters 

func (f *Filter) GetFilters() []*Filter

func (*Filter) GetKey 

func (f *Filter) GetKey() string

func (*Filter) GetName 

func (f *Filter) GetName() string

func (*Filter) GetOp 

func (f *Filter) GetOp() Operation

func (*Filter) GetValue 

func (f *Filter) GetValue() string

func (*Filter) MarshalJSON 

func (f *Filter) MarshalJSON() ([]byte, error)

func (*Filter) SetFilters 

func (f *Filter) SetFilters(filters []*Filter)

func (*Filter) SetKey 

func (f *Filter) SetKey(key string)

func (*Filter) SetName 

func (f *Filter) SetName(name string)

func (*Filter) SetOp 

func (f *Filter) SetOp(op Operation)

func (*Filter) SetValue 

func (f *Filter) SetValue(value string)

func (*Filter) StableMarshal 

func (f *Filter) StableMarshal(buf []byte) ([]byte, error)

func (*Filter) StableSize 

func (f *Filter) StableSize() (size int)

func (*Filter) ToGRPCMessage added in v1.25.0 

func (f *Filter) ToGRPCMessage() grpc.Message

func (*Filter) Unmarshal 

func (f *Filter) Unmarshal(data []byte) error

func (*Filter) UnmarshalJSON 

func (f *Filter) UnmarshalJSON(data []byte) error

type LocalNodeInfoRequest 

type LocalNodeInfoRequest struct {
	session.RequestHeaders
	// contains filtered or unexported fields
}

func (*LocalNodeInfoRequest) FromGRPCMessage added in v1.25.0 

func (l *LocalNodeInfoRequest) FromGRPCMessage(m grpc.Message) error

func (*LocalNodeInfoRequest) GetBody 

func (l *LocalNodeInfoRequest) GetBody() *LocalNodeInfoRequestBody

func (*LocalNodeInfoRequest) SetBody 

func (l *LocalNodeInfoRequest) SetBody(body *LocalNodeInfoRequestBody)

func (*LocalNodeInfoRequest) ToGRPCMessage added in v1.25.0 

func (l *LocalNodeInfoRequest) ToGRPCMessage() grpc.Message

type LocalNodeInfoRequestBody 

type LocalNodeInfoRequestBody struct{}

func (*LocalNodeInfoRequestBody) FromGRPCMessage added in v1.25.0 

func (l *LocalNodeInfoRequestBody) FromGRPCMessage(m grpc.Message) error

func (*LocalNodeInfoRequestBody) StableMarshal 

func (l *LocalNodeInfoRequestBody) StableMarshal(buf []byte) ([]byte, error)

func (*LocalNodeInfoRequestBody) StableSize 

func (l *LocalNodeInfoRequestBody) StableSize() (size int)

func (*LocalNodeInfoRequestBody) ToGRPCMessage added in v1.25.0 

func (l *LocalNodeInfoRequestBody) ToGRPCMessage() grpc.Message

func (*LocalNodeInfoRequestBody) Unmarshal added in v1.25.0 

func (l *LocalNodeInfoRequestBody) Unmarshal([]byte) error

type LocalNodeInfoResponse 

type LocalNodeInfoResponse struct {
	session.ResponseHeaders
	// contains filtered or unexported fields
}

func (*LocalNodeInfoResponse) FromGRPCMessage added in v1.25.0 

func (l *LocalNodeInfoResponse) FromGRPCMessage(m grpc.Message) error

func (*LocalNodeInfoResponse) GetBody 

func (l *LocalNodeInfoResponse) GetBody() *LocalNodeInfoResponseBody

func (*LocalNodeInfoResponse) SetBody 

func (l *LocalNodeInfoResponse) SetBody(body *LocalNodeInfoResponseBody)

func (*LocalNodeInfoResponse) ToGRPCMessage added in v1.25.0 

func (l *LocalNodeInfoResponse) ToGRPCMessage() grpc.Message

type LocalNodeInfoResponseBody 

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

func (*LocalNodeInfoResponseBody) FromGRPCMessage added in v1.25.0 

func (l *LocalNodeInfoResponseBody) FromGRPCMessage(m grpc.Message) error

func (*LocalNodeInfoResponseBody) GetNodeInfo 

func (l *LocalNodeInfoResponseBody) GetNodeInfo() *NodeInfo

func (*LocalNodeInfoResponseBody) GetVersion 

func (l *LocalNodeInfoResponseBody) GetVersion() *refs.Version

func (*LocalNodeInfoResponseBody) SetNodeInfo 

func (l *LocalNodeInfoResponseBody) SetNodeInfo(nodeInfo *NodeInfo)

func (*LocalNodeInfoResponseBody) SetVersion 

func (l *LocalNodeInfoResponseBody) SetVersion(version *refs.Version)

func (*LocalNodeInfoResponseBody) StableMarshal 

func (l *LocalNodeInfoResponseBody) StableMarshal(buf []byte) ([]byte, error)

func (*LocalNodeInfoResponseBody) StableSize 

func (l *LocalNodeInfoResponseBody) StableSize() (size int)

func (*LocalNodeInfoResponseBody) ToGRPCMessage added in v1.25.0 

func (l *LocalNodeInfoResponseBody) ToGRPCMessage() grpc.Message

func (*LocalNodeInfoResponseBody) Unmarshal added in v1.25.0 

func (l *LocalNodeInfoResponseBody) Unmarshal(data []byte) error

type NetworkInfo added in v1.24.0 

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

NetworkInfo groups information about NeoFS network.

func (*NetworkInfo) FromGRPCMessage added in v1.25.0 

func (i *NetworkInfo) FromGRPCMessage(m grpc.Message) error

func (*NetworkInfo) GetCurrentEpoch added in v1.24.0 

func (i *NetworkInfo) GetCurrentEpoch() uint64

GetCurrentEpoch returns number of the current epoch.

func (*NetworkInfo) GetMagicNumber added in v1.24.0 

func (i *NetworkInfo) GetMagicNumber() uint64

GetMagicNumber returns magic number of the sidechain.

func (*NetworkInfo) MarshalJSON added in v1.24.0 

func (i *NetworkInfo) MarshalJSON() ([]byte, error)

func (*NetworkInfo) SetCurrentEpoch added in v1.24.0 

func (i *NetworkInfo) SetCurrentEpoch(epoch uint64)

SetCurrentEpoch sets number of the current epoch.

func (*NetworkInfo) SetMagicNumber added in v1.24.0 

func (i *NetworkInfo) SetMagicNumber(magic uint64)

SetMagicNumber sets magic number of the sidechain.

func (*NetworkInfo) StableMarshal added in v1.24.0 

func (i *NetworkInfo) StableMarshal(buf []byte) ([]byte, error)

func (*NetworkInfo) StableSize added in v1.24.0 

func (i *NetworkInfo) StableSize() (size int)

func (*NetworkInfo) ToGRPCMessage added in v1.25.0 

func (i *NetworkInfo) ToGRPCMessage() grpc.Message

func (*NetworkInfo) Unmarshal added in v1.24.0 

func (i *NetworkInfo) Unmarshal(data []byte) error

func (*NetworkInfo) UnmarshalJSON added in v1.24.0 

func (i *NetworkInfo) UnmarshalJSON(data []byte) error

type NetworkInfoRequest added in v1.24.0 

type NetworkInfoRequest struct {
	session.RequestHeaders
	// contains filtered or unexported fields
}

NetworkInfoRequest is a structure of NetworkInfo request.

func (*NetworkInfoRequest) FromGRPCMessage added in v1.25.0 

func (l *NetworkInfoRequest) FromGRPCMessage(m grpc.Message) error

func (*NetworkInfoRequest) GetBody added in v1.24.0 

func (l *NetworkInfoRequest) GetBody() *NetworkInfoRequestBody

func (*NetworkInfoRequest) SetBody added in v1.24.0 

func (l *NetworkInfoRequest) SetBody(body *NetworkInfoRequestBody)

func (*NetworkInfoRequest) ToGRPCMessage added in v1.25.0 

func (l *NetworkInfoRequest) ToGRPCMessage() grpc.Message

type NetworkInfoRequestBody added in v1.24.0 

type NetworkInfoRequestBody struct{}

NetworkInfoRequestBody is a structure of NetworkInfo request body.

func (*NetworkInfoRequestBody) FromGRPCMessage added in v1.25.0 

func (l *NetworkInfoRequestBody) FromGRPCMessage(m grpc.Message) error

func (*NetworkInfoRequestBody) StableMarshal added in v1.24.0 

func (l *NetworkInfoRequestBody) StableMarshal(buf []byte) ([]byte, error)

func (*NetworkInfoRequestBody) StableSize added in v1.24.0 

func (l *NetworkInfoRequestBody) StableSize() (size int)

func (*NetworkInfoRequestBody) ToGRPCMessage added in v1.25.0 

func (l *NetworkInfoRequestBody) ToGRPCMessage() grpc.Message

func (*NetworkInfoRequestBody) Unmarshal added in v1.25.0 

func (l *NetworkInfoRequestBody) Unmarshal(data []byte) error

type NetworkInfoResponse added in v1.24.0 

type NetworkInfoResponse struct {
	session.ResponseHeaders
	// contains filtered or unexported fields
}

NetworkInfoResponse is a structure of NetworkInfo response.

func (*NetworkInfoResponse) FromGRPCMessage added in v1.25.0 

func (l *NetworkInfoResponse) FromGRPCMessage(m grpc.Message) error

func (*NetworkInfoResponse) GetBody added in v1.24.0 

func (l *NetworkInfoResponse) GetBody() *NetworkInfoResponseBody

func (*NetworkInfoResponse) SetBody added in v1.24.0 

func (l *NetworkInfoResponse) SetBody(body *NetworkInfoResponseBody)

func (*NetworkInfoResponse) ToGRPCMessage added in v1.25.0 

func (l *NetworkInfoResponse) ToGRPCMessage() grpc.Message

type NetworkInfoResponseBody added in v1.24.0 

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

NetworkInfoResponseBody is a structure of NetworkInfo response body.

func (*NetworkInfoResponseBody) FromGRPCMessage added in v1.25.0 

func (i *NetworkInfoResponseBody) FromGRPCMessage(m grpc.Message) error

func (*NetworkInfoResponseBody) GetNetworkInfo added in v1.24.0 

func (i *NetworkInfoResponseBody) GetNetworkInfo() *NetworkInfo

GetNetworkInfo returns information about the NeoFS network.

func (*NetworkInfoResponseBody) SetNetworkInfo added in v1.24.0 

func (i *NetworkInfoResponseBody) SetNetworkInfo(netInfo *NetworkInfo)

SetNetworkInfo sets information about the NeoFS network.

func (*NetworkInfoResponseBody) StableMarshal added in v1.24.0 

func (i *NetworkInfoResponseBody) StableMarshal(buf []byte) ([]byte, error)

func (*NetworkInfoResponseBody) StableSize added in v1.24.0 

func (i *NetworkInfoResponseBody) StableSize() (size int)

func (*NetworkInfoResponseBody) ToGRPCMessage added in v1.25.0 

func (i *NetworkInfoResponseBody) ToGRPCMessage() grpc.Message

func (*NetworkInfoResponseBody) Unmarshal added in v1.25.0 

func (i *NetworkInfoResponseBody) Unmarshal(data []byte) error

type NodeInfo 

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

NodeInfo of storage node.

func (*NodeInfo) FromGRPCMessage added in v1.25.0 

func (ni *NodeInfo) FromGRPCMessage(m grpc.Message) error

func (*NodeInfo) GetAddress deprecated 

func (ni *NodeInfo) GetAddress() (addr string)

GetAddress returns node's network address.

Deprecated: use IterateAddresses.

func (*NodeInfo) GetAttributes 

func (ni *NodeInfo) GetAttributes() []*Attribute

func (*NodeInfo) GetPublicKey 

func (ni *NodeInfo) GetPublicKey() []byte

func (*NodeInfo) GetState 

func (ni *NodeInfo) GetState() NodeState

func (*NodeInfo) IterateAddresses added in v1.28.0 

func (ni *NodeInfo) IterateAddresses(f func(string) bool)

IterateAddresses iterates over network addresses of the node. Breaks iteration on f's true return.

Handler should not be nil.

func (*NodeInfo) MarshalJSON 

func (ni *NodeInfo) MarshalJSON() ([]byte, error)

func (*NodeInfo) NumberOfAddresses added in v1.28.0 

func (ni *NodeInfo) NumberOfAddresses() int

NumberOfAddresses returns number of network addresses of the node.

func (*NodeInfo) SetAddress deprecated 

func (ni *NodeInfo) SetAddress(v string)

SetAddress sets node's network address.

Deprecated: use SetAddresses.

func (*NodeInfo) SetAddresses added in v1.28.0 

func (ni *NodeInfo) SetAddresses(v ...string)

SetAddresses sets list of network addresses of the node.

func (*NodeInfo) SetAttributes 

func (ni *NodeInfo) SetAttributes(v []*Attribute)

func (*NodeInfo) SetPublicKey 

func (ni *NodeInfo) SetPublicKey(v []byte)

func (*NodeInfo) SetState 

func (ni *NodeInfo) SetState(state NodeState)

func (*NodeInfo) StableMarshal 

func (ni *NodeInfo) StableMarshal(buf []byte) ([]byte, error)

func (*NodeInfo) StableSize 

func (ni *NodeInfo) StableSize() (size int)

func (*NodeInfo) ToGRPCMessage added in v1.25.0 

func (ni *NodeInfo) ToGRPCMessage() grpc.Message

func (*NodeInfo) Unmarshal 

func (ni *NodeInfo) Unmarshal(data []byte) error

func (*NodeInfo) UnmarshalJSON 

func (ni *NodeInfo) UnmarshalJSON(data []byte) error

type NodeState 

type NodeState uint32

NodeState of storage node. 

const (
	UnspecifiedState NodeState = iota
	Online
	Offline
)

func NodeStateFromRPCMessage 

func NodeStateFromRPCMessage(n netmap.NodeInfo_State) NodeState

func (*NodeState) FromString added in v1.28.0 

func (x *NodeState) FromString(s string) bool

FromString parses NodeState from a string representation. It is a reverse action to String().

Returns true if s was parsed successfully.

func (NodeState) String added in v1.28.0 

func (x NodeState) String() string

String returns string representation of NodeState.

type Operation 

type Operation uint32
const (
	UnspecifiedOperation Operation = iota
	EQ
	NE
	GT
	GE
	LT
	LE
	OR
	AND
)

func OperationFromGRPCMessage 

func OperationFromGRPCMessage(n netmap.Operation) Operation

func (*Operation) FromString added in v1.28.0 

func (x *Operation) FromString(s string) bool

FromString parses Operation from a string representation. It is a reverse action to String().

Returns true if s was parsed successfully.

func (Operation) String added in v1.28.0 

func (x Operation) String() string

String returns string representation of Operation.

type PlacementPolicy 

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

func (*PlacementPolicy) FromGRPCMessage added in v1.25.0 

func (p *PlacementPolicy) FromGRPCMessage(m grpc.Message) error

func (*PlacementPolicy) GetContainerBackupFactor 

func (p *PlacementPolicy) GetContainerBackupFactor() uint32

func (*PlacementPolicy) GetFilters 

func (p *PlacementPolicy) GetFilters() []*Filter

func (*PlacementPolicy) GetReplicas 

func (p *PlacementPolicy) GetReplicas() []*Replica

func (*PlacementPolicy) GetSelectors 

func (p *PlacementPolicy) GetSelectors() []*Selector

func (*PlacementPolicy) MarshalJSON 

func (p *PlacementPolicy) MarshalJSON() ([]byte, error)

func (*PlacementPolicy) SetContainerBackupFactor 

func (p *PlacementPolicy) SetContainerBackupFactor(backupFactor uint32)

func (*PlacementPolicy) SetFilters 

func (p *PlacementPolicy) SetFilters(filters []*Filter)

func (*PlacementPolicy) SetReplicas 

func (p *PlacementPolicy) SetReplicas(replicas []*Replica)

func (*PlacementPolicy) SetSelectors 

func (p *PlacementPolicy) SetSelectors(selectors []*Selector)

func (*PlacementPolicy) StableMarshal 

func (p *PlacementPolicy) StableMarshal(buf []byte) ([]byte, error)

func (*PlacementPolicy) StableSize 

func (p *PlacementPolicy) StableSize() (size int)

func (*PlacementPolicy) ToGRPCMessage added in v1.25.0 

func (p *PlacementPolicy) ToGRPCMessage() grpc.Message

func (*PlacementPolicy) Unmarshal 

func (p *PlacementPolicy) Unmarshal(data []byte) error

func (*PlacementPolicy) UnmarshalJSON 

func (p *PlacementPolicy) UnmarshalJSON(data []byte) error

type Replica 

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

func ReplicasFromGRPC added in v1.25.0 

func ReplicasFromGRPC(rs []*netmap.Replica) (res []*Replica, err error)

func (*Replica) FromGRPCMessage added in v1.25.0 

func (r *Replica) FromGRPCMessage(m grpc.Message) error

func (*Replica) GetCount 

func (r *Replica) GetCount() uint32

func (*Replica) GetSelector 

func (r *Replica) GetSelector() string

func (*Replica) MarshalJSON 

func (r *Replica) MarshalJSON() ([]byte, error)

func (*Replica) SetCount 

func (r *Replica) SetCount(count uint32)

func (*Replica) SetSelector 

func (r *Replica) SetSelector(selector string)

func (*Replica) StableMarshal 

func (r *Replica) StableMarshal(buf []byte) ([]byte, error)

func (*Replica) StableSize 

func (r *Replica) StableSize() (size int)

func (*Replica) ToGRPCMessage added in v1.25.0 

func (r *Replica) ToGRPCMessage() grpc.Message

func (*Replica) Unmarshal 

func (r *Replica) Unmarshal(data []byte) error

func (*Replica) UnmarshalJSON 

func (r *Replica) UnmarshalJSON(data []byte) error

type Selector 

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

func SelectorsFromGRPC added in v1.25.0 

func SelectorsFromGRPC(ss []*netmap.Selector) (res []*Selector, err error)

func (*Selector) FromGRPCMessage added in v1.25.0 

func (s *Selector) FromGRPCMessage(m grpc.Message) error

func (*Selector) GetAttribute 

func (s *Selector) GetAttribute() string

func (*Selector) GetClause 

func (s *Selector) GetClause() Clause

func (*Selector) GetCount 

func (s *Selector) GetCount() uint32

func (*Selector) GetFilter 

func (s *Selector) GetFilter() string

func (*Selector) GetName 

func (s *Selector) GetName() string

func (*Selector) MarshalJSON 

func (s *Selector) MarshalJSON() ([]byte, error)

func (*Selector) SetAttribute 

func (s *Selector) SetAttribute(attribute string)

func (*Selector) SetClause 

func (s *Selector) SetClause(clause Clause)

func (*Selector) SetCount 

func (s *Selector) SetCount(count uint32)

func (*Selector) SetFilter 

func (s *Selector) SetFilter(filter string)

func (*Selector) SetName 

func (s *Selector) SetName(name string)

func (*Selector) StableMarshal 

func (s *Selector) StableMarshal(buf []byte) ([]byte, error)

func (*Selector) StableSize 

func (s *Selector) StableSize() (size int)

func (*Selector) ToGRPCMessage added in v1.25.0 

func (s *Selector) ToGRPCMessage() grpc.Message

func (*Selector) Unmarshal 

func (s *Selector) Unmarshal(data []byte) error

func (*Selector) UnmarshalJSON 

func (s *Selector) UnmarshalJSON(data []byte) error

Source Files

View all Source files

Directories

Path Synopsis

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.