netmap

package
v2.16.0 Latest Latest
Warning

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

 Go to latest Published: Sep 14, 2023 License: Apache-2.0 Imports: 7 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AttributesToGRPC 

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

func ClauseToGRPCMessage 

func ClauseToGRPCMessage(n Clause) netmap.Clause

func FiltersToGRPC 

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 

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

func SelectorsToGRPC 

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

Types

type Attribute 

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

Attribute of storage node.

func AttributesFromGRPC 

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

func (*Attribute) FromGRPCMessage 

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

func (*Attribute) StableSize 

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

func (*Attribute) ToGRPCMessage 

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 

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 

func (x Clause) String() string

String returns string representation of Clause.

type Filter 

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

func FiltersFromGRPC 

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

func (*Filter) FromGRPCMessage 

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

func (*Filter) StableSize 

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

func (*Filter) ToGRPCMessage 

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 

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 

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

type LocalNodeInfoRequestBody 

type LocalNodeInfoRequestBody struct{}

func (*LocalNodeInfoRequestBody) FromGRPCMessage 

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

func (*LocalNodeInfoRequestBody) StableMarshal 

func (l *LocalNodeInfoRequestBody) StableMarshal(_ []byte) []byte

func (*LocalNodeInfoRequestBody) StableSize 

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

func (*LocalNodeInfoRequestBody) ToGRPCMessage 

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

func (*LocalNodeInfoRequestBody) Unmarshal 

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

type LocalNodeInfoResponse 

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

func (*LocalNodeInfoResponse) FromGRPCMessage 

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 

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

type LocalNodeInfoResponseBody 

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

func (*LocalNodeInfoResponseBody) FromGRPCMessage 

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

func (*LocalNodeInfoResponseBody) StableSize 

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

func (*LocalNodeInfoResponseBody) ToGRPCMessage 

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

func (*LocalNodeInfoResponseBody) Unmarshal 

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

type NetMap 

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

NetMap represents structure of NeoFS network map.

func (*NetMap) Epoch 

func (x *NetMap) Epoch() uint64

Epoch returns revision number of the NetMap.

func (*NetMap) FromGRPCMessage 

func (x *NetMap) FromGRPCMessage(m grpc.Message) error

func (*NetMap) Nodes 

func (x *NetMap) Nodes() []NodeInfo

Nodes returns nodes presented in the NetMap.

func (*NetMap) SetEpoch 

func (x *NetMap) SetEpoch(v uint64)

SetEpoch sets revision number of the NetMap.

func (*NetMap) SetNodes 

func (x *NetMap) SetNodes(v []NodeInfo)

SetNodes sets nodes presented in the NetMap.

func (*NetMap) StableMarshal 

func (x *NetMap) StableMarshal(buf []byte) []byte

func (*NetMap) StableSize 

func (x *NetMap) StableSize() (size int)

func (*NetMap) ToGRPCMessage 

func (x *NetMap) ToGRPCMessage() grpc.Message

type NetworkConfig 

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

NetworkConfig represents NeoFS network configuration.

func (*NetworkConfig) FromGRPCMessage 

func (x *NetworkConfig) FromGRPCMessage(m grpc.Message) error

func (*NetworkConfig) IterateParameters 

func (x *NetworkConfig) IterateParameters(f func(*NetworkParameter) bool)

IterateParameters iterates over network parameters. Breaks iteration on f's true return.

Handler must not be nil.

func (*NetworkConfig) NumberOfParameters 

func (x *NetworkConfig) NumberOfParameters() int

NumberOfParameters returns number of network parameters.

func (*NetworkConfig) SetParameters 

func (x *NetworkConfig) SetParameters(v ...NetworkParameter)

SetParameters sets list of network parameters.

func (*NetworkConfig) StableMarshal 

func (x *NetworkConfig) StableMarshal(buf []byte) []byte

func (*NetworkConfig) StableSize 

func (x *NetworkConfig) StableSize() (size int)

func (*NetworkConfig) ToGRPCMessage 

func (x *NetworkConfig) ToGRPCMessage() grpc.Message

