dev

type ConfigNotFoundError uint32

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

type CorrectableEmpty struct {

	// the actual reply
	*empty.Empty
	NodeIDs []uint32
	// contains filtered or unexported fields
}

type CorrectableMyResponse struct {

	// the actual reply
	*MyResponse
	NodeIDs []uint32
	// contains filtered or unexported fields
}

type CorrectableResponse struct {

	// the actual reply
	*Response
	NodeIDs []uint32
	// contains filtered or unexported fields
}

type CorrectableStreamEmpty struct {

	// the actual reply
	*empty.Empty
	NodeIDs []uint32
	// contains filtered or unexported fields
}

type CorrectableStreamMyResponse struct {

	// the actual reply
	*MyResponse
	NodeIDs []uint32
	// contains filtered or unexported fields
}

type CorrectableStreamResponse struct {

	// the actual reply
	*Response
	NodeIDs []uint32
	// contains filtered or unexported fields
}

type FutureEmpty struct {
	// the actual reply
	*empty.Empty
	NodeIDs []uint32
	// contains filtered or unexported fields
}

type FutureMyResponse struct {
	// the actual reply
	*MyResponse
	NodeIDs []uint32
	// contains filtered or unexported fields
}

type FutureResponse struct {
	// the actual reply
	*Response
	NodeIDs []uint32
	// contains filtered or unexported fields
}

type GRPCError struct {
	NodeID uint32
	Cause  error
}

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

type IllegalConfigError string

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

type ManagerOption func(*managerOptions)

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

type MyResponse struct {
	Value string `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

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

type NodeNotFoundError uint32

type QuorumCallError struct {
	Reason     string
	ReplyCount int
	Errors     []GRPCError
}

type QuorumSpec interface {

	// QuorumCallQF is the quorum function for the QuorumCall
	// quorum call method. The in parameter is the request object
	// supplied to the QuorumCall method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	QuorumCallQF(in *Request, replies map[uint32]*Response) (*Response, bool)

	// QuorumCallPerNodeArgQF is the quorum function for the QuorumCallPerNodeArg
	// quorum call method. The in parameter is the request object
	// supplied to the QuorumCallPerNodeArg method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	QuorumCallPerNodeArgQF(in *Request, replies map[uint32]*Response) (*Response, bool)

	// QuorumCallCustomReturnTypeQF is the quorum function for the QuorumCallCustomReturnType
	// quorum call method. The in parameter is the request object
	// supplied to the QuorumCallCustomReturnType method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	QuorumCallCustomReturnTypeQF(in *Request, replies map[uint32]*Response) (*MyResponse, bool)

	// QuorumCallComboQF is the quorum function for the QuorumCallCombo
	// quorum call method. The in parameter is the request object
	// supplied to the QuorumCallCombo method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	QuorumCallComboQF(in *Request, replies map[uint32]*Response) (*MyResponse, bool)

	// QuorumCallEmptyQF is the quorum function for the QuorumCallEmpty
	// quorum call method. The in parameter is the request object
	// supplied to the QuorumCallEmpty method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *empty.Empty'.
	QuorumCallEmptyQF(in *empty.Empty, replies map[uint32]*Response) (*Response, bool)

	// QuorumCallEmpty2QF is the quorum function for the QuorumCallEmpty2
	// quorum call method. The in parameter is the request object
	// supplied to the QuorumCallEmpty2 method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	QuorumCallEmpty2QF(in *Request, replies map[uint32]*empty.Empty) (*empty.Empty, bool)

	// QuorumCallFutureQF is the quorum function for the QuorumCallFuture
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallFuture method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	QuorumCallFutureQF(in *Request, replies map[uint32]*Response) (*Response, bool)

	// QuorumCallFuturePerNodeArgQF is the quorum function for the QuorumCallFuturePerNodeArg
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallFuturePerNodeArg method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	QuorumCallFuturePerNodeArgQF(in *Request, replies map[uint32]*Response) (*Response, bool)

	// QuorumCallFutureCustomReturnTypeQF is the quorum function for the QuorumCallFutureCustomReturnType
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallFutureCustomReturnType method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	QuorumCallFutureCustomReturnTypeQF(in *Request, replies map[uint32]*Response) (*MyResponse, bool)

	// QuorumCallFutureComboQF is the quorum function for the QuorumCallFutureCombo
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallFutureCombo method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	QuorumCallFutureComboQF(in *Request, replies map[uint32]*Response) (*MyResponse, bool)

	// QuorumCallFuture2QF is the quorum function for the QuorumCallFuture2
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallFuture2 method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	QuorumCallFuture2QF(in *Request, replies map[uint32]*Response) (*Response, bool)

	// QuorumCallFutureEmptyQF is the quorum function for the QuorumCallFutureEmpty
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallFutureEmpty method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	QuorumCallFutureEmptyQF(in *Request, replies map[uint32]*empty.Empty) (*empty.Empty, bool)

	// QuorumCallFutureEmpty2QF is the quorum function for the QuorumCallFutureEmpty2
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallFutureEmpty2 method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *empty.Empty'.
	QuorumCallFutureEmpty2QF(in *empty.Empty, replies map[uint32]*Response) (*Response, bool)

	// CorrectableQF is the quorum function for the Correctable
	// correctable quorum call method. The in parameter is the request object
	// supplied to the Correctable method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	CorrectableQF(in *Request, replies map[uint32]*Response) (*Response, int, bool)

	// CorrectablePerNodeArgQF is the quorum function for the CorrectablePerNodeArg
	// correctable quorum call method. The in parameter is the request object
	// supplied to the CorrectablePerNodeArg method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	CorrectablePerNodeArgQF(in *Request, replies map[uint32]*Response) (*Response, int, bool)

	// CorrectableCustomReturnTypeQF is the quorum function for the CorrectableCustomReturnType
	// correctable quorum call method. The in parameter is the request object
	// supplied to the CorrectableCustomReturnType method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	CorrectableCustomReturnTypeQF(in *Request, replies map[uint32]*Response) (*MyResponse, int, bool)

	// CorrectableComboQF is the quorum function for the CorrectableCombo
	// correctable quorum call method. The in parameter is the request object
	// supplied to the CorrectableCombo method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	CorrectableComboQF(in *Request, replies map[uint32]*Response) (*MyResponse, int, bool)

	// CorrectableEmptyQF is the quorum function for the CorrectableEmpty
	// correctable quorum call method. The in parameter is the request object
	// supplied to the CorrectableEmpty method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	CorrectableEmptyQF(in *Request, replies map[uint32]*empty.Empty) (*empty.Empty, int, bool)

	// CorrectableEmpty2QF is the quorum function for the CorrectableEmpty2
	// correctable quorum call method. The in parameter is the request object
	// supplied to the CorrectableEmpty2 method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *empty.Empty'.
	CorrectableEmpty2QF(in *empty.Empty, replies map[uint32]*Response) (*Response, int, bool)

	// CorrectableStreamQF is the quorum function for the CorrectableStream
	// correctable stream quorum call method. The in parameter is the request object
	// supplied to the CorrectableStream method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	CorrectableStreamQF(in *Request, replies map[uint32]*Response) (*Response, int, bool)

	// CorrectableStreamPerNodeArgQF is the quorum function for the CorrectableStreamPerNodeArg
	// correctable stream quorum call method. The in parameter is the request object
	// supplied to the CorrectableStreamPerNodeArg method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	CorrectableStreamPerNodeArgQF(in *Request, replies map[uint32]*Response) (*Response, int, bool)

	// CorrectableStreamCustomReturnTypeQF is the quorum function for the CorrectableStreamCustomReturnType
	// correctable stream quorum call method. The in parameter is the request object
	// supplied to the CorrectableStreamCustomReturnType method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	CorrectableStreamCustomReturnTypeQF(in *Request, replies map[uint32]*Response) (*MyResponse, int, bool)

	// CorrectableStreamComboQF is the quorum function for the CorrectableStreamCombo
	// correctable stream quorum call method. The in parameter is the request object
	// supplied to the CorrectableStreamCombo method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	CorrectableStreamComboQF(in *Request, replies map[uint32]*Response) (*MyResponse, int, bool)

	// CorrectableStreamEmptyQF is the quorum function for the CorrectableStreamEmpty
	// correctable stream quorum call method. The in parameter is the request object
	// supplied to the CorrectableStreamEmpty method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	CorrectableStreamEmptyQF(in *Request, replies map[uint32]*empty.Empty) (*empty.Empty, int, bool)

	// CorrectableStreamEmpty2QF is the quorum function for the CorrectableStreamEmpty2
	// correctable stream quorum call method. The in parameter is the request object
	// supplied to the CorrectableStreamEmpty2 method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *empty.Empty'.
	CorrectableStreamEmpty2QF(in *empty.Empty, replies map[uint32]*Response) (*Response, int, bool)

	// OrderingQCQF is the quorum function for the OrderingQC
	// ordered quorum call method. The in parameter is the request object
	// supplied to the OrderingQC method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	OrderingQCQF(in *Request, replies map[uint32]*Response) (*Response, bool)

	// OrderingPerNodeArgQF is the quorum function for the OrderingPerNodeArg
	// ordered quorum call method. The in parameter is the request object
	// supplied to the OrderingPerNodeArg method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	OrderingPerNodeArgQF(in *Request, replies map[uint32]*Response) (*Response, bool)

	// OrderingCustomReturnTypeQF is the quorum function for the OrderingCustomReturnType
	// ordered quorum call method. The in parameter is the request object
	// supplied to the OrderingCustomReturnType method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	OrderingCustomReturnTypeQF(in *Request, replies map[uint32]*Response) (*MyResponse, bool)

	// OrderingComboQF is the quorum function for the OrderingCombo
	// ordered quorum call method. The in parameter is the request object
	// supplied to the OrderingCombo method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	OrderingComboQF(in *Request, replies map[uint32]*Response) (*MyResponse, bool)

	// OrderingFutureQF is the quorum function for the OrderingFuture
	// asynchronous ordered quorum call method. The in parameter is the request object
	// supplied to the OrderingFuture method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	OrderingFutureQF(in *Request, replies map[uint32]*Response) (*Response, bool)

	// OrderingFuturePerNodeArgQF is the quorum function for the OrderingFuturePerNodeArg
	// asynchronous ordered quorum call method. The in parameter is the request object
	// supplied to the OrderingFuturePerNodeArg method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	OrderingFuturePerNodeArgQF(in *Request, replies map[uint32]*Response) (*Response, bool)

	// OrderingFutureCustomReturnTypeQF is the quorum function for the OrderingFutureCustomReturnType
	// asynchronous ordered quorum call method. The in parameter is the request object
	// supplied to the OrderingFutureCustomReturnType method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	OrderingFutureCustomReturnTypeQF(in *Request, replies map[uint32]*Response) (*MyResponse, bool)

	// OrderingFutureComboQF is the quorum function for the OrderingFutureCombo
	// asynchronous ordered quorum call method. The in parameter is the request object
	// supplied to the OrderingFutureCombo method at call time, and may or may not
	// be used by the quorum function. If the in parameter is not needed
	// you should implement your quorum function with '_ *Request'.
	OrderingFutureComboQF(in *Request, replies map[uint32]*Response) (*MyResponse, bool)
}

type Request struct {
	Value string `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
	// contains filtered or unexported fields
}

type Response struct {
	Result int64 `protobuf:"varint,1,opt,name=Result,proto3" json:"Result,omitempty"`
	// contains filtered or unexported fields
}

type ServerOption func(*serverOptions)

type UnimplementedZorumsServiceServer struct {
}

type ZorumsService interface {
	Multicast(context.Context, *Request)
	MulticastPerNodeArg(context.Context, *Request)
	Multicast2(context.Context, *Request)
	Multicast3(context.Context, *Request)
	Multicast4(context.Context, *empty.Empty)
	OrderingQC(context.Context, *Request, func(*Response, error))
	OrderingPerNodeArg(context.Context, *Request, func(*Response, error))
	OrderingCustomReturnType(context.Context, *Request, func(*Response, error))
	OrderingCombo(context.Context, *Request, func(*Response, error))
	OrderingUnaryRPC(context.Context, *Request, func(*Response, error))
	OrderingFuture(context.Context, *Request, func(*Response, error))
	OrderingFuturePerNodeArg(context.Context, *Request, func(*Response, error))
	OrderingFutureCustomReturnType(context.Context, *Request, func(*Response, error))
	OrderingFutureCombo(context.Context, *Request, func(*Response, error))
	Unicast(context.Context, *Request)
	Unicast2(context.Context, *Request)
}

type ZorumsServiceClient interface {
	// GRPCCall plain gRPC call; testing that Gorums can ignore these, but that
	// they are added to the _grpc.pb.go generated file.
	GRPCCall(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// QuorumCall plain.
	QuorumCall(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// QuorumCall with per_node_arg option.
	QuorumCallPerNodeArg(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// QuorumCall with custom_return_type option.
	QuorumCallCustomReturnType(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// QuorumCallCombo with all supported options.
	QuorumCallCombo(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// QuorumCallEmpty for testing imported message type.
	QuorumCallEmpty(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Response, error)
	// QuorumCallEmpty2 for testing imported message type.
	QuorumCallEmpty2(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)
	// Multicast plain. Response type is not needed here.
	Multicast(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// MulticastPerNodeArg with per_node_arg option.
	MulticastPerNodeArg(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// Multicast2 is testing whether multiple streams work.
	Multicast2(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// Multicast3 is testing imported message type.
	Multicast3(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)
	// Multicast4 is testing imported message type.
	Multicast4(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
	// QuorumCallFuture plain.
	QuorumCallFuture(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// QuorumCallFuturePerNodeArg with per_node_arg option.
	QuorumCallFuturePerNodeArg(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// QuorumCallFutureCustomReturnType with custom_return_type option.
	QuorumCallFutureCustomReturnType(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// QuorumCallFutureCombo with all supported options.
	QuorumCallFutureCombo(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// QuorumCallFuture2 plain; with same return type: Response.
	QuorumCallFuture2(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// QuorumCallFutureEmpty for testing imported message type.
	QuorumCallFutureEmpty(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)
	// QuorumCallFutureEmpty2 for testing imported message type; with same return
	// type as QuorumCallFuture: Response.
	QuorumCallFutureEmpty2(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Response, error)
	// Correctable plain.
	Correctable(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// CorrectablePerNodeArg with per_node_arg option.
	CorrectablePerNodeArg(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// CorrectableCustomReturnType with custom_return_type option.
	CorrectableCustomReturnType(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// CorrectableCombo with all supported options.
	CorrectableCombo(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// CorrectableEmpty for testing imported message type.
	CorrectableEmpty(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)
	// CorrectableEmpty2 for testing imported message type; with same return
	// type as Correctable: Response.
	CorrectableEmpty2(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Response, error)
	// CorrectableStream plain.
	CorrectableStream(ctx context.Context, in *Request, opts ...grpc.CallOption) (ZorumsService_CorrectableStreamClient, error)
	// CorrectablePerNodeArg with per_node_arg option.
	CorrectableStreamPerNodeArg(ctx context.Context, in *Request, opts ...grpc.CallOption) (ZorumsService_CorrectableStreamPerNodeArgClient, error)
	// CorrectableCustomReturnType with custom_return_type option.
	CorrectableStreamCustomReturnType(ctx context.Context, in *Request, opts ...grpc.CallOption) (ZorumsService_CorrectableStreamCustomReturnTypeClient, error)
	// CorrectableCombo with all supported options.
	CorrectableStreamCombo(ctx context.Context, in *Request, opts ...grpc.CallOption) (ZorumsService_CorrectableStreamComboClient, error)
	// CorrectableEmpty for testing imported message type.
	CorrectableStreamEmpty(ctx context.Context, in *Request, opts ...grpc.CallOption) (ZorumsService_CorrectableStreamEmptyClient, error)
	// CorrectableEmpty2 for testing imported message type; with same return
	// type as Correctable: Response.
	CorrectableStreamEmpty2(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (ZorumsService_CorrectableStreamEmpty2Client, error)
	OrderingQC(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	OrderingPerNodeArg(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	OrderingCustomReturnType(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	OrderingCombo(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	// OrderingUnaryRPC is testing that we can create ordered Unary RPCs
	OrderingUnaryRPC(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	OrderingFuture(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	OrderingFuturePerNodeArg(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	OrderingFutureCustomReturnType(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	OrderingFutureCombo(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	Unicast(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	Unicast2(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)
}

type ZorumsServiceServer interface {
	// GRPCCall plain gRPC call; testing that Gorums can ignore these, but that
	// they are added to the _grpc.pb.go generated file.
	GRPCCall(context.Context, *Request) (*Response, error)
	// QuorumCall plain.
	QuorumCall(context.Context, *Request) (*Response, error)
	// QuorumCall with per_node_arg option.
	QuorumCallPerNodeArg(context.Context, *Request) (*Response, error)
	// QuorumCall with custom_return_type option.
	QuorumCallCustomReturnType(context.Context, *Request) (*Response, error)
	// QuorumCallCombo with all supported options.
	QuorumCallCombo(context.Context, *Request) (*Response, error)
	// QuorumCallEmpty for testing imported message type.
	QuorumCallEmpty(context.Context, *empty.Empty) (*Response, error)
	// QuorumCallEmpty2 for testing imported message type.
	QuorumCallEmpty2(context.Context, *Request) (*empty.Empty, error)
	// Multicast plain. Response type is not needed here.
	Multicast(context.Context, *Request) (*Response, error)
	// MulticastPerNodeArg with per_node_arg option.
	MulticastPerNodeArg(context.Context, *Request) (*Response, error)
	// Multicast2 is testing whether multiple streams work.
	Multicast2(context.Context, *Request) (*Response, error)
	// Multicast3 is testing imported message type.
	Multicast3(context.Context, *Request) (*empty.Empty, error)
	// Multicast4 is testing imported message type.
	Multicast4(context.Context, *empty.Empty) (*empty.Empty, error)
	// QuorumCallFuture plain.
	QuorumCallFuture(context.Context, *Request) (*Response, error)
	// QuorumCallFuturePerNodeArg with per_node_arg option.
	QuorumCallFuturePerNodeArg(context.Context, *Request) (*Response, error)
	// QuorumCallFutureCustomReturnType with custom_return_type option.
	QuorumCallFutureCustomReturnType(context.Context, *Request) (*Response, error)
	// QuorumCallFutureCombo with all supported options.
	QuorumCallFutureCombo(context.Context, *Request) (*Response, error)
	// QuorumCallFuture2 plain; with same return type: Response.
	QuorumCallFuture2(context.Context, *Request) (*Response, error)
	// QuorumCallFutureEmpty for testing imported message type.
	QuorumCallFutureEmpty(context.Context, *Request) (*empty.Empty, error)
	// QuorumCallFutureEmpty2 for testing imported message type; with same return
	// type as QuorumCallFuture: Response.
	QuorumCallFutureEmpty2(context.Context, *empty.Empty) (*Response, error)
	// Correctable plain.
	Correctable(context.Context, *Request) (*Response, error)
	// CorrectablePerNodeArg with per_node_arg option.
	CorrectablePerNodeArg(context.Context, *Request) (*Response, error)
	// CorrectableCustomReturnType with custom_return_type option.
	CorrectableCustomReturnType(context.Context, *Request) (*Response, error)
	// CorrectableCombo with all supported options.
	CorrectableCombo(context.Context, *Request) (*Response, error)
	// CorrectableEmpty for testing imported message type.
	CorrectableEmpty(context.Context, *Request) (*empty.Empty, error)
	// CorrectableEmpty2 for testing imported message type; with same return
	// type as Correctable: Response.
	CorrectableEmpty2(context.Context, *empty.Empty) (*Response, error)
	// CorrectableStream plain.
	CorrectableStream(*Request, ZorumsService_CorrectableStreamServer) error
	// CorrectablePerNodeArg with per_node_arg option.
	CorrectableStreamPerNodeArg(*Request, ZorumsService_CorrectableStreamPerNodeArgServer) error
	// CorrectableCustomReturnType with custom_return_type option.
	CorrectableStreamCustomReturnType(*Request, ZorumsService_CorrectableStreamCustomReturnTypeServer) error
	// CorrectableCombo with all supported options.
	CorrectableStreamCombo(*Request, ZorumsService_CorrectableStreamComboServer) error
	// CorrectableEmpty for testing imported message type.
	CorrectableStreamEmpty(*Request, ZorumsService_CorrectableStreamEmptyServer) error
	// CorrectableEmpty2 for testing imported message type; with same return
	// type as Correctable: Response.
	CorrectableStreamEmpty2(*empty.Empty, ZorumsService_CorrectableStreamEmpty2Server) error
	OrderingQC(context.Context, *Request) (*Response, error)
	OrderingPerNodeArg(context.Context, *Request) (*Response, error)
	OrderingCustomReturnType(context.Context, *Request) (*Response, error)
	OrderingCombo(context.Context, *Request) (*Response, error)
	// OrderingUnaryRPC is testing that we can create ordered Unary RPCs
	OrderingUnaryRPC(context.Context, *Request) (*Response, error)
	OrderingFuture(context.Context, *Request) (*Response, error)
	OrderingFuturePerNodeArg(context.Context, *Request) (*Response, error)
	OrderingFutureCustomReturnType(context.Context, *Request) (*Response, error)
	OrderingFutureCombo(context.Context, *Request) (*Response, error)
	Unicast(context.Context, *Request) (*Response, error)
	Unicast2(context.Context, *Request) (*empty.Empty, error)
	// contains filtered or unexported methods
}

type ZorumsService_CorrectableStreamClient interface {
	Recv() (*Response, error)
	grpc.ClientStream
}

type ZorumsService_CorrectableStreamComboClient interface {
	Recv() (*Response, error)
	grpc.ClientStream
}

type ZorumsService_CorrectableStreamComboServer interface {
	Send(*Response) error
	grpc.ServerStream
}

type ZorumsService_CorrectableStreamCustomReturnTypeClient interface {
	Recv() (*Response, error)
	grpc.ClientStream
}

type ZorumsService_CorrectableStreamCustomReturnTypeServer interface {
	Send(*Response) error
	grpc.ServerStream
}

type ZorumsService_CorrectableStreamEmpty2Client interface {
	Recv() (*Response, error)
	grpc.ClientStream
}

type ZorumsService_CorrectableStreamEmpty2Server interface {
	Send(*Response) error
	grpc.ServerStream
}

type ZorumsService_CorrectableStreamEmptyClient interface {
	Recv() (*empty.Empty, error)
	grpc.ClientStream
}

type ZorumsService_CorrectableStreamEmptyServer interface {
	Send(*empty.Empty) error
	grpc.ServerStream
}

type ZorumsService_CorrectableStreamPerNodeArgClient interface {
	Recv() (*Response, error)
	grpc.ClientStream
}

type ZorumsService_CorrectableStreamPerNodeArgServer interface {
	Send(*Response) error
	grpc.ServerStream
}

type ZorumsService_CorrectableStreamServer interface {
	Send(*Response) error
	grpc.ServerStream
}