Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
var File_unresponsive_unresponsive_proto protoreflect.FileDescriptor
Functions ¶
func RegisterUnresponsiveServer ¶
func RegisterUnresponsiveServer(srv *gorums.Server, impl UnresponsiveServer)
Types ¶
type Configuration ¶
type Configuration = gorums.Configuration
Type aliases for important Gorums types to make them more accessible from user code already interacting with the generated code.
func NewConfig ¶
func NewConfig(opts ...gorums.Option) (Configuration, error)
NewConfig returns a new Configuration based on the provided [gorums.Option]s. It accepts exactly one gorums.NodeListOption and multiple [gorums.ManagerOption]s. You may use this function to create the initial configuration for a new manager.
Example:
cfg, err := NewConfig(
gorums.WithNodeList([]string{"localhost:8080", "localhost:8081", "localhost:8082"}),
gorums.WithDialOptions(grpc.WithTransportCredentials(insecure.NewCredentials())),
)
This is a convenience function for creating a configuration without explicitly creating a manager first. However, the manager can be accessed using the [Configuration.Manager] method. This method should only be used once since it creates a new manager; if a manager already exists, use NewConfiguration instead, and provide the existing manager as the first argument.
func NewConfiguration ¶
func NewConfiguration(mgr *Manager, opt gorums.NodeListOption) (Configuration, error)
NewConfiguration returns a configuration based on the provided list of nodes. 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 Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func TestUnresponsive ¶
func TestUnresponsive(ctx *gorums.NodeContext, in *Empty) (resp *Empty, err error)
TestUnresponsive is an RPC call invoked on the node in ctx.
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type Empty_builder ¶
type Empty_builder struct {
// contains filtered or unexported fields
}
func (Empty_builder) Build ¶
func (b0 Empty_builder) Build() *Empty
type Manager ¶
Type aliases for important Gorums types to make them more accessible from user code already interacting with the generated code.
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.
Source Files