type NetworkInfo 

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

NetworkInfo groups information about NeoFS network.

func (*NetworkInfo) FromGRPCMessage 

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

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

func (i *NetworkInfo) GetMsPerBlock() int64

GetMsPerBlock returns MillisecondsPerBlock network parameter.

func (*NetworkInfo) GetNetworkConfig 

func (i *NetworkInfo) GetNetworkConfig() *NetworkConfig

GetNetworkConfig returns NeoFS network configuration.

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

func (i *NetworkInfo) SetMsPerBlock(v int64)

SetMsPerBlock sets MillisecondsPerBlock network parameter.

func (*NetworkInfo) SetNetworkConfig 

func (i *NetworkInfo) SetNetworkConfig(v *NetworkConfig)

SetNetworkConfig sets NeoFS network configuration.

func (*NetworkInfo) StableMarshal 

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

func (*NetworkInfo) StableSize 

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

func (*NetworkInfo) ToGRPCMessage 

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

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 {
	session.RequestHeaders
	// contains filtered or unexported fields
}

NetworkInfoRequest is a structure of NetworkInfo request.

func (*NetworkInfoRequest) FromGRPCMessage 

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

func (*NetworkInfoRequest) GetBody 

func (l *NetworkInfoRequest) GetBody() *NetworkInfoRequestBody

func (*NetworkInfoRequest) SetBody 

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

func (*NetworkInfoRequest) ToGRPCMessage 

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

type NetworkInfoRequestBody 

type NetworkInfoRequestBody struct{}

NetworkInfoRequestBody is a structure of NetworkInfo request body.

func (*NetworkInfoRequestBody) FromGRPCMessage 

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

func (*NetworkInfoRequestBody) StableMarshal 

func (l *NetworkInfoRequestBody) StableMarshal(_ []byte) []byte

func (*NetworkInfoRequestBody) StableSize 

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

func (*NetworkInfoRequestBody) ToGRPCMessage 

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

func (*NetworkInfoRequestBody) Unmarshal 

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

type NetworkInfoResponse 

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

NetworkInfoResponse is a structure of NetworkInfo response.

func (*NetworkInfoResponse) FromGRPCMessage 

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

func (*NetworkInfoResponse) GetBody 

func (l *NetworkInfoResponse) GetBody() *NetworkInfoResponseBody

func (*NetworkInfoResponse) SetBody 

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

func (*NetworkInfoResponse) ToGRPCMessage 

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

type NetworkInfoResponseBody 

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

NetworkInfoResponseBody is a structure of NetworkInfo response body.

func (*NetworkInfoResponseBody) FromGRPCMessage 

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

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

func (*NetworkInfoResponseBody) StableSize 

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

func (*NetworkInfoResponseBody) ToGRPCMessage 

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

func (*NetworkInfoResponseBody) Unmarshal 

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

type NetworkParameter 

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

NetworkParameter represents NeoFS network parameter.

func (*NetworkParameter) FromGRPCMessage 

func (x *NetworkParameter) FromGRPCMessage(m grpc.Message) error

func (*NetworkParameter) GetKey 

func (x *NetworkParameter) GetKey() []byte

GetKey returns parameter key.

func (*NetworkParameter) GetValue 

func (x *NetworkParameter) GetValue() []byte

GetValue returns parameter value.

func (*NetworkParameter) SetKey 

func (x *NetworkParameter) SetKey(k []byte)

SetKey sets parameter key.

func (*NetworkParameter) SetValue 

func (x *NetworkParameter) SetValue(v []byte)

SetValue sets parameter value.

func (*NetworkParameter) StableMarshal 

func (x *NetworkParameter) StableMarshal(buf []byte) []byte

func (*NetworkParameter) StableSize 

func (x *NetworkParameter) StableSize() (size int)

func (*NetworkParameter) ToGRPCMessage 

func (x *NetworkParameter) ToGRPCMessage() grpc.Message

type NodeInfo 

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

NodeInfo of storage node.

func (*NodeInfo) FromGRPCMessage 

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 

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 

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 

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

