dev

type AsyncEmpty struct {
	*gorums.Async
}

type AsyncMyResponse struct {
	*gorums.Async
}

type AsyncResponse struct {
	*gorums.Async
}

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

type CorrectableEmpty struct {
	*gorums.Correctable
}

type CorrectableMyResponse struct {
	*gorums.Correctable
}

type CorrectableResponse struct {
	*gorums.Correctable
}

type CorrectableStreamEmpty struct {
	*gorums.Correctable
}

type CorrectableStreamMyResponse struct {
	*gorums.Correctable
}

type CorrectableStreamResponse struct {
	*gorums.Correctable
}

type Manager struct {
	*gorums.Manager
}

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

type Node struct {
	*gorums.Node
}

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 '_ *emptypb.Empty'.
	QuorumCallEmptyQF(in *emptypb.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]*emptypb.Empty) (*emptypb.Empty, bool)

	// QuorumCallAsyncQF is the quorum function for the QuorumCallAsync
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallAsync 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'.
	QuorumCallAsyncQF(in *Request, replies map[uint32]*Response) (*Response, bool)

	// QuorumCallAsyncPerNodeArgQF is the quorum function for the QuorumCallAsyncPerNodeArg
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallAsyncPerNodeArg 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'.
	QuorumCallAsyncPerNodeArgQF(in *Request, replies map[uint32]*Response) (*Response, bool)

	// QuorumCallAsyncCustomReturnTypeQF is the quorum function for the QuorumCallAsyncCustomReturnType
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallAsyncCustomReturnType 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'.
	QuorumCallAsyncCustomReturnTypeQF(in *Request, replies map[uint32]*Response) (*MyResponse, bool)

	// QuorumCallAsyncComboQF is the quorum function for the QuorumCallAsyncCombo
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallAsyncCombo 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'.
	QuorumCallAsyncComboQF(in *Request, replies map[uint32]*Response) (*MyResponse, bool)

	// QuorumCallAsync2QF is the quorum function for the QuorumCallAsync2
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallAsync2 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'.
	QuorumCallAsync2QF(in *Request, replies map[uint32]*Response) (*Response, bool)

	// QuorumCallAsyncEmptyQF is the quorum function for the QuorumCallAsyncEmpty
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallAsyncEmpty 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'.
	QuorumCallAsyncEmptyQF(in *Request, replies map[uint32]*emptypb.Empty) (*emptypb.Empty, bool)

	// QuorumCallAsyncEmpty2QF is the quorum function for the QuorumCallAsyncEmpty2
	// asynchronous quorum call method. The in parameter is the request object
	// supplied to the QuorumCallAsyncEmpty2 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 '_ *emptypb.Empty'.
	QuorumCallAsyncEmpty2QF(in *emptypb.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]*emptypb.Empty) (*emptypb.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 '_ *emptypb.Empty'.
	CorrectableEmpty2QF(in *emptypb.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]*emptypb.Empty) (*emptypb.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 '_ *emptypb.Empty'.
	CorrectableStreamEmpty2QF(in *emptypb.Empty, replies map[uint32]*Response) (*Response, int, 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 ZorumsService interface {
	GRPCCall(context.Context, *Request, func(*Response, error))
	QuorumCall(context.Context, *Request, func(*Response, error))
	QuorumCallPerNodeArg(context.Context, *Request, func(*Response, error))
	QuorumCallCustomReturnType(context.Context, *Request, func(*Response, error))
	QuorumCallCombo(context.Context, *Request, func(*Response, error))
	QuorumCallEmpty(context.Context, *emptypb.Empty, func(*Response, error))
	QuorumCallEmpty2(context.Context, *Request, func(*emptypb.Empty, error))
	Multicast(context.Context, *Request)
	MulticastPerNodeArg(context.Context, *Request)
	Multicast2(context.Context, *Request)
	Multicast3(context.Context, *Request)
	Multicast4(context.Context, *emptypb.Empty)
	QuorumCallAsync(context.Context, *Request, func(*Response, error))
	QuorumCallAsyncPerNodeArg(context.Context, *Request, func(*Response, error))
	QuorumCallAsyncCustomReturnType(context.Context, *Request, func(*Response, error))
	QuorumCallAsyncCombo(context.Context, *Request, func(*Response, error))
	QuorumCallAsync2(context.Context, *Request, func(*Response, error))
	QuorumCallAsyncEmpty(context.Context, *Request, func(*emptypb.Empty, error))
	QuorumCallAsyncEmpty2(context.Context, *emptypb.Empty, func(*Response, error))
	Correctable(context.Context, *Request, func(*Response, error))
	CorrectablePerNodeArg(context.Context, *Request, func(*Response, error))
	CorrectableCustomReturnType(context.Context, *Request, func(*Response, error))
	CorrectableCombo(context.Context, *Request, func(*Response, error))
	CorrectableEmpty(context.Context, *Request, func(*emptypb.Empty, error))
	CorrectableEmpty2(context.Context, *emptypb.Empty, func(*Response, error))
	CorrectableStream(context.Context, *Request, func(*Response, error))
	CorrectableStreamPerNodeArg(context.Context, *Request, func(*Response, error))
	CorrectableStreamCustomReturnType(context.Context, *Request, func(*Response, error))
	CorrectableStreamCombo(context.Context, *Request, func(*Response, error))
	CorrectableStreamEmpty(context.Context, *Request, func(*emptypb.Empty, error))
	CorrectableStreamEmpty2(context.Context, *emptypb.Empty, func(*Response, error))
	Unicast(context.Context, *Request)
	Unicast2(context.Context, *Request)
}