eventsmocks

Documentation

Index

• type Stream
  • func NewStream(t interface{ ... }) *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

Types

type Stream

type Stream struct {
	mock.Mock
}

Stream is an autogenerated mock type for the Stream type

func NewStream

func NewStream(t interface {
	mock.TestingT
	Cleanup(func())
}) *Stream

NewStream creates a new instance of Stream. 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 (*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) Delete

func (_m *Stream) Delete(ctx context.Context) error

Delete provides a mock function with given fields: ctx

func (*Stream) RemoveListener

func (_m *Stream) RemoveListener(ctx context.Context, id *fftypes.UUID) error

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) Start

func (_m *Stream) Start(ctx context.Context) error

Start provides a mock function with given fields: ctx

func (*Stream) Status

func (_m *Stream) Status() apitypes.EventStreamStatus

Status provides a mock function with given fields:

func (*Stream) Stop

func (_m *Stream) Stop(ctx context.Context) error

Stop provides a mock function with given fields: ctx

func (*Stream) UpdateSpec

func (_m *Stream) UpdateSpec(ctx context.Context, updates *apitypes.EventStream) error

UpdateSpec provides a mock function with given fields: ctx, updates