Documentation
¶
Index ¶
- Variables
- func QuorumCall(ctx *gorums.ConfigContext, in *Request, opts ...gorums.CallOption) *gorums.Responses[*Response]
- func RegisterGorumsTestServer(srv *gorums.Server, impl GorumsTestServer)
- type AsyncResponse
- type Configuration
- type CorrectableResponse
- type GorumsTestServer
- type Manager
- type Node
- type Request
- type Request_builder
- type Response
- type Response_builder
Constants ¶
This section is empty.
Variables ¶
var File_ordering_order_proto protoreflect.FileDescriptor
Functions ¶
func QuorumCall ¶
func QuorumCall(ctx *gorums.ConfigContext, in *Request, opts ...gorums.CallOption) *gorums.Responses[*Response]
QuorumCall is a quorum call invoked on all nodes in the configuration, with the same argument in. Use terminal methods like Majority(), First(), or Threshold(n) to retrieve the aggregated result.
Example:
resp, err := QuorumCall(ctx, in).Majority()
func RegisterGorumsTestServer ¶
func RegisterGorumsTestServer(srv *gorums.Server, impl GorumsTestServer)
Types ¶
type AsyncResponse ¶
AsyncResponse is a future for async quorum calls returning *Response.
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 CorrectableResponse ¶
type CorrectableResponse = *gorums.Correctable[*Response]
CorrectableResponse is a correctable object for quorum calls returning *Response.
type GorumsTestServer ¶
type GorumsTestServer interface {
QuorumCall(ctx gorums.ServerCtx, request *Request) (response *Response, err error)
UnaryRPC(ctx gorums.ServerCtx, request *Request) (response *Response, err error)
}
GorumsTest is the server-side API for the GorumsTest Service
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.
type Node ¶
Type aliases for important Gorums types to make them more accessible from user code already interacting with the generated code.
type Request ¶
type Request struct {
// contains filtered or unexported fields
}
func (*Request) ProtoMessage ¶
func (*Request) ProtoMessage()
func (*Request) ProtoReflect ¶
func (x *Request) ProtoReflect() protoreflect.Message
type Request_builder ¶
type Request_builder struct {
Num uint64
// contains filtered or unexported fields
}
func (Request_builder) Build ¶
func (b0 Request_builder) Build() *Request
type Response ¶
type Response struct {
// contains filtered or unexported fields
}
func UnaryRPC ¶
func UnaryRPC(ctx *gorums.NodeContext, in *Request) (resp *Response, err error)
UnaryRPC is an RPC call invoked on the node in ctx.
func (*Response) GetInOrder ¶
func (*Response) ProtoMessage ¶
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶
func (x *Response) ProtoReflect() protoreflect.Message
func (*Response) SetInOrder ¶
type Response_builder ¶
type Response_builder struct {
InOrder bool
// contains filtered or unexported fields
}
func (Response_builder) Build ¶
func (b0 Response_builder) Build() *Response
Source Files