Documentation
¶
Index ¶
- func NewBatchDependentStore(db *sql.DB, scope tally.Scope, queue string) storage.BatchDependentStore
- func NewBatchStore(db *sql.DB, scope tally.Scope, queue string) storage.BatchStore
- func NewBuildStore(db *sql.DB, scope tally.Scope, queue string) storage.BuildStore
- func NewChangeStore(db *sql.DB, scope tally.Scope, queue string) storage.ChangeStore
- func NewPathBuildStore(db *sql.DB, scope tally.Scope, queue string) storage.PathBuildStore
- func NewQueueBatchStateStore(db *sql.DB, scope tally.Scope, queue string) storage.QueueBatchStateStore
- func NewRequestBatchStore(db *sql.DB, scope tally.Scope, queue string) storage.RequestBatchStore
- func NewRequestLogStore(db *sql.DB, scope tally.Scope, queue string) storage.RequestLogStore
- func NewRequestQueueSummaryStore(db *sql.DB, scope tally.Scope, queue string) storage.RequestQueueSummaryStore
- func NewRequestStore(db *sql.DB, scope tally.Scope, queue string) storage.RequestStore
- func NewRequestSummaryStore(db *sql.DB, scope tally.Scope, queue string) storage.RequestSummaryStore
- func NewRequestURIStore(db *sql.DB, scope tally.Scope, queue string) storage.RequestURIStore
- func NewSpeculationPathSetStore(db *sql.DB, scope tally.Scope, queue string) storage.SpeculationPathSetStore
- type Storage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewBatchDependentStore ¶
func NewBatchDependentStore(db *sql.DB, scope tally.Scope, queue string) storage.BatchDependentStore
NewBatchDependentStore creates a new MySQL-backed BatchDependentStore.
func NewBatchStore ¶
NewBatchStore creates a new MySQL-backed BatchStore.
func NewBuildStore ¶
NewBuildStore creates a new MySQL-backed BuildStore.
func NewChangeStore ¶
NewChangeStore creates a new MySQL-backed ChangeStore.
func NewPathBuildStore ¶
NewPathBuildStore creates a new MySQL-backed PathBuildStore.
func NewQueueBatchStateStore ¶
func NewQueueBatchStateStore(db *sql.DB, scope tally.Scope, queue string) storage.QueueBatchStateStore
NewQueueBatchStateStore creates a new MySQL-backed QueueBatchStateStore.
func NewRequestBatchStore ¶
NewRequestBatchStore creates a MySQL-backed RequestBatchStore.
func NewRequestLogStore ¶
NewRequestLogStore creates a new MySQL-backed RequestLogStore.
func NewRequestQueueSummaryStore ¶
func NewRequestQueueSummaryStore(db *sql.DB, scope tally.Scope, queue string) storage.RequestQueueSummaryStore
NewRequestQueueSummaryStore creates a MySQL-backed RequestQueueSummaryStore.
func NewRequestStore ¶
NewRequestStore creates a new MySQL-backed RequestStore.
func NewRequestSummaryStore ¶
func NewRequestSummaryStore(db *sql.DB, scope tally.Scope, queue string) storage.RequestSummaryStore
NewRequestSummaryStore creates a MySQL-backed RequestSummaryStore.
func NewRequestURIStore ¶
NewRequestURIStore creates a MySQL-backed RequestURIStore.
func NewSpeculationPathSetStore ¶
func NewSpeculationPathSetStore(db *sql.DB, scope tally.Scope, queue string) storage.SpeculationPathSetStore
NewSpeculationPathSetStore creates a new MySQL-backed SpeculationPathSetStore.
Types ¶
type Storage ¶
type Storage struct {
// contains filtered or unexported fields
}
Storage is the MySQL storage backend. It owns the shared connection pool and binds queue-scoped store aggregates over the shared tables on demand via For. The wiring layer adapts For into the storage.Factory seam; per-queue backend routing stays a host decision.
func NewStorage ¶
NewStorage creates a new MySQL storage backend over the given connection pool.
Source Files