Versions in this module Expand all Collapse all v0 v0.4.0 Nov 14, 2019 Changes in this version + type MockPathDB struct + func NewMockPathDB(ctrl *gomock.Controller) *MockPathDB + func (m *MockPathDB) BeginTransaction(arg0 context.Context, arg1 *sql.TxOptions) (pathdb.Transaction, error) + func (m *MockPathDB) Close() error + func (m *MockPathDB) Delete(arg0 context.Context, arg1 *query.Params) (int, error) + func (m *MockPathDB) DeleteExpired(arg0 context.Context, arg1 time.Time) (int, error) + func (m *MockPathDB) DeleteExpiredNQ(arg0 context.Context, arg1 time.Time) (int, error) + func (m *MockPathDB) DeleteNQ(arg0 context.Context, arg1, arg2 addr.IA, arg3 pathdb.PolicyHash) (int, error) + func (m *MockPathDB) EXPECT() *MockPathDBMockRecorder + func (m *MockPathDB) Get(arg0 context.Context, arg1 *query.Params) (query.Results, error) + func (m *MockPathDB) GetAll(arg0 context.Context) (<-chan query.ResultOrErr, error) + func (m *MockPathDB) GetNextQuery(arg0 context.Context, arg1, arg2 addr.IA, arg3 pathdb.PolicyHash) (time.Time, error) + func (m *MockPathDB) Insert(arg0 context.Context, arg1 *seg.Meta) (pathdb.InsertStats, error) + func (m *MockPathDB) InsertNextQuery(arg0 context.Context, arg1, arg2 addr.IA, arg3 pathdb.PolicyHash, ...) (bool, error) + func (m *MockPathDB) InsertWithHPCfgIDs(arg0 context.Context, arg1 *seg.Meta, arg2 []*query.HPCfgID) (pathdb.InsertStats, error) + func (m *MockPathDB) SetMaxIdleConns(arg0 int) + func (m *MockPathDB) SetMaxOpenConns(arg0 int) + type MockPathDBMockRecorder struct + func (mr *MockPathDBMockRecorder) BeginTransaction(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPathDBMockRecorder) Close() *gomock.Call + func (mr *MockPathDBMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPathDBMockRecorder) DeleteExpired(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPathDBMockRecorder) DeleteExpiredNQ(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPathDBMockRecorder) DeleteNQ(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockPathDBMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPathDBMockRecorder) GetAll(arg0 interface{}) *gomock.Call + func (mr *MockPathDBMockRecorder) GetNextQuery(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockPathDBMockRecorder) Insert(arg0, arg1 interface{}) *gomock.Call + func (mr *MockPathDBMockRecorder) InsertNextQuery(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockPathDBMockRecorder) InsertWithHPCfgIDs(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockPathDBMockRecorder) SetMaxIdleConns(arg0 interface{}) *gomock.Call + func (mr *MockPathDBMockRecorder) SetMaxOpenConns(arg0 interface{}) *gomock.Call + type MockReadWrite struct + func NewMockReadWrite(ctrl *gomock.Controller) *MockReadWrite + func (m *MockReadWrite) Delete(arg0 context.Context, arg1 *query.Params) (int, error) + func (m *MockReadWrite) DeleteExpired(arg0 context.Context, arg1 time.Time) (int, error) + func (m *MockReadWrite) DeleteExpiredNQ(arg0 context.Context, arg1 time.Time) (int, error) + func (m *MockReadWrite) DeleteNQ(arg0 context.Context, arg1, arg2 addr.IA, arg3 pathdb.PolicyHash) (int, error) + func (m *MockReadWrite) EXPECT() *MockReadWriteMockRecorder + func (m *MockReadWrite) Get(arg0 context.Context, arg1 *query.Params) (query.Results, error) + func (m *MockReadWrite) GetAll(arg0 context.Context) (<-chan query.ResultOrErr, error) + func (m *MockReadWrite) GetNextQuery(arg0 context.Context, arg1, arg2 addr.IA, arg3 pathdb.PolicyHash) (time.Time, error) + func (m *MockReadWrite) Insert(arg0 context.Context, arg1 *seg.Meta) (pathdb.InsertStats, error) + func (m *MockReadWrite) InsertNextQuery(arg0 context.Context, arg1, arg2 addr.IA, arg3 pathdb.PolicyHash, ...) (bool, error) + func (m *MockReadWrite) InsertWithHPCfgIDs(arg0 context.Context, arg1 *seg.Meta, arg2 []*query.HPCfgID) (pathdb.InsertStats, error) + type MockReadWriteMockRecorder struct + func (mr *MockReadWriteMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call + func (mr *MockReadWriteMockRecorder) DeleteExpired(arg0, arg1 interface{}) *gomock.Call + func (mr *MockReadWriteMockRecorder) DeleteExpiredNQ(arg0, arg1 interface{}) *gomock.Call + func (mr *MockReadWriteMockRecorder) DeleteNQ(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockReadWriteMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call + func (mr *MockReadWriteMockRecorder) GetAll(arg0 interface{}) *gomock.Call + func (mr *MockReadWriteMockRecorder) GetNextQuery(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockReadWriteMockRecorder) Insert(arg0, arg1 interface{}) *gomock.Call + func (mr *MockReadWriteMockRecorder) InsertNextQuery(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockReadWriteMockRecorder) InsertWithHPCfgIDs(arg0, arg1, arg2 interface{}) *gomock.Call + type MockTransaction struct + func NewMockTransaction(ctrl *gomock.Controller) *MockTransaction + func (m *MockTransaction) Commit() error + func (m *MockTransaction) Delete(arg0 context.Context, arg1 *query.Params) (int, error) + func (m *MockTransaction) DeleteExpired(arg0 context.Context, arg1 time.Time) (int, error) + func (m *MockTransaction) DeleteExpiredNQ(arg0 context.Context, arg1 time.Time) (int, error) + func (m *MockTransaction) DeleteNQ(arg0 context.Context, arg1, arg2 addr.IA, arg3 pathdb.PolicyHash) (int, error) + func (m *MockTransaction) EXPECT() *MockTransactionMockRecorder + func (m *MockTransaction) Get(arg0 context.Context, arg1 *query.Params) (query.Results, error) + func (m *MockTransaction) GetAll(arg0 context.Context) (<-chan query.ResultOrErr, error) + func (m *MockTransaction) GetNextQuery(arg0 context.Context, arg1, arg2 addr.IA, arg3 pathdb.PolicyHash) (time.Time, error) + func (m *MockTransaction) Insert(arg0 context.Context, arg1 *seg.Meta) (pathdb.InsertStats, error) + func (m *MockTransaction) InsertNextQuery(arg0 context.Context, arg1, arg2 addr.IA, arg3 pathdb.PolicyHash, ...) (bool, error) + func (m *MockTransaction) InsertWithHPCfgIDs(arg0 context.Context, arg1 *seg.Meta, arg2 []*query.HPCfgID) (pathdb.InsertStats, error) + func (m *MockTransaction) Rollback() error + type MockTransactionMockRecorder struct + func (mr *MockTransactionMockRecorder) Commit() *gomock.Call + func (mr *MockTransactionMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call + func (mr *MockTransactionMockRecorder) DeleteExpired(arg0, arg1 interface{}) *gomock.Call + func (mr *MockTransactionMockRecorder) DeleteExpiredNQ(arg0, arg1 interface{}) *gomock.Call + func (mr *MockTransactionMockRecorder) DeleteNQ(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockTransactionMockRecorder) Get(arg0, arg1 interface{}) *gomock.Call + func (mr *MockTransactionMockRecorder) GetAll(arg0 interface{}) *gomock.Call + func (mr *MockTransactionMockRecorder) GetNextQuery(arg0, arg1, arg2, arg3 interface{}) *gomock.Call + func (mr *MockTransactionMockRecorder) Insert(arg0, arg1 interface{}) *gomock.Call + func (mr *MockTransactionMockRecorder) InsertNextQuery(arg0, arg1, arg2, arg3, arg4 interface{}) *gomock.Call + func (mr *MockTransactionMockRecorder) InsertWithHPCfgIDs(arg0, arg1, arg2 interface{}) *gomock.Call + func (mr *MockTransactionMockRecorder) Rollback() *gomock.Call