Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var File_metadata_metadata_proto protoreflect.FileDescriptor
Functions ¶
func RegisterMetadataTestServer ¶
func RegisterMetadataTestServer(srv *gorums.Server, impl MetadataTestServer)
Types ¶
type Configuration ¶
type Configuration struct {
gorums.RawConfiguration
// contains filtered or unexported fields
}
A Configuration represents a static set of nodes on which quorum remote procedure calls may be invoked.
func ConfigurationFromRaw ¶ added in v0.7.0
func ConfigurationFromRaw(rawCfg gorums.RawConfiguration, qspec QuorumSpec) (*Configuration, error)
ConfigurationFromRaw returns a new Configuration from the given raw configuration and QuorumSpec.
This function may for example be used to "clone" a configuration but install a different QuorumSpec:
cfg1, err := mgr.NewConfiguration(qspec1, opts...) cfg2 := ConfigurationFromRaw(cfg1.RawConfig, qspec2)
func (Configuration) And ¶
func (c Configuration) And(d *Configuration) gorums.NodeListOption
And returns a NodeListOption that can be used to create a new configuration combining c and d.
func (Configuration) Except ¶
func (c Configuration) Except(rm *Configuration) gorums.NodeListOption
Except returns a NodeListOption that can be used to create a new configuration from c without the nodes in rm.
func (*Configuration) Nodes ¶
func (c *Configuration) Nodes() []*Node
Nodes returns a slice of each available node. IDs are returned in the same order as they were provided in the creation of the Manager.
NOTE: mutating the returned slice is not supported.
type IPAddr ¶
type IPAddr struct {
// contains filtered or unexported fields
}
func (*IPAddr) ProtoMessage ¶
func (*IPAddr) ProtoMessage()
func (*IPAddr) ProtoReflect ¶
func (x *IPAddr) ProtoReflect() protoreflect.Message
type IPAddr_builder ¶ added in v0.10.0
type IPAddr_builder struct {
Addr string
// contains filtered or unexported fields
}
func (IPAddr_builder) Build ¶ added in v0.10.0
func (b0 IPAddr_builder) Build() *IPAddr
type Manager ¶
type Manager struct {
*gorums.RawManager
}
Manager maintains a connection pool of nodes on which quorum calls can be performed.
func NewManager ¶
func NewManager(opts ...gorums.ManagerOption) *Manager
NewManager returns a new Manager for managing connection to nodes added to the manager. This function accepts manager options used to configure various aspects of the manager.
func (*Manager) NewConfiguration ¶
func (m *Manager) NewConfiguration(opts ...gorums.ConfigOption) (c *Configuration, err error)
NewConfiguration returns a configuration based on the provided list of nodes (required) and an optional quorum specification. The QuorumSpec is necessary for call types that must process replies. For configurations only used for unicast or multicast call types, a QuorumSpec is not needed. The QuorumSpec interface is also a ConfigOption. Nodes can be supplied using WithNodeMap or WithNodeList, or WithNodeIDs. A new configuration can also be created from an existing configuration, using the And, WithNewNodes, Except, and WithoutNodes methods.
type MetadataTestNodeClient ¶ added in v0.8.0
type MetadataTestNodeClient interface {
IDFromMD(ctx context.Context, in *emptypb.Empty) (resp *NodeID, err error)
WhatIP(ctx context.Context, in *emptypb.Empty) (resp *IPAddr, err error)
}
MetadataTestNodeClient is the single node client interface for the MetadataTest service.
type MetadataTestServer ¶ added in v0.8.0
type MetadataTestServer interface {
IDFromMD(ctx gorums.ServerCtx, request *emptypb.Empty) (response *NodeID, err error)
WhatIP(ctx gorums.ServerCtx, request *emptypb.Empty) (response *IPAddr, err error)
}
MetadataTest is the server-side API for the MetadataTest Service
type Node ¶
Node encapsulates the state of a node on which a remote procedure call can be performed.
type NodeID ¶
type NodeID struct {
// contains filtered or unexported fields
}
func (*NodeID) ProtoMessage ¶
func (*NodeID) ProtoMessage()
func (*NodeID) ProtoReflect ¶
func (x *NodeID) ProtoReflect() protoreflect.Message
type NodeID_builder ¶ added in v0.10.0
type NodeID_builder struct {
ID uint32
// contains filtered or unexported fields
}
func (NodeID_builder) Build ¶ added in v0.10.0
func (b0 NodeID_builder) Build() *NodeID
Source Files