eventsstoregrpc

Documentation

Index

• type Store
  • func (s *Store) Add(ctx context.Context, id apievent.EventID, srcid apieventsrc.EventSourceID, ...) (apievent.EventID, error)
  • func (s *Store) Get(ctx context.Context, id apievent.EventID) (*apievent.Event, error)
  • func (s *Store) GetProjectWaitingEvents(ctx context.Context, pid apiproject.ProjectID) ([]apievent.EventID, error)
  • func (s *Store) GetState(ctx context.Context, id apievent.EventID) ([]*apievent.EventStateRecord, error)
  • func (s *Store) GetStateForProject(ctx context.Context, id apievent.EventID, pid apiproject.ProjectID) ([]*apievent.ProjectEventStateRecord, error)
  • func (s *Store) List(ctx context.Context, pid *apiproject.ProjectID, ofs, l uint32) ([]*eventsstore.ListRecord, error)
  • func (s *Store) Setup(context.Context) error
  • func (s *Store) Teardown(context.Context) error
  • func (s *Store) UpdateState(ctx context.Context, id apievent.EventID, state *apievent.EventState) error
  • func (s *Store) UpdateStateForProject(ctx context.Context, id apievent.EventID, pid apiproject.ProjectID, ...) error

Types

type Store

type Store struct{ Client pbeventsvc.EventsClient }

func (*Store) Add

func (s *Store) Add(ctx context.Context, id apievent.EventID, srcid apieventsrc.EventSourceID, assoc, originalID, typ string, data map[string]*apivalues.Value, memo map[string]string) (apievent.EventID, error)

func (*Store) Get

func (s *Store) Get(ctx context.Context, id apievent.EventID) (*apievent.Event, error)

func (*Store) GetProjectWaitingEvents

func (s *Store) GetProjectWaitingEvents(ctx context.Context, pid apiproject.ProjectID) ([]apievent.EventID, error)

func (*Store) GetState

func (s *Store) GetState(ctx context.Context, id apievent.EventID) ([]*apievent.EventStateRecord, error)

func (*Store) GetStateForProject

func (s *Store) GetStateForProject(ctx context.Context, id apievent.EventID, pid apiproject.ProjectID) ([]*apievent.ProjectEventStateRecord, error)

func (*Store) List

func (s *Store) List(ctx context.Context, pid *apiproject.ProjectID, ofs, l uint32) ([]*eventsstore.ListRecord, error)

func (*Store) Setup

func (s *Store) Setup(context.Context) error

func (*Store) Teardown

func (s *Store) Teardown(context.Context) error

func (*Store) UpdateState

func (s *Store) UpdateState(ctx context.Context, id apievent.EventID, state *apievent.EventState) error

func (*Store) UpdateStateForProject

func (s *Store) UpdateStateForProject(ctx context.Context, id apievent.EventID, pid apiproject.ProjectID, state *apievent.ProjectEventState) error