func (*NodeInfo) StableSize 

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

func (*NodeInfo) ToGRPCMessage 

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

func NodeStateFromRPCMessage 

func NodeStateFromRPCMessage(n netmap.NodeInfo_State) NodeState

func (*NodeState) FromString 

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 

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

func OperationFromGRPCMessage 

func OperationFromGRPCMessage(n netmap.Operation) Operation

func (*Operation) FromString 

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 

func (x Operation) String() string

String returns string representation of Operation.

type PlacementPolicy 

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

func (*PlacementPolicy) FromGRPCMessage 

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) GetUnique added in v2.16.0 

func (p *PlacementPolicy) GetUnique() bool

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) SetUnique added in v2.16.0 

func (p *PlacementPolicy) SetUnique(unique bool)

func (*PlacementPolicy) StableMarshal 

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

func (*PlacementPolicy) StableSize 

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

func (*PlacementPolicy) ToGRPCMessage 

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 

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

func (*Replica) FromGRPCMessage 

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

func (*Replica) StableSize 

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

func (*Replica) ToGRPCMessage 

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 

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

func (*Selector) FromGRPCMessage 

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

func (*Selector) StableSize 

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

func (*Selector) ToGRPCMessage 

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

type SnapshotRequest 

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

SnapshotRequest represents structure of Snapshot request.

func (*SnapshotRequest) FromGRPCMessage 

func (x *SnapshotRequest) FromGRPCMessage(m grpc.Message) error

func (*SnapshotRequest) GetBody 

func (x *SnapshotRequest) GetBody() *SnapshotRequestBody

func (*SnapshotRequest) SetBody 

func (x *SnapshotRequest) SetBody(body *SnapshotRequestBody)

func (*SnapshotRequest) ToGRPCMessage 

func (x *SnapshotRequest) ToGRPCMessage() grpc.Message

type SnapshotRequestBody 

type SnapshotRequestBody struct{}

SnapshotRequestBody represents structure of Snapshot request body.

func (*SnapshotRequestBody) FromGRPCMessage 

func (x *SnapshotRequestBody) FromGRPCMessage(m grpc.Message) error

func (*SnapshotRequestBody) StableMarshal 

func (x *SnapshotRequestBody) StableMarshal([]byte) []byte

func (*SnapshotRequestBody) StableSize 

func (x *SnapshotRequestBody) StableSize() int

func (*SnapshotRequestBody) ToGRPCMessage 

func (x *SnapshotRequestBody) ToGRPCMessage() grpc.Message

type SnapshotResponse 

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

SnapshotResponse represents structure of Snapshot response.

func (*SnapshotResponse) FromGRPCMessage 

func (x *SnapshotResponse) FromGRPCMessage(m grpc.Message) error

func (*SnapshotResponse) GetBody 

func (x *SnapshotResponse) GetBody() *SnapshotResponseBody

func (*SnapshotResponse) SetBody 

func (x *SnapshotResponse) SetBody(body *SnapshotResponseBody)

func (*SnapshotResponse) ToGRPCMessage 

func (x *SnapshotResponse) ToGRPCMessage() grpc.Message

type SnapshotResponseBody 

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

SnapshotResponseBody represents structure of Snapshot response body.

func (*SnapshotResponseBody) FromGRPCMessage 

func (x *SnapshotResponseBody) FromGRPCMessage(m grpc.Message) error

func (*SnapshotResponseBody) NetMap 

func (x *SnapshotResponseBody) NetMap() *NetMap

NetMap returns current NetMap.

func (*SnapshotResponseBody) SetNetMap 

func (x *SnapshotResponseBody) SetNetMap(netMap *NetMap)

SetNetMap sets current NetMap.

func (*SnapshotResponseBody) StableMarshal 

func (x *SnapshotResponseBody) StableMarshal(buf []byte) []byte

func (*SnapshotResponseBody) StableSize 

func (x *SnapshotResponseBody) StableSize() (size int)

func (*SnapshotResponseBody) ToGRPCMessage 

func (x *SnapshotResponseBody) ToGRPCMessage() grpc.Message

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.