dbadaptertest

type TestAdapter struct {
	JobCancelCalled              bool
	JobCancelTxCalled            bool
	JobInsertCalled              bool
	JobInsertTxCalled            bool
	JobInsertManyCalled          bool
	JobInsertManyTxCalled        bool
	JobGetAvailableCalled        bool
	JobGetAvailableTxCalled      bool
	JobListCalled                bool
	JobListTxCalled              bool
	JobSetStateIfRunningCalled   bool
	LeadershipAttemptElectCalled bool
	LeadershipResignedCalled     bool

	JobCancelFunc              func(ctx context.Context, id int64) (*dbsqlc.RiverJob, error)
	JobCancelTxFunc            func(ctx context.Context, tx pgx.Tx, id int64) (*dbsqlc.RiverJob, error)
	JobInsertFunc              func(ctx context.Context, params *dbadapter.JobInsertParams) (*dbadapter.JobInsertResult, error)
	JobInsertTxFunc            func(ctx context.Context, tx pgx.Tx, params *dbadapter.JobInsertParams) (*dbadapter.JobInsertResult, error)
	JobInsertManyFunc          func(ctx context.Context, params []*dbadapter.JobInsertParams) (int64, error)
	JobInsertManyTxFunc        func(ctx context.Context, tx pgx.Tx, params []*dbadapter.JobInsertParams) (int64, error)
	JobGetAvailableFunc        func(ctx context.Context, queueName string, limit int32) ([]*dbsqlc.RiverJob, error)
	JobGetAvailableTxFunc      func(ctx context.Context, tx pgx.Tx, queueName string, limit int32) ([]*dbsqlc.RiverJob, error)
	JobListFunc                func(ctx context.Context, params dbadapter.JobListParams) ([]*dbsqlc.RiverJob, error)
	JobListTxFunc              func(ctx context.Context, tx pgx.Tx, params dbadapter.JobListParams) ([]*dbsqlc.RiverJob, error)
	JobSetStateIfRunningFunc   func(ctx context.Context, params *dbadapter.JobSetStateIfRunningParams) (*dbsqlc.RiverJob, error)
	LeadershipAttemptElectFunc func(ctx context.Context) (bool, error)
	LeadershipResignFunc       func(ctx context.Context, name string, leaderID string) error
	// contains filtered or unexported fields
}