netmap

package
v2.0.0-...-d29d931 Latest Latest
Warning

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

 Go to latest Published: Feb 25, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AttributeToGRPCMessage 

func AttributeToGRPCMessage(a *Attribute) *netmap.NodeInfo_Attribute

func ClauseToGRPCMessage 

func ClauseToGRPCMessage(n Clause) netmap.Clause

func FilterToGRPCMessage 

func FilterToGRPCMessage(f *Filter) *netmap.Filter

func LocalNodeInfoRequestBodyToGRPCMessage 

func LocalNodeInfoRequestBodyToGRPCMessage(r *LocalNodeInfoRequestBody) *netmap.LocalNodeInfoRequest_Body

func LocalNodeInfoRequestToGRPCMessage 

func LocalNodeInfoRequestToGRPCMessage(r *LocalNodeInfoRequest) *netmap.LocalNodeInfoRequest

func LocalNodeInfoResponseBodyToGRPCMessage 

func LocalNodeInfoResponseBodyToGRPCMessage(r *LocalNodeInfoResponseBody) *netmap.LocalNodeInfoResponse_Body

func LocalNodeInfoResponseToGRPCMessage 

func LocalNodeInfoResponseToGRPCMessage(r *LocalNodeInfoResponse) *netmap.LocalNodeInfoResponse

func NetworkInfoRequestBodyToGRPCMessage 

func NetworkInfoRequestBodyToGRPCMessage(r *NetworkInfoRequestBody) *netmap.NetworkInfoRequest_Body

func NetworkInfoRequestToGRPCMessage 

func NetworkInfoRequestToGRPCMessage(r *NetworkInfoRequest) *netmap.NetworkInfoRequest

func NetworkInfoResponseBodyToGRPCMessage 

func NetworkInfoResponseBodyToGRPCMessage(r *NetworkInfoResponseBody) *netmap.NetworkInfoResponse_Body

func NetworkInfoResponseToGRPCMessage 

func NetworkInfoResponseToGRPCMessage(r *NetworkInfoResponse) *netmap.NetworkInfoResponse

func NetworkInfoToGRPCMessage 

func NetworkInfoToGRPCMessage(n *NetworkInfo) *netmap.NetworkInfo

func NodeInfoToGRPCMessage 

func NodeInfoToGRPCMessage(n *NodeInfo) *netmap.NodeInfo

func NodeStateToGRPCMessage 

func NodeStateToGRPCMessage(n NodeState) netmap.NodeInfo_State

func OperationToGRPCMessage 

func OperationToGRPCMessage(n Operation) netmap.Operation

func PlacementPolicyToGRPCMessage 

func PlacementPolicyToGRPCMessage(p *PlacementPolicy) *netmap.PlacementPolicy

func ReplicaToGRPCMessage 

func ReplicaToGRPCMessage(r *Replica) *netmap.Replica

func SelectorToGRPCMessage 

func SelectorToGRPCMessage(s *Selector) *netmap.Selector

Types

type Attribute 

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

Attribute of storage node.

func AttributeFromGRPCMessage 

func AttributeFromGRPCMessage(m *netmap.NodeInfo_Attribute) *Attribute

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

type Client 

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

Client represents universal netmap transport client.

func NewClient 

func NewClient(opts ...Option) (*Client, error)

NewClient is a constructor for netmap transport client.

func (*Client) LocalNodeInfo 

func (c *Client) LocalNodeInfo(ctx context.Context, req *LocalNodeInfoRequest) (*LocalNodeInfoResponse, error)

LocalNodeInfo sends LocalNodeInfoRequest over the network.

func (*Client) NetworkInfo 

func (c *Client) NetworkInfo(ctx context.Context, req *NetworkInfoRequest) (*NetworkInfoResponse, error)

NetworkInfo sends NetworkInfoRequest over the network.

type Filter 

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

func FilterFromGRPCMessage 

func FilterFromGRPCMessage(m *netmap.Filter) *Filter

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

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

func (*Filter) UnmarshalJSON 

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

type LocalNodeInfoRequest 

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

func LocalNodeInfoRequestFromGRPCMessage 

func LocalNodeInfoRequestFromGRPCMessage(m *netmap.LocalNodeInfoRequest) *LocalNodeInfoRequest

func (*LocalNodeInfoRequest) GetBody 

func (l *LocalNodeInfoRequest) GetBody() *LocalNodeInfoRequestBody

func (*LocalNodeInfoRequest) GetMetaHeader 

func (l *LocalNodeInfoRequest) GetMetaHeader() *session.RequestMetaHeader

func (*LocalNodeInfoRequest) GetVerificationHeader 

func (l *LocalNodeInfoRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*LocalNodeInfoRequest) SetBody 

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

func (*LocalNodeInfoRequest) SetMetaHeader 

func (l *LocalNodeInfoRequest) SetMetaHeader(metaHeader *session.RequestMetaHeader)

func (*LocalNodeInfoRequest) SetVerificationHeader 

func (l *LocalNodeInfoRequest) SetVerificationHeader(verifyHeader *session.RequestVerificationHeader)

type LocalNodeInfoRequestBody 

type LocalNodeInfoRequestBody struct{}

func LocalNodeInfoRequestBodyFromGRPCMessage 

func LocalNodeInfoRequestBodyFromGRPCMessage(m *netmap.LocalNodeInfoRequest_Body) *LocalNodeInfoRequestBody

func (*LocalNodeInfoRequestBody) StableMarshal 

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

func (*LocalNodeInfoRequestBody) StableSize 

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

type LocalNodeInfoResponse 

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

func LocalNodeInfoResponseFromGRPCMessage 

func LocalNodeInfoResponseFromGRPCMessage(m *netmap.LocalNodeInfoResponse) *LocalNodeInfoResponse

func (*LocalNodeInfoResponse) GetBody 

func (l *LocalNodeInfoResponse) GetBody() *LocalNodeInfoResponseBody

func (*LocalNodeInfoResponse) GetMetaHeader 

func (l *LocalNodeInfoResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*LocalNodeInfoResponse) GetVerificationHeader 

func (l *LocalNodeInfoResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*LocalNodeInfoResponse) SetBody 

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

func (*LocalNodeInfoResponse) SetMetaHeader 

func (l *LocalNodeInfoResponse) SetMetaHeader(metaHeader *session.ResponseMetaHeader)

func (*LocalNodeInfoResponse) SetVerificationHeader 

func (l *LocalNodeInfoResponse) SetVerificationHeader(verifyHeader *session.ResponseVerificationHeader)

type LocalNodeInfoResponseBody 

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

func LocalNodeInfoResponseBodyFromGRPCMessage 

func LocalNodeInfoResponseBodyFromGRPCMessage(m *netmap.LocalNodeInfoResponse_Body) *LocalNodeInfoResponseBody

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)

type NetworkInfo 

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

NetworkInfo groups information about NeoFS network.

func NetworkInfoFromGRPCMessage 

func NetworkInfoFromGRPCMessage(m *netmap.NetworkInfo) *NetworkInfo

func (*NetworkInfo) GetCurrentEpoch 

func (i *NetworkInfo) GetCurrentEpoch() uint64

GetCurrentEpoch returns number of the current epoch.

func (*NetworkInfo) GetMagicNumber 

func (i *NetworkInfo) GetMagicNumber() uint64

GetMagicNumber returns magic number of the sidechain.

func (*NetworkInfo) MarshalJSON 

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

func (*NetworkInfo) SetCurrentEpoch 

func (i *NetworkInfo) SetCurrentEpoch(epoch uint64)

SetCurrentEpoch sets number of the current epoch.

func (*NetworkInfo) SetMagicNumber 

func (i *NetworkInfo) SetMagicNumber(magic uint64)

SetMagicNumber sets magic number of the sidechain.

func (*NetworkInfo) StableMarshal 

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

func (*NetworkInfo) StableSize 

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

func (*NetworkInfo) Unmarshal 

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

func (*NetworkInfo) UnmarshalJSON 

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

type NetworkInfoRequest 

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

NetworkInfoRequest is a structure of NetworkInfo request.

func NetworkInfoRequestFromGRPCMessage 

func NetworkInfoRequestFromGRPCMessage(m *netmap.NetworkInfoRequest) *NetworkInfoRequest

func (*NetworkInfoRequest) GetBody 

func (l *NetworkInfoRequest) GetBody() *NetworkInfoRequestBody

func (*NetworkInfoRequest) GetMetaHeader 

func (l *NetworkInfoRequest) GetMetaHeader() *session.RequestMetaHeader

func (*NetworkInfoRequest) GetVerificationHeader 

func (l *NetworkInfoRequest) GetVerificationHeader() *session.RequestVerificationHeader

func (*NetworkInfoRequest) SetBody 

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

func (*NetworkInfoRequest) SetMetaHeader 

func (l *NetworkInfoRequest) SetMetaHeader(metaHeader *session.RequestMetaHeader)

func (*NetworkInfoRequest) SetVerificationHeader 

func (l *NetworkInfoRequest) SetVerificationHeader(verifyHeader *session.RequestVerificationHeader)

type NetworkInfoRequestBody 

type NetworkInfoRequestBody struct{}

NetworkInfoRequestBody is a structure of NetworkInfo request body.

func NetworkInfoRequestBodyFromGRPCMessage 

func NetworkInfoRequestBodyFromGRPCMessage(m *netmap.NetworkInfoRequest_Body) *NetworkInfoRequestBody

func (*NetworkInfoRequestBody) StableMarshal 

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

func (*NetworkInfoRequestBody) StableSize 

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

type NetworkInfoResponse 

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

NetworkInfoResponse is a structure of NetworkInfo response.

func NetworkInfoResponseFromGRPCMessage 

func NetworkInfoResponseFromGRPCMessage(m *netmap.NetworkInfoResponse) *NetworkInfoResponse

func (*NetworkInfoResponse) GetBody 

func (l *NetworkInfoResponse) GetBody() *NetworkInfoResponseBody

func (*NetworkInfoResponse) GetMetaHeader 

func (l *NetworkInfoResponse) GetMetaHeader() *session.ResponseMetaHeader

func (*NetworkInfoResponse) GetVerificationHeader 

func (l *NetworkInfoResponse) GetVerificationHeader() *session.ResponseVerificationHeader

func (*NetworkInfoResponse) SetBody 

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

func (*NetworkInfoResponse) SetMetaHeader 

func (l *NetworkInfoResponse) SetMetaHeader(metaHeader *session.ResponseMetaHeader)

func (*NetworkInfoResponse) SetVerificationHeader 

func (l *NetworkInfoResponse) SetVerificationHeader(verifyHeader *session.ResponseVerificationHeader)

type NetworkInfoResponseBody 

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

NetworkInfoResponseBody is a structure of NetworkInfo response body.

func NetworkInfoResponseBodyFromGRPCMessage 

func NetworkInfoResponseBodyFromGRPCMessage(m *netmap.NetworkInfoResponse_Body) *NetworkInfoResponseBody

func (*NetworkInfoResponseBody) GetNetworkInfo 

func (i *NetworkInfoResponseBody) GetNetworkInfo() *NetworkInfo

GetNetworkInfo returns information about the NeoFS network.

func (*NetworkInfoResponseBody) SetNetworkInfo 

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

SetNetworkInfo sets information about the NeoFS network.

func (*NetworkInfoResponseBody) StableMarshal 

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

func (*NetworkInfoResponseBody) StableSize 

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

type NodeInfo 

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

NodeInfo of storage node.

func NodeInfoFromGRPCMessage 

func NodeInfoFromGRPCMessage(m *netmap.NodeInfo) *NodeInfo

func (*NodeInfo) GetAddress 

func (ni *NodeInfo) GetAddress() string

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

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

func (*NodeInfo) SetAddress 

func (ni *NodeInfo) SetAddress(v string)

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

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

type Option 

type Option func(*cfg)

Option represents Client option.

func WithGRPCCallOpts 

func WithGRPCCallOpts(v []grpc.CallOption) Option

WithGRPCServiceClient sets GRPC specific call options.

func WithGRPCClient 

func WithGRPCClient(v *netmap.Client) Option

WithGRPCServiceClient sets existing GRPC client.

func WithGRPCClientOpts 

func WithGRPCClientOpts(v []netmap.Option) Option

WithGRPCServiceClient sets GRPC specific client options.

func WithGRPCServiceClient 

func WithGRPCServiceClient(v netmap.NetmapServiceClient) Option

WithGRPCServiceClient sets existing service client.

func WithGlobalOpts 

func WithGlobalOpts(v ...client.Option) Option

WithGlobalOpts sets global client options to client.

type PlacementPolicy 

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

func PlacementPolicyFromGRPCMessage 

func PlacementPolicyFromGRPCMessage(m *netmap.PlacementPolicy) *PlacementPolicy

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

func ReplicaFromGRPCMessage(m *netmap.Replica) *Replica

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

func SelectorFromGRPCMessage(m *netmap.Selector) *Selector

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

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

func (*Selector) UnmarshalJSON 

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

type Service 

type Service interface {
	LocalNodeInfo(ctx context.Context, request *LocalNodeInfoRequest) (*LocalNodeInfoResponse, error)
	NetworkInfo(ctx context.Context, request *NetworkInfoRequest) (*NetworkInfoResponse, 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.