Documentation ¶
Index ¶
- type Stream
- func (_m *Stream) AddOrUpdateListener(ctx context.Context, id *fftypes.UUID, updates *apitypes.Listener, reset bool) (*apitypes.Listener, error)
- func (_m *Stream) Delete(ctx context.Context) error
- func (_m *Stream) RemoveListener(ctx context.Context, id *fftypes.UUID) error
- func (_m *Stream) Spec() *apitypes.EventStream
- func (_m *Stream) Start(ctx context.Context) error
- func (_m *Stream) Status() apitypes.EventStreamStatus
- func (_m *Stream) Stop(ctx context.Context) error
- func (_m *Stream) UpdateSpec(ctx context.Context, updates *apitypes.EventStream) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Stream ¶
Stream is an autogenerated mock type for the Stream type
func (*Stream) AddOrUpdateListener ¶
func (_m *Stream) AddOrUpdateListener(ctx context.Context, id *fftypes.UUID, updates *apitypes.Listener, reset bool) (*apitypes.Listener, error)
AddOrUpdateListener provides a mock function with given fields: ctx, id, updates, reset
func (*Stream) RemoveListener ¶
RemoveListener provides a mock function with given fields: ctx, id
func (*Stream) Spec ¶
func (_m *Stream) Spec() *apitypes.EventStream
Spec provides a mock function with given fields:
func (*Stream) Status ¶
func (_m *Stream) Status() apitypes.EventStreamStatus
Status provides a mock function with given fields:
func (*Stream) UpdateSpec ¶
UpdateSpec provides a mock function with given fields: ctx, updates
Click to show internal directories.
Click to hide internal directories.