Documentation ¶
Index ¶
- type FanOut
- func (_m *FanOut) Attach(ctx context.Context, req *sdk.AttachmentRequest) (*sdk.AttachmentResponse, error)
- func (_m *FanOut) Describe() *sdk.IntegrationInfo
- func (_m *FanOut) Execute(ctx context.Context, req *sdk.ExecutionRequest) error
- func (_m *FanOut) IsSubscribedTo(materialType string) bool
- func (_m *FanOut) Register(ctx context.Context, req *sdk.RegistrationRequest) (*sdk.RegistrationResponse, error)
- func (_m *FanOut) String() string
- func (_m *FanOut) ValidateAttachmentRequest(jsonPayload []byte) error
- func (_m *FanOut) ValidateRegistrationRequest(jsonPayload []byte) error
- type FanOutPlugin
- func (_m *FanOutPlugin) Attach(ctx context.Context, req *sdk.AttachmentRequest) (*sdk.AttachmentResponse, error)
- func (_m *FanOutPlugin) Execute(ctx context.Context, req *sdk.ExecutionRequest) error
- func (_m *FanOutPlugin) Register(ctx context.Context, req *sdk.RegistrationRequest) (*sdk.RegistrationResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FanOut ¶
FanOut is an autogenerated mock type for the FanOut type
func NewFanOut ¶
func NewFanOut(t mockConstructorTestingTNewFanOut) *FanOut
NewFanOut creates a new instance of FanOut. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*FanOut) Attach ¶
func (_m *FanOut) Attach(ctx context.Context, req *sdk.AttachmentRequest) (*sdk.AttachmentResponse, error)
Attach provides a mock function with given fields: ctx, req
func (*FanOut) Describe ¶
func (_m *FanOut) Describe() *sdk.IntegrationInfo
Describe provides a mock function with given fields:
func (*FanOut) IsSubscribedTo ¶
IsSubscribedTo provides a mock function with given fields: materialType
func (*FanOut) Register ¶
func (_m *FanOut) Register(ctx context.Context, req *sdk.RegistrationRequest) (*sdk.RegistrationResponse, error)
Register provides a mock function with given fields: ctx, req
func (*FanOut) ValidateAttachmentRequest ¶
ValidateAttachmentRequest provides a mock function with given fields: jsonPayload
func (*FanOut) ValidateRegistrationRequest ¶
ValidateRegistrationRequest provides a mock function with given fields: jsonPayload
type FanOutPlugin ¶
FanOutPlugin is an autogenerated mock type for the FanOutPlugin type
func NewFanOutPlugin ¶
func NewFanOutPlugin(t mockConstructorTestingTNewFanOutPlugin) *FanOutPlugin
NewFanOutPlugin creates a new instance of FanOutPlugin. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*FanOutPlugin) Attach ¶
func (_m *FanOutPlugin) Attach(ctx context.Context, req *sdk.AttachmentRequest) (*sdk.AttachmentResponse, error)
Attach provides a mock function with given fields: ctx, req
func (*FanOutPlugin) Execute ¶
func (_m *FanOutPlugin) Execute(ctx context.Context, req *sdk.ExecutionRequest) error
Execute provides a mock function with given fields: ctx, req
func (*FanOutPlugin) Register ¶
func (_m *FanOutPlugin) Register(ctx context.Context, req *sdk.RegistrationRequest) (*sdk.RegistrationResponse, error)
Register provides a mock function with given fields: ctx, req