mock

Documentation

Index

• type Streamer
  • func (ms Streamer) Collect(context.Context, streamstore.Collectable) error
  • func (ms Streamer) Delete(context.Context, string) error
  • func (ms Streamer) Read(ctx context.Context, snapshotID string, col streamstore.Collectable, ...) error
  • func (ms Streamer) Write(context.Context, []identity.Reasoner, *fault.Bus) (string, error)

Types

type Streamer

type Streamer struct {
	Deets  map[string]*details.Details
	Errors map[string]*fault.Errors
}

func (Streamer) Collect

func (ms Streamer) Collect(context.Context, streamstore.Collectable) error

func (Streamer) Delete

func (ms Streamer) Delete(context.Context, string) error

func (Streamer) Read

func (ms Streamer) Read(
	ctx context.Context,
	snapshotID string,
	col streamstore.Collectable,
	errs *fault.Bus,
) error

func (Streamer) Write

func (ms Streamer) Write(
	context.Context,
	[]identity.Reasoner,
	*fault.Bus,
) (string, error)