sqlite

Documentation

Index

• type Store
  • func (sto *Store) AddEvent(ctx context.Context, input *api.AddEventInput) (*api.AddEventOutput, error)
  • func (sto *Store) ClearEvents(ctx context.Context, input *api.ClearEventsInput) (*api.ClearEventsOutput, error)
  • func (sto *Store) DescribeStreams(ctx context.Context, input *api.DescribeStreamsInput) (*api.DescribeStreamsOutput, error)
  • func (sto *Store) GetEvents(ctx context.Context, input *api.GetEventsInput) (*api.GetEventsOutput, error)
  • func (sto *Store) RemoveOldEvents(ctx context.Context, input *api.RemoveOldEventsInput) (*api.RemoveOldEventsOutput, error)

Types

type Store

type Store struct {
	DB    *sqlx.DB
	IDGen *gensym.ULIDGenerator
}

func (*Store) AddEvent

func (sto *Store) AddEvent(ctx context.Context, input *api.AddEventInput) (*api.AddEventOutput, error)

func (*Store) ClearEvents

func (sto *Store) ClearEvents(ctx context.Context, input *api.ClearEventsInput) (*api.ClearEventsOutput, error)

func (*Store) DescribeStreams

func (sto *Store) DescribeStreams(ctx context.Context, input *api.DescribeStreamsInput) (*api.DescribeStreamsOutput, error)

func (*Store) GetEvents

func (sto *Store) GetEvents(ctx context.Context, input *api.GetEventsInput) (*api.GetEventsOutput, error)

func (*Store) RemoveOldEvents

func (sto *Store) RemoveOldEvents(ctx context.Context, input *api.RemoveOldEventsInput) (*api.RemoveOldEventsOutput, error)