yolopersist

Documentation

Index

• type YoloPersister
  • func NewYoloPersister() *YoloPersister
  • func (yp *YoloPersister) Flush(ctx context.Context) error
  • func (yp *YoloPersister) Persist(ctx context.Context, e *events.XRPCStreamEvent) error
  • func (mp *YoloPersister) Playback(ctx context.Context, since int64, cb func(*events.XRPCStreamEvent) error) error
  • func (yp *YoloPersister) SetEventBroadcaster(brc func(*events.XRPCStreamEvent))
  • func (yp *YoloPersister) Shutdown(ctx context.Context) error
  • func (yp *YoloPersister) TakeDownRepo(ctx context.Context, uid models.Uid) error

Types

type YoloPersister

type YoloPersister struct {
	// contains filtered or unexported fields
}

YoloPersister is used for benchmarking, it has no persistence, it just emits events and forgets them

func NewYoloPersister

func NewYoloPersister() *YoloPersister

func (*YoloPersister) Flush

func (yp *YoloPersister) Flush(ctx context.Context) error

func (*YoloPersister) Persist

func (yp *YoloPersister) Persist(ctx context.Context, e *events.XRPCStreamEvent) error

func (*YoloPersister) Playback

func (mp *YoloPersister) Playback(ctx context.Context, since int64, cb func(*events.XRPCStreamEvent) error) error

func (*YoloPersister) SetEventBroadcaster

func (yp *YoloPersister) SetEventBroadcaster(brc func(*events.XRPCStreamEvent))

func (*YoloPersister) Shutdown

func (yp *YoloPersister) Shutdown(ctx context.Context) error

func (*YoloPersister) TakeDownRepo

func (yp *YoloPersister) TakeDownRepo(ctx context.Context, uid models.Uid) error