db

Dec 12, 2019

Changes in this version

+ const CFAuditEventsTable

+ const DefaultInitTimeout

+ const DefaultQueryTimeout

+ const DefaultStoreTimeout

+ const ShipperCursorsTable

+ type EventDB interface

+ GetCFAuditEvents func(filter RawEventFilter) ([]cfclient.Event, error)

+ GetCFEventCount func() (int64, error)

+ GetLatestCFEventTime func() (*time.Time, error)

+ GetUnshippedCFAuditEventsForShipper func(shipperName string) ([]cfclient.Event, error)

+ Init func() error

+ StoreCFAuditEvents func(events []cfclient.Event) error

+ UpdateShipperCursor func(shipperName string, shipperTime string, shippedID string) error

+ type EventStore struct

+ func NewEventStore(ctx context.Context, db *sql.DB, logger lager.Logger) *EventStore

+ func (s *EventStore) GetCFAuditEvents(filter RawEventFilter) ([]cfclient.Event, error)

+ func (s *EventStore) GetCFEventCount() (int64, error)

+ func (s *EventStore) GetLatestCFEventTime() (*time.Time, error)

+ func (s *EventStore) GetUnshippedCFAuditEventsForShipper(shipperName string) ([]cfclient.Event, error)

+ func (s *EventStore) Init() error

+ func (s *EventStore) StoreCFAuditEvents(events []cfclient.Event) error

+ func (s *EventStore) UpdateShipperCursor(shipperName string, shipperTime string, shippedID string) error

+ type RawEventFilter struct

+ Kind string

+ Limit int

+ Reverse bool