proto

type AsyncReadResponse ¶

type AsyncReadResponse = *gorums.Async[*ReadResponse]

AsyncReadResponse is a future for async quorum calls returning *ReadResponse.

type AsyncWriteResponse ¶

type AsyncWriteResponse = *gorums.Async[*WriteResponse]

AsyncWriteResponse is a future for async quorum calls returning *WriteResponse.

type ConfigContext ¶

type ConfigContext = gorums.ConfigContext

Type aliases for important Gorums types to make them more accessible from user code already interacting with the generated code.

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(opts ...gorums.Option) (Configuration, error)

	cfg, err := NewConfig(
	    gorums.WithNodeList([]string{"localhost:8080", "localhost:8081", "localhost:8082"}),
        gorums.WithDialOptions(grpc.WithTransportCredentials(insecure.NewCredentials())),
	)

func NewConfiguration(mgr *Manager, opt gorums.NodeListOption) (Configuration, error)

type CorrectableReadResponse ¶

type CorrectableReadResponse = *gorums.Correctable[*ReadResponse]

CorrectableReadResponse is a correctable object for quorum calls returning *ReadResponse.

type CorrectableWriteResponse ¶

type CorrectableWriteResponse = *gorums.Correctable[*WriteResponse]

CorrectableWriteResponse is a correctable object for quorum calls returning *WriteResponse.

type Manager ¶

type Manager = gorums.Manager

Type aliases for important Gorums types to make them more accessible from user code already interacting with the generated code.

func NewManager(opts ...gorums.ManagerOption) *Manager

type Node ¶

type Node = gorums.Node

Type aliases for important Gorums types to make them more accessible from user code already interacting with the generated code.

type NodeContext ¶

type NodeContext = gorums.NodeContext

Type aliases for important Gorums types to make them more accessible from user code already interacting with the generated code.

type ReadRequest ¶

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

ReadRequest is the request message for Read RPCs and Read quorum calls.

func (x *ReadRequest) GetKey() string

func (*ReadRequest) ProtoMessage()

func (x *ReadRequest) ProtoReflect() protoreflect.Message

func (x *ReadRequest) Reset()

func (x *ReadRequest) SetKey(v string)

func (x *ReadRequest) String() string

type ReadRequest_builder ¶

type ReadRequest_builder struct {
	Key string
	// contains filtered or unexported fields
}

func (b0 ReadRequest_builder) Build() *ReadRequest

type ReadResponse ¶

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

ReadResponse is the response message for Read RPCs and Read quorum calls.

func ReadRPC(ctx *NodeContext, in *ReadRequest) (*ReadResponse, error)

func (x *ReadResponse) ClearTime()

func (x *ReadResponse) GetOK() bool

func (x *ReadResponse) GetTime() *timestamppb.Timestamp

func (x *ReadResponse) GetValue() string

func (x *ReadResponse) HasTime() bool

func (*ReadResponse) ProtoMessage()

func (x *ReadResponse) ProtoReflect() protoreflect.Message

func (x *ReadResponse) Reset()

func (x *ReadResponse) SetOK(v bool)

func (x *ReadResponse) SetTime(v *timestamppb.Timestamp)

func (x *ReadResponse) SetValue(v string)

func (x *ReadResponse) String() string

type ReadResponse_builder ¶

type ReadResponse_builder struct {
	OK    bool
	Value string
	Time  *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (b0 ReadResponse_builder) Build() *ReadResponse

type StorageServer ¶

type StorageServer interface {
	ReadRPC(ctx gorums.ServerCtx, request *ReadRequest) (response *ReadResponse, err error)
	WriteRPC(ctx gorums.ServerCtx, request *WriteRequest) (response *WriteResponse, err error)
	ReadQC(ctx gorums.ServerCtx, request *ReadRequest) (response *ReadResponse, err error)
	WriteQC(ctx gorums.ServerCtx, request *WriteRequest) (response *WriteResponse, err error)
	WriteMulticast(ctx gorums.ServerCtx, request *WriteRequest)
}

Storage is the server-side API for the Storage Service

type WriteRequest ¶

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

WriteRequest is the request message for Write RPCs, Write quorum calls, and Write multicast calls.

func (x *WriteRequest) ClearTime()

func (x *WriteRequest) GetKey() string

func (x *WriteRequest) GetTime() *timestamppb.Timestamp

func (x *WriteRequest) GetValue() string

func (x *WriteRequest) HasTime() bool

func (*WriteRequest) ProtoMessage()

func (x *WriteRequest) ProtoReflect() protoreflect.Message

func (x *WriteRequest) Reset()

func (x *WriteRequest) SetKey(v string)

func (x *WriteRequest) SetTime(v *timestamppb.Timestamp)

func (x *WriteRequest) SetValue(v string)

func (x *WriteRequest) String() string

type WriteRequest_builder ¶

type WriteRequest_builder struct {
	Key   string
	Value string
	Time  *timestamppb.Timestamp
	// contains filtered or unexported fields
}

func (b0 WriteRequest_builder) Build() *WriteRequest

type WriteResponse ¶

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

WriteResponse is the response message for Write RPCs and Write quorum calls.

func WriteRPC(ctx *NodeContext, in *WriteRequest) (*WriteResponse, error)

func (x *WriteResponse) GetNew() bool

func (*WriteResponse) ProtoMessage()

func (x *WriteResponse) ProtoReflect() protoreflect.Message

func (x *WriteResponse) Reset()

func (x *WriteResponse) SetNew(v bool)

func (x *WriteResponse) String() string

type WriteResponse_builder ¶

type WriteResponse_builder struct {
	New bool
	// contains filtered or unexported fields
}

func (b0 WriteResponse_builder) Build() *WriteResponse