Documentation ¶
Index ¶
- type ModelTransformer
- type ModelTransformer_Expecter
- type ModelTransformer_GetInput_Call
- type ModelTransformer_Transform_Call
- func (_c *ModelTransformer_Transform_Call) Return(out mdlsub.Model, err error) *ModelTransformer_Transform_Call
- func (_c *ModelTransformer_Transform_Call) Run(run func(ctx context.Context, inp interface{})) *ModelTransformer_Transform_Call
- func (_c *ModelTransformer_Transform_Call) RunAndReturn(run func(context.Context, interface{}) (mdlsub.Model, error)) *ModelTransformer_Transform_Call
- type Output
- type Output_Expecter
- type Output_Persist_Call
- func (_c *Output_Persist_Call) Return(_a0 error) *Output_Persist_Call
- func (_c *Output_Persist_Call) Run(run func(ctx context.Context, model mdlsub.Model, op string)) *Output_Persist_Call
- func (_c *Output_Persist_Call) RunAndReturn(run func(context.Context, mdlsub.Model, string) error) *Output_Persist_Call
- type Publisher
- type Publisher_Expecter
- type Publisher_PublishBatch_Call
- type Publisher_Publish_Call
- type SubscriberCore
- func (_m *SubscriberCore) EXPECT() *SubscriberCore_Expecter
- func (_m *SubscriberCore) GetLatestModelIdVersion(modelId mdl.ModelId) (int, error)
- func (_m *SubscriberCore) GetModelIds() []string
- func (_m *SubscriberCore) GetOutput(spec *mdlsub.ModelSpecification) (mdlsub.Output, error)
- func (_m *SubscriberCore) GetTransformer(spec *mdlsub.ModelSpecification) (mdlsub.ModelTransformer, error)
- func (_m *SubscriberCore) Persist(ctx context.Context, spec *mdlsub.ModelSpecification, model mdlsub.Model) error
- func (_m *SubscriberCore) Transform(ctx context.Context, spec *mdlsub.ModelSpecification, input interface{}) (mdlsub.Model, error)
- type SubscriberCore_Expecter
- func (_e *SubscriberCore_Expecter) GetLatestModelIdVersion(modelId interface{}) *SubscriberCore_GetLatestModelIdVersion_Call
- func (_e *SubscriberCore_Expecter) GetModelIds() *SubscriberCore_GetModelIds_Call
- func (_e *SubscriberCore_Expecter) GetOutput(spec interface{}) *SubscriberCore_GetOutput_Call
- func (_e *SubscriberCore_Expecter) GetTransformer(spec interface{}) *SubscriberCore_GetTransformer_Call
- func (_e *SubscriberCore_Expecter) Persist(ctx interface{}, spec interface{}, model interface{}) *SubscriberCore_Persist_Call
- func (_e *SubscriberCore_Expecter) Transform(ctx interface{}, spec interface{}, input interface{}) *SubscriberCore_Transform_Call
- type SubscriberCore_GetLatestModelIdVersion_Call
- func (_c *SubscriberCore_GetLatestModelIdVersion_Call) Return(_a0 int, _a1 error) *SubscriberCore_GetLatestModelIdVersion_Call
- func (_c *SubscriberCore_GetLatestModelIdVersion_Call) Run(run func(modelId mdl.ModelId)) *SubscriberCore_GetLatestModelIdVersion_Call
- func (_c *SubscriberCore_GetLatestModelIdVersion_Call) RunAndReturn(run func(mdl.ModelId) (int, error)) *SubscriberCore_GetLatestModelIdVersion_Call
- type SubscriberCore_GetModelIds_Call
- type SubscriberCore_GetOutput_Call
- func (_c *SubscriberCore_GetOutput_Call) Return(_a0 mdlsub.Output, _a1 error) *SubscriberCore_GetOutput_Call
- func (_c *SubscriberCore_GetOutput_Call) Run(run func(spec *mdlsub.ModelSpecification)) *SubscriberCore_GetOutput_Call
- func (_c *SubscriberCore_GetOutput_Call) RunAndReturn(run func(*mdlsub.ModelSpecification) (mdlsub.Output, error)) *SubscriberCore_GetOutput_Call
- type SubscriberCore_GetTransformer_Call
- func (_c *SubscriberCore_GetTransformer_Call) Return(_a0 mdlsub.ModelTransformer, _a1 error) *SubscriberCore_GetTransformer_Call
- func (_c *SubscriberCore_GetTransformer_Call) Run(run func(spec *mdlsub.ModelSpecification)) *SubscriberCore_GetTransformer_Call
- func (_c *SubscriberCore_GetTransformer_Call) RunAndReturn(run func(*mdlsub.ModelSpecification) (mdlsub.ModelTransformer, error)) *SubscriberCore_GetTransformer_Call
- type SubscriberCore_Persist_Call
- func (_c *SubscriberCore_Persist_Call) Return(_a0 error) *SubscriberCore_Persist_Call
- func (_c *SubscriberCore_Persist_Call) Run(...) *SubscriberCore_Persist_Call
- func (_c *SubscriberCore_Persist_Call) RunAndReturn(run func(context.Context, *mdlsub.ModelSpecification, mdlsub.Model) error) *SubscriberCore_Persist_Call
- type SubscriberCore_Transform_Call
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ModelTransformer ¶
ModelTransformer is an autogenerated mock type for the ModelTransformer type
func NewModelTransformer ¶
func NewModelTransformer(t interface { mock.TestingT Cleanup(func()) }) *ModelTransformer
NewModelTransformer creates a new instance of ModelTransformer. 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 (*ModelTransformer) EXPECT ¶
func (_m *ModelTransformer) EXPECT() *ModelTransformer_Expecter
func (*ModelTransformer) GetInput ¶
func (_m *ModelTransformer) GetInput() interface{}
GetInput provides a mock function with given fields:
type ModelTransformer_Expecter ¶
type ModelTransformer_Expecter struct {
// contains filtered or unexported fields
}
func (*ModelTransformer_Expecter) GetInput ¶
func (_e *ModelTransformer_Expecter) GetInput() *ModelTransformer_GetInput_Call
GetInput is a helper method to define mock.On call
func (*ModelTransformer_Expecter) Transform ¶
func (_e *ModelTransformer_Expecter) Transform(ctx interface{}, inp interface{}) *ModelTransformer_Transform_Call
Transform is a helper method to define mock.On call
- ctx context.Context
- inp interface{}
type ModelTransformer_GetInput_Call ¶
ModelTransformer_GetInput_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetInput'
func (*ModelTransformer_GetInput_Call) Return ¶
func (_c *ModelTransformer_GetInput_Call) Return(_a0 interface{}) *ModelTransformer_GetInput_Call
func (*ModelTransformer_GetInput_Call) Run ¶
func (_c *ModelTransformer_GetInput_Call) Run(run func()) *ModelTransformer_GetInput_Call
func (*ModelTransformer_GetInput_Call) RunAndReturn ¶
func (_c *ModelTransformer_GetInput_Call) RunAndReturn(run func() interface{}) *ModelTransformer_GetInput_Call
type ModelTransformer_Transform_Call ¶
ModelTransformer_Transform_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Transform'
func (*ModelTransformer_Transform_Call) Return ¶
func (_c *ModelTransformer_Transform_Call) Return(out mdlsub.Model, err error) *ModelTransformer_Transform_Call
func (*ModelTransformer_Transform_Call) Run ¶
func (_c *ModelTransformer_Transform_Call) Run(run func(ctx context.Context, inp interface{})) *ModelTransformer_Transform_Call
func (*ModelTransformer_Transform_Call) RunAndReturn ¶
func (_c *ModelTransformer_Transform_Call) RunAndReturn(run func(context.Context, interface{}) (mdlsub.Model, error)) *ModelTransformer_Transform_Call
type Output ¶ added in v0.26.0
Output is an autogenerated mock type for the Output type
func NewOutput ¶ added in v0.26.0
NewOutput creates a new instance of Output. 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 (*Output) EXPECT ¶ added in v0.26.0
func (_m *Output) EXPECT() *Output_Expecter
type Output_Expecter ¶ added in v0.26.0
type Output_Expecter struct {
// contains filtered or unexported fields
}
func (*Output_Expecter) Persist ¶ added in v0.26.0
func (_e *Output_Expecter) Persist(ctx interface{}, model interface{}, op interface{}) *Output_Persist_Call
Persist is a helper method to define mock.On call
- ctx context.Context
- model mdlsub.Model
- op string
type Output_Persist_Call ¶ added in v0.26.0
Output_Persist_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Persist'
func (*Output_Persist_Call) Return ¶ added in v0.26.0
func (_c *Output_Persist_Call) Return(_a0 error) *Output_Persist_Call
func (*Output_Persist_Call) Run ¶ added in v0.26.0
func (_c *Output_Persist_Call) Run(run func(ctx context.Context, model mdlsub.Model, op string)) *Output_Persist_Call
func (*Output_Persist_Call) RunAndReturn ¶ added in v0.26.0
func (_c *Output_Persist_Call) RunAndReturn(run func(context.Context, mdlsub.Model, string) error) *Output_Persist_Call
type Publisher ¶
Publisher is an autogenerated mock type for the Publisher type
func NewPublisher ¶
NewPublisher creates a new instance of Publisher. 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 (*Publisher) EXPECT ¶
func (_m *Publisher) EXPECT() *Publisher_Expecter
type Publisher_Expecter ¶
type Publisher_Expecter struct {
// contains filtered or unexported fields
}
func (*Publisher_Expecter) Publish ¶
func (_e *Publisher_Expecter) Publish(ctx interface{}, typ interface{}, version interface{}, value interface{}, customAttributes ...interface{}) *Publisher_Publish_Call
Publish is a helper method to define mock.On call
- ctx context.Context
- typ string
- version int
- value interface{}
- customAttributes ...map[string]string
func (*Publisher_Expecter) PublishBatch ¶
func (_e *Publisher_Expecter) PublishBatch(ctx interface{}, typ interface{}, version interface{}, values interface{}, customAttributes ...interface{}) *Publisher_PublishBatch_Call
PublishBatch is a helper method to define mock.On call
- ctx context.Context
- typ string
- version int
- values []interface{}
- customAttributes ...map[string]string
type Publisher_PublishBatch_Call ¶
Publisher_PublishBatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PublishBatch'
func (*Publisher_PublishBatch_Call) Return ¶
func (_c *Publisher_PublishBatch_Call) Return(_a0 error) *Publisher_PublishBatch_Call
func (*Publisher_PublishBatch_Call) Run ¶
func (_c *Publisher_PublishBatch_Call) Run(run func(ctx context.Context, typ string, version int, values []interface{}, customAttributes ...map[string]string)) *Publisher_PublishBatch_Call
func (*Publisher_PublishBatch_Call) RunAndReturn ¶
func (_c *Publisher_PublishBatch_Call) RunAndReturn(run func(context.Context, string, int, []interface{}, ...map[string]string) error) *Publisher_PublishBatch_Call
type Publisher_Publish_Call ¶
Publisher_Publish_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Publish'
func (*Publisher_Publish_Call) Return ¶
func (_c *Publisher_Publish_Call) Return(_a0 error) *Publisher_Publish_Call
func (*Publisher_Publish_Call) Run ¶
func (_c *Publisher_Publish_Call) Run(run func(ctx context.Context, typ string, version int, value interface{}, customAttributes ...map[string]string)) *Publisher_Publish_Call
func (*Publisher_Publish_Call) RunAndReturn ¶
func (_c *Publisher_Publish_Call) RunAndReturn(run func(context.Context, string, int, interface{}, ...map[string]string) error) *Publisher_Publish_Call
type SubscriberCore ¶ added in v0.26.0
SubscriberCore is an autogenerated mock type for the SubscriberCore type
func NewSubscriberCore ¶ added in v0.26.0
func NewSubscriberCore(t interface { mock.TestingT Cleanup(func()) }) *SubscriberCore
NewSubscriberCore creates a new instance of SubscriberCore. 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 (*SubscriberCore) EXPECT ¶ added in v0.26.0
func (_m *SubscriberCore) EXPECT() *SubscriberCore_Expecter
func (*SubscriberCore) GetLatestModelIdVersion ¶ added in v0.26.0
func (_m *SubscriberCore) GetLatestModelIdVersion(modelId mdl.ModelId) (int, error)
GetLatestModelIdVersion provides a mock function with given fields: modelId
func (*SubscriberCore) GetModelIds ¶ added in v0.26.0
func (_m *SubscriberCore) GetModelIds() []string
GetModelIds provides a mock function with given fields:
func (*SubscriberCore) GetOutput ¶ added in v0.26.0
func (_m *SubscriberCore) GetOutput(spec *mdlsub.ModelSpecification) (mdlsub.Output, error)
GetOutput provides a mock function with given fields: spec
func (*SubscriberCore) GetTransformer ¶ added in v0.26.0
func (_m *SubscriberCore) GetTransformer(spec *mdlsub.ModelSpecification) (mdlsub.ModelTransformer, error)
GetTransformer provides a mock function with given fields: spec
func (*SubscriberCore) Persist ¶ added in v0.26.0
func (_m *SubscriberCore) Persist(ctx context.Context, spec *mdlsub.ModelSpecification, model mdlsub.Model) error
Persist provides a mock function with given fields: ctx, spec, model
func (*SubscriberCore) Transform ¶ added in v0.26.0
func (_m *SubscriberCore) Transform(ctx context.Context, spec *mdlsub.ModelSpecification, input interface{}) (mdlsub.Model, error)
Transform provides a mock function with given fields: ctx, spec, input
type SubscriberCore_Expecter ¶ added in v0.26.0
type SubscriberCore_Expecter struct {
// contains filtered or unexported fields
}
func (*SubscriberCore_Expecter) GetLatestModelIdVersion ¶ added in v0.26.0
func (_e *SubscriberCore_Expecter) GetLatestModelIdVersion(modelId interface{}) *SubscriberCore_GetLatestModelIdVersion_Call
GetLatestModelIdVersion is a helper method to define mock.On call
- modelId mdl.ModelId
func (*SubscriberCore_Expecter) GetModelIds ¶ added in v0.26.0
func (_e *SubscriberCore_Expecter) GetModelIds() *SubscriberCore_GetModelIds_Call
GetModelIds is a helper method to define mock.On call
func (*SubscriberCore_Expecter) GetOutput ¶ added in v0.26.0
func (_e *SubscriberCore_Expecter) GetOutput(spec interface{}) *SubscriberCore_GetOutput_Call
GetOutput is a helper method to define mock.On call
- spec *mdlsub.ModelSpecification
func (*SubscriberCore_Expecter) GetTransformer ¶ added in v0.26.0
func (_e *SubscriberCore_Expecter) GetTransformer(spec interface{}) *SubscriberCore_GetTransformer_Call
GetTransformer is a helper method to define mock.On call
- spec *mdlsub.ModelSpecification
func (*SubscriberCore_Expecter) Persist ¶ added in v0.26.0
func (_e *SubscriberCore_Expecter) Persist(ctx interface{}, spec interface{}, model interface{}) *SubscriberCore_Persist_Call
Persist is a helper method to define mock.On call
- ctx context.Context
- spec *mdlsub.ModelSpecification
- model mdlsub.Model
func (*SubscriberCore_Expecter) Transform ¶ added in v0.26.0
func (_e *SubscriberCore_Expecter) Transform(ctx interface{}, spec interface{}, input interface{}) *SubscriberCore_Transform_Call
Transform is a helper method to define mock.On call
- ctx context.Context
- spec *mdlsub.ModelSpecification
- input interface{}
type SubscriberCore_GetLatestModelIdVersion_Call ¶ added in v0.26.0
SubscriberCore_GetLatestModelIdVersion_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetLatestModelIdVersion'
func (*SubscriberCore_GetLatestModelIdVersion_Call) Return ¶ added in v0.26.0
func (_c *SubscriberCore_GetLatestModelIdVersion_Call) Return(_a0 int, _a1 error) *SubscriberCore_GetLatestModelIdVersion_Call
func (*SubscriberCore_GetLatestModelIdVersion_Call) Run ¶ added in v0.26.0
func (_c *SubscriberCore_GetLatestModelIdVersion_Call) Run(run func(modelId mdl.ModelId)) *SubscriberCore_GetLatestModelIdVersion_Call
func (*SubscriberCore_GetLatestModelIdVersion_Call) RunAndReturn ¶ added in v0.26.0
func (_c *SubscriberCore_GetLatestModelIdVersion_Call) RunAndReturn(run func(mdl.ModelId) (int, error)) *SubscriberCore_GetLatestModelIdVersion_Call
type SubscriberCore_GetModelIds_Call ¶ added in v0.26.0
SubscriberCore_GetModelIds_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetModelIds'
func (*SubscriberCore_GetModelIds_Call) Return ¶ added in v0.26.0
func (_c *SubscriberCore_GetModelIds_Call) Return(_a0 []string) *SubscriberCore_GetModelIds_Call
func (*SubscriberCore_GetModelIds_Call) Run ¶ added in v0.26.0
func (_c *SubscriberCore_GetModelIds_Call) Run(run func()) *SubscriberCore_GetModelIds_Call
func (*SubscriberCore_GetModelIds_Call) RunAndReturn ¶ added in v0.26.0
func (_c *SubscriberCore_GetModelIds_Call) RunAndReturn(run func() []string) *SubscriberCore_GetModelIds_Call
type SubscriberCore_GetOutput_Call ¶ added in v0.26.0
SubscriberCore_GetOutput_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetOutput'
func (*SubscriberCore_GetOutput_Call) Return ¶ added in v0.26.0
func (_c *SubscriberCore_GetOutput_Call) Return(_a0 mdlsub.Output, _a1 error) *SubscriberCore_GetOutput_Call
func (*SubscriberCore_GetOutput_Call) Run ¶ added in v0.26.0
func (_c *SubscriberCore_GetOutput_Call) Run(run func(spec *mdlsub.ModelSpecification)) *SubscriberCore_GetOutput_Call
func (*SubscriberCore_GetOutput_Call) RunAndReturn ¶ added in v0.26.0
func (_c *SubscriberCore_GetOutput_Call) RunAndReturn(run func(*mdlsub.ModelSpecification) (mdlsub.Output, error)) *SubscriberCore_GetOutput_Call
type SubscriberCore_GetTransformer_Call ¶ added in v0.26.0
SubscriberCore_GetTransformer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTransformer'
func (*SubscriberCore_GetTransformer_Call) Return ¶ added in v0.26.0
func (_c *SubscriberCore_GetTransformer_Call) Return(_a0 mdlsub.ModelTransformer, _a1 error) *SubscriberCore_GetTransformer_Call
func (*SubscriberCore_GetTransformer_Call) Run ¶ added in v0.26.0
func (_c *SubscriberCore_GetTransformer_Call) Run(run func(spec *mdlsub.ModelSpecification)) *SubscriberCore_GetTransformer_Call
func (*SubscriberCore_GetTransformer_Call) RunAndReturn ¶ added in v0.26.0
func (_c *SubscriberCore_GetTransformer_Call) RunAndReturn(run func(*mdlsub.ModelSpecification) (mdlsub.ModelTransformer, error)) *SubscriberCore_GetTransformer_Call
type SubscriberCore_Persist_Call ¶ added in v0.26.0
SubscriberCore_Persist_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Persist'
func (*SubscriberCore_Persist_Call) Return ¶ added in v0.26.0
func (_c *SubscriberCore_Persist_Call) Return(_a0 error) *SubscriberCore_Persist_Call
func (*SubscriberCore_Persist_Call) Run ¶ added in v0.26.0
func (_c *SubscriberCore_Persist_Call) Run(run func(ctx context.Context, spec *mdlsub.ModelSpecification, model mdlsub.Model)) *SubscriberCore_Persist_Call
func (*SubscriberCore_Persist_Call) RunAndReturn ¶ added in v0.26.0
func (_c *SubscriberCore_Persist_Call) RunAndReturn(run func(context.Context, *mdlsub.ModelSpecification, mdlsub.Model) error) *SubscriberCore_Persist_Call
type SubscriberCore_Transform_Call ¶ added in v0.26.0
SubscriberCore_Transform_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Transform'
func (*SubscriberCore_Transform_Call) Return ¶ added in v0.26.0
func (_c *SubscriberCore_Transform_Call) Return(_a0 mdlsub.Model, _a1 error) *SubscriberCore_Transform_Call
func (*SubscriberCore_Transform_Call) Run ¶ added in v0.26.0
func (_c *SubscriberCore_Transform_Call) Run(run func(ctx context.Context, spec *mdlsub.ModelSpecification, input interface{})) *SubscriberCore_Transform_Call
func (*SubscriberCore_Transform_Call) RunAndReturn ¶ added in v0.26.0
func (_c *SubscriberCore_Transform_Call) RunAndReturn(run func(context.Context, *mdlsub.ModelSpecification, interface{}) (mdlsub.Model, error)) *SubscriberCore_Transform_Call