Documentation ¶
Index ¶
- type OperatorClient
- type OperatorClient_Call_Call
- func (_c *OperatorClient_Call_Call) Return(res []byte, err error) *OperatorClient_Call_Call
- func (_c *OperatorClient_Call_Call) Run(run func(_a0 context.Context, _a1 *jetflow.Request)) *OperatorClient_Call_Call
- func (_c *OperatorClient_Call_Call) RunAndReturn(run func(context.Context, *jetflow.Request) ([]byte, error)) *OperatorClient_Call_Call
- type OperatorClient_Expecter
- type OperatorClient_Find_Call
- func (_c *OperatorClient_Find_Call) Return(_a0 error) *OperatorClient_Find_Call
- func (_c *OperatorClient_Find_Call) Run(run func(ctx context.Context, id string, operator interface{})) *OperatorClient_Find_Call
- func (_c *OperatorClient_Find_Call) RunAndReturn(run func(context.Context, string, interface{}) error) *OperatorClient_Find_Call
- type OperatorHandler
- type OperatorHandler_Expecter
- type OperatorHandler_Handle_Call
- type Storage
- func (_m *Storage) Commit(_a0 context.Context, _a1 *jetflow.Request) error
- func (_m *Storage) EXPECT() *Storage_Expecter
- func (_m *Storage) Get(_a0 context.Context, _a1 *jetflow.Request) (jetflow.OperatorHandler, error)
- func (_m *Storage) Prepare(_a0 context.Context, _a1 *jetflow.Request) error
- func (_m *Storage) Rollback(_a0 context.Context, _a1 *jetflow.Request) error
- type Storage_Commit_Call
- type Storage_Expecter
- func (_e *Storage_Expecter) Commit(_a0 interface{}, _a1 interface{}) *Storage_Commit_Call
- func (_e *Storage_Expecter) Get(_a0 interface{}, _a1 interface{}) *Storage_Get_Call
- func (_e *Storage_Expecter) Prepare(_a0 interface{}, _a1 interface{}) *Storage_Prepare_Call
- func (_e *Storage_Expecter) Rollback(_a0 interface{}, _a1 interface{}) *Storage_Rollback_Call
- type Storage_Get_Call
- func (_c *Storage_Get_Call) Return(_a0 jetflow.OperatorHandler, _a1 error) *Storage_Get_Call
- func (_c *Storage_Get_Call) Run(run func(_a0 context.Context, _a1 *jetflow.Request)) *Storage_Get_Call
- func (_c *Storage_Get_Call) RunAndReturn(run func(context.Context, *jetflow.Request) (jetflow.OperatorHandler, error)) *Storage_Get_Call
- type Storage_Prepare_Call
- func (_c *Storage_Prepare_Call) Return(_a0 error) *Storage_Prepare_Call
- func (_c *Storage_Prepare_Call) Run(run func(_a0 context.Context, _a1 *jetflow.Request)) *Storage_Prepare_Call
- func (_c *Storage_Prepare_Call) RunAndReturn(run func(context.Context, *jetflow.Request) error) *Storage_Prepare_Call
- type Storage_Rollback_Call
- func (_c *Storage_Rollback_Call) Return(_a0 error) *Storage_Rollback_Call
- func (_c *Storage_Rollback_Call) Run(run func(_a0 context.Context, _a1 *jetflow.Request)) *Storage_Rollback_Call
- func (_c *Storage_Rollback_Call) RunAndReturn(run func(context.Context, *jetflow.Request) error) *Storage_Rollback_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type OperatorClient ¶
OperatorClient is an autogenerated mock type for the OperatorClient type
func NewOperatorClient ¶
func NewOperatorClient(t interface { mock.TestingT Cleanup(func()) }) *OperatorClient
NewOperatorClient creates a new instance of OperatorClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*OperatorClient) EXPECT ¶
func (_m *OperatorClient) EXPECT() *OperatorClient_Expecter
type OperatorClient_Call_Call ¶
OperatorClient_Call_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Call'
func (*OperatorClient_Call_Call) Return ¶
func (_c *OperatorClient_Call_Call) Return(res []byte, err error) *OperatorClient_Call_Call
func (*OperatorClient_Call_Call) Run ¶
func (_c *OperatorClient_Call_Call) Run(run func(_a0 context.Context, _a1 *jetflow.Request)) *OperatorClient_Call_Call
func (*OperatorClient_Call_Call) RunAndReturn ¶
func (_c *OperatorClient_Call_Call) RunAndReturn(run func(context.Context, *jetflow.Request) ([]byte, error)) *OperatorClient_Call_Call
type OperatorClient_Expecter ¶
type OperatorClient_Expecter struct {
// contains filtered or unexported fields
}
func (*OperatorClient_Expecter) Call ¶
func (_e *OperatorClient_Expecter) Call(_a0 interface{}, _a1 interface{}) *OperatorClient_Call_Call
Call is a helper method to define mock.On call
- _a0 context.Context
- _a1 *jetflow.Request
func (*OperatorClient_Expecter) Find ¶
func (_e *OperatorClient_Expecter) Find(ctx interface{}, id interface{}, operator interface{}) *OperatorClient_Find_Call
Find is a helper method to define mock.On call
- ctx context.Context
- id string
- operator interface{}
type OperatorClient_Find_Call ¶
OperatorClient_Find_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Find'
func (*OperatorClient_Find_Call) Return ¶
func (_c *OperatorClient_Find_Call) Return(_a0 error) *OperatorClient_Find_Call
func (*OperatorClient_Find_Call) Run ¶
func (_c *OperatorClient_Find_Call) Run(run func(ctx context.Context, id string, operator interface{})) *OperatorClient_Find_Call
func (*OperatorClient_Find_Call) RunAndReturn ¶
func (_c *OperatorClient_Find_Call) RunAndReturn(run func(context.Context, string, interface{}) error) *OperatorClient_Find_Call
type OperatorHandler ¶
OperatorHandler is an autogenerated mock type for the OperatorHandler type
func NewOperatorHandler ¶
func NewOperatorHandler(t interface { mock.TestingT Cleanup(func()) }) *OperatorHandler
NewOperatorHandler creates a new instance of OperatorHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*OperatorHandler) EXPECT ¶
func (_m *OperatorHandler) EXPECT() *OperatorHandler_Expecter
type OperatorHandler_Expecter ¶
type OperatorHandler_Expecter struct {
// contains filtered or unexported fields
}
func (*OperatorHandler_Expecter) Handle ¶
func (_e *OperatorHandler_Expecter) Handle(_a0 interface{}, _a1 interface{}, _a2 interface{}) *OperatorHandler_Handle_Call
Handle is a helper method to define mock.On call
- _a0 context.Context
- _a1 jetflow.OperatorClient
- _a2 *jetflow.Request
type OperatorHandler_Handle_Call ¶
OperatorHandler_Handle_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Handle'
func (*OperatorHandler_Handle_Call) Return ¶
func (_c *OperatorHandler_Handle_Call) Return(_a0 []byte, _a1 error) *OperatorHandler_Handle_Call
func (*OperatorHandler_Handle_Call) Run ¶
func (_c *OperatorHandler_Handle_Call) Run(run func(_a0 context.Context, _a1 jetflow.OperatorClient, _a2 *jetflow.Request)) *OperatorHandler_Handle_Call
func (*OperatorHandler_Handle_Call) RunAndReturn ¶
func (_c *OperatorHandler_Handle_Call) RunAndReturn(run func(context.Context, jetflow.OperatorClient, *jetflow.Request) ([]byte, error)) *OperatorHandler_Handle_Call
type Storage ¶
Storage is an autogenerated mock type for the Storage type
func NewStorage ¶
NewStorage creates a new instance of Storage. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.
func (*Storage) EXPECT ¶
func (_m *Storage) EXPECT() *Storage_Expecter
type Storage_Commit_Call ¶
Storage_Commit_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Commit'
func (*Storage_Commit_Call) Return ¶
func (_c *Storage_Commit_Call) Return(_a0 error) *Storage_Commit_Call
func (*Storage_Commit_Call) Run ¶
func (_c *Storage_Commit_Call) Run(run func(_a0 context.Context, _a1 *jetflow.Request)) *Storage_Commit_Call
func (*Storage_Commit_Call) RunAndReturn ¶
func (_c *Storage_Commit_Call) RunAndReturn(run func(context.Context, *jetflow.Request) error) *Storage_Commit_Call
type Storage_Expecter ¶
type Storage_Expecter struct {
// contains filtered or unexported fields
}
func (*Storage_Expecter) Commit ¶
func (_e *Storage_Expecter) Commit(_a0 interface{}, _a1 interface{}) *Storage_Commit_Call
Commit is a helper method to define mock.On call
- _a0 context.Context
- _a1 *jetflow.Request
func (*Storage_Expecter) Get ¶
func (_e *Storage_Expecter) Get(_a0 interface{}, _a1 interface{}) *Storage_Get_Call
Get is a helper method to define mock.On call
- _a0 context.Context
- _a1 *jetflow.Request
func (*Storage_Expecter) Prepare ¶
func (_e *Storage_Expecter) Prepare(_a0 interface{}, _a1 interface{}) *Storage_Prepare_Call
Prepare is a helper method to define mock.On call
- _a0 context.Context
- _a1 *jetflow.Request
func (*Storage_Expecter) Rollback ¶
func (_e *Storage_Expecter) Rollback(_a0 interface{}, _a1 interface{}) *Storage_Rollback_Call
Rollback is a helper method to define mock.On call
- _a0 context.Context
- _a1 *jetflow.Request
type Storage_Get_Call ¶
Storage_Get_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Get'
func (*Storage_Get_Call) Return ¶
func (_c *Storage_Get_Call) Return(_a0 jetflow.OperatorHandler, _a1 error) *Storage_Get_Call
func (*Storage_Get_Call) Run ¶
func (_c *Storage_Get_Call) Run(run func(_a0 context.Context, _a1 *jetflow.Request)) *Storage_Get_Call
func (*Storage_Get_Call) RunAndReturn ¶
func (_c *Storage_Get_Call) RunAndReturn(run func(context.Context, *jetflow.Request) (jetflow.OperatorHandler, error)) *Storage_Get_Call
type Storage_Prepare_Call ¶
Storage_Prepare_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Prepare'
func (*Storage_Prepare_Call) Return ¶
func (_c *Storage_Prepare_Call) Return(_a0 error) *Storage_Prepare_Call
func (*Storage_Prepare_Call) Run ¶
func (_c *Storage_Prepare_Call) Run(run func(_a0 context.Context, _a1 *jetflow.Request)) *Storage_Prepare_Call
func (*Storage_Prepare_Call) RunAndReturn ¶
func (_c *Storage_Prepare_Call) RunAndReturn(run func(context.Context, *jetflow.Request) error) *Storage_Prepare_Call
type Storage_Rollback_Call ¶
Storage_Rollback_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Rollback'
func (*Storage_Rollback_Call) Return ¶
func (_c *Storage_Rollback_Call) Return(_a0 error) *Storage_Rollback_Call
func (*Storage_Rollback_Call) Run ¶
func (_c *Storage_Rollback_Call) Run(run func(_a0 context.Context, _a1 *jetflow.Request)) *Storage_Rollback_Call
func (*Storage_Rollback_Call) RunAndReturn ¶
func (_c *Storage_Rollback_Call) RunAndReturn(run func(context.Context, *jetflow.Request) error) *Storage_Rollback_Call