Versions in this module Expand all Collapse all v0 v0.11.0 Jan 4, 2026 Changes in this version + var File_correctable_correctable_proto protoreflect.FileDescriptor + func Correctable(ctx *gorums.ConfigContext, in *Request, opts ...gorums.CallOption) *gorums.Responses[*Response] + func CorrectableStream(ctx *gorums.ConfigContext, in *Request, opts ...gorums.CallOption) *gorums.Responses[*Response] + func RegisterCorrectableTestServer(srv *gorums.Server, impl CorrectableTestServer) + type AsyncResponse = *gorums.Async[*Response] + type Configuration = gorums.Configuration + func NewConfig(opts ...gorums.Option) (Configuration, error) + func NewConfiguration(mgr *Manager, opt gorums.NodeListOption) (Configuration, error) + type CorrectableResponse = *gorums.Correctable[*Response] + type CorrectableTestServer interface + Correctable func(ctx gorums.ServerCtx, request *Request) (response *Response, err error) + CorrectableStream func(ctx gorums.ServerCtx, request *Request, send func(response *Response) error) error + type Manager = gorums.Manager + func NewManager(opts ...gorums.ManagerOption) *Manager + type Node = gorums.Node + type Request struct + func (*Request) ProtoMessage() + func (x *Request) ProtoReflect() protoreflect.Message + func (x *Request) Reset() + func (x *Request) String() string + type Request_builder struct + func (b0 Request_builder) Build() *Request + type Response struct + func (*Response) ProtoMessage() + func (x *Response) GetLevel() int32 + func (x *Response) ProtoReflect() protoreflect.Message + func (x *Response) Reset() + func (x *Response) SetLevel(v int32) + func (x *Response) String() string + type Response_builder struct + Level int32 + func (b0 Response_builder) Build() *Response