db

Documentation

Index

• Constants
• type EventDB
• type EventStore
  • 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

Constants

const (
	CFAuditEventsTable  = "cf_audit_events"
	ShipperCursorsTable = "shipper_cursors"

	DefaultInitTimeout  = 15 * time.Minute
	DefaultStoreTimeout = 10 * time.Minute
	DefaultQueryTimeout = 60 * time.Second
)

Types

type EventDB

type EventDB interface {
	Init() error

	StoreCFAuditEvents(events []cfclient.Event) error
	GetCFAuditEvents(filter RawEventFilter) ([]cfclient.Event, error)
	GetLatestCFEventTime() (*time.Time, error)
	GetCFEventCount() (int64, error)

	GetUnshippedCFAuditEventsForShipper(shipperName string) ([]cfclient.Event, error)
	UpdateShipperCursor(shipperName string, shipperTime string, shippedID string) error
}

type EventStore

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

func NewEventStore

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

func (*EventStore) GetCFAuditEvents

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

func (*EventStore) GetCFEventCount

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

func (*EventStore) GetLatestCFEventTime

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

func (*EventStore) GetUnshippedCFAuditEventsForShipper

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

func (*EventStore) Init

func (s *EventStore) Init() error

Init initialises the database tables and functions

func (*EventStore) StoreCFAuditEvents

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

func (*EventStore) UpdateShipperCursor

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

type RawEventFilter

type RawEventFilter struct {
	Reverse bool
	Limit   int
	Kind    string
}