mocks

package
v0.6.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 31, 2026 License: BSD-2-Clause Imports: 12 Imported by: 0

Documentation

Overview

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Code generated by counterfeiter. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GitClient 

type GitClient struct {
	AtomicReadModifyWriteAndCommitPushStub func(context.Context, string, func(current []byte) ([]byte, error), string) error

	AtomicWriteAndCommitPushStub func(context.Context, string, []byte, string) error

	AtomicWriteIfAbsentAndCommitPushStub func(context.Context, string, []byte, string) error

	CommitAndPushStub func(context.Context, string) error

	EnsureClonedStub func(context.Context) error

	ListFilesStub func(context.Context, string) ([]string, error)

	PathStub func() string

	PullStub func(context.Context) error

	ReadFileStub func(context.Context, string) ([]byte, error)

	WriteFileStub func(context.Context, string, []byte) error
	// contains filtered or unexported fields
}

func (*GitClient) AtomicReadModifyWriteAndCommitPush 

func (fake *GitClient) AtomicReadModifyWriteAndCommitPush(arg1 context.Context, arg2 string, arg3 func(current []byte) ([]byte, error), arg4 string) error

func (*GitClient) AtomicReadModifyWriteAndCommitPushArgsForCall 

func (fake *GitClient) AtomicReadModifyWriteAndCommitPushArgsForCall(i int) (context.Context, string, func(current []byte) ([]byte, error), string)

func (*GitClient) AtomicReadModifyWriteAndCommitPushCallCount 

func (fake *GitClient) AtomicReadModifyWriteAndCommitPushCallCount() int

func (*GitClient) AtomicReadModifyWriteAndCommitPushCalls 

func (fake *GitClient) AtomicReadModifyWriteAndCommitPushCalls(stub func(context.Context, string, func(current []byte) ([]byte, error), string) error)

func (*GitClient) AtomicReadModifyWriteAndCommitPushReturns 

func (fake *GitClient) AtomicReadModifyWriteAndCommitPushReturns(result1 error)

func (*GitClient) AtomicReadModifyWriteAndCommitPushReturnsOnCall 

func (fake *GitClient) AtomicReadModifyWriteAndCommitPushReturnsOnCall(i int, result1 error)

func (*GitClient) AtomicWriteAndCommitPush 

func (fake *GitClient) AtomicWriteAndCommitPush(arg1 context.Context, arg2 string, arg3 []byte, arg4 string) error

func (*GitClient) AtomicWriteAndCommitPushArgsForCall 

func (fake *GitClient) AtomicWriteAndCommitPushArgsForCall(i int) (context.Context, string, []byte, string)

func (*GitClient) AtomicWriteAndCommitPushCallCount 

func (fake *GitClient) AtomicWriteAndCommitPushCallCount() int

func (*GitClient) AtomicWriteAndCommitPushCalls 

func (fake *GitClient) AtomicWriteAndCommitPushCalls(stub func(context.Context, string, []byte, string) error)

func (*GitClient) AtomicWriteAndCommitPushReturns 

func (fake *GitClient) AtomicWriteAndCommitPushReturns(result1 error)

func (*GitClient) AtomicWriteAndCommitPushReturnsOnCall 

func (fake *GitClient) AtomicWriteAndCommitPushReturnsOnCall(i int, result1 error)

func (*GitClient) AtomicWriteIfAbsentAndCommitPush added in v0.6.1 

func (fake *GitClient) AtomicWriteIfAbsentAndCommitPush(arg1 context.Context, arg2 string, arg3 []byte, arg4 string) error

func (*GitClient) AtomicWriteIfAbsentAndCommitPushArgsForCall added in v0.6.1 

func (fake *GitClient) AtomicWriteIfAbsentAndCommitPushArgsForCall(i int) (context.Context, string, []byte, string)

func (*GitClient) AtomicWriteIfAbsentAndCommitPushCallCount added in v0.6.1 

func (fake *GitClient) AtomicWriteIfAbsentAndCommitPushCallCount() int

func (*GitClient) AtomicWriteIfAbsentAndCommitPushCalls added in v0.6.1 

func (fake *GitClient) AtomicWriteIfAbsentAndCommitPushCalls(stub func(context.Context, string, []byte, string) error)

func (*GitClient) AtomicWriteIfAbsentAndCommitPushReturns added in v0.6.1 

func (fake *GitClient) AtomicWriteIfAbsentAndCommitPushReturns(result1 error)

func (*GitClient) AtomicWriteIfAbsentAndCommitPushReturnsOnCall added in v0.6.1 

func (fake *GitClient) AtomicWriteIfAbsentAndCommitPushReturnsOnCall(i int, result1 error)

func (*GitClient) CommitAndPush 

func (fake *GitClient) CommitAndPush(arg1 context.Context, arg2 string) error

func (*GitClient) CommitAndPushArgsForCall 

func (fake *GitClient) CommitAndPushArgsForCall(i int) (context.Context, string)

func (*GitClient) CommitAndPushCallCount 

func (fake *GitClient) CommitAndPushCallCount() int

func (*GitClient) CommitAndPushCalls 

func (fake *GitClient) CommitAndPushCalls(stub func(context.Context, string) error)

func (*GitClient) CommitAndPushReturns 

func (fake *GitClient) CommitAndPushReturns(result1 error)

func (*GitClient) CommitAndPushReturnsOnCall 

func (fake *GitClient) CommitAndPushReturnsOnCall(i int, result1 error)

func (*GitClient) EnsureCloned 

func (fake *GitClient) EnsureCloned(arg1 context.Context) error

func (*GitClient) EnsureClonedArgsForCall 

func (fake *GitClient) EnsureClonedArgsForCall(i int) context.Context

func (*GitClient) EnsureClonedCallCount 

func (fake *GitClient) EnsureClonedCallCount() int

func (*GitClient) EnsureClonedCalls 

func (fake *GitClient) EnsureClonedCalls(stub func(context.Context) error)

func (*GitClient) EnsureClonedReturns 

func (fake *GitClient) EnsureClonedReturns(result1 error)

func (*GitClient) EnsureClonedReturnsOnCall 

func (fake *GitClient) EnsureClonedReturnsOnCall(i int, result1 error)

func (*GitClient) Invocations 

func (fake *GitClient) Invocations() map[string][][]interface{}

func (*GitClient) ListFiles 

func (fake *GitClient) ListFiles(arg1 context.Context, arg2 string) ([]string, error)

func (*GitClient) ListFilesArgsForCall 

func (fake *GitClient) ListFilesArgsForCall(i int) (context.Context, string)

func (*GitClient) ListFilesCallCount 

func (fake *GitClient) ListFilesCallCount() int

func (*GitClient) ListFilesCalls 

func (fake *GitClient) ListFilesCalls(stub func(context.Context, string) ([]string, error))

func (*GitClient) ListFilesReturns 

func (fake *GitClient) ListFilesReturns(result1 []string, result2 error)

func (*GitClient) ListFilesReturnsOnCall 

func (fake *GitClient) ListFilesReturnsOnCall(i int, result1 []string, result2 error)

func (*GitClient) Path 

func (fake *GitClient) Path() string

func (*GitClient) PathCallCount 

func (fake *GitClient) PathCallCount() int

func (*GitClient) PathCalls 

func (fake *GitClient) PathCalls(stub func() string)

func (*GitClient) PathReturns 

func (fake *GitClient) PathReturns(result1 string)

func (*GitClient) PathReturnsOnCall 

func (fake *GitClient) PathReturnsOnCall(i int, result1 string)

func (*GitClient) Pull 

func (fake *GitClient) Pull(arg1 context.Context) error

func (*GitClient) PullArgsForCall 

func (fake *GitClient) PullArgsForCall(i int) context.Context

func (*GitClient) PullCallCount 

func (fake *GitClient) PullCallCount() int

func (*GitClient) PullCalls 

func (fake *GitClient) PullCalls(stub func(context.Context) error)

func (*GitClient) PullReturns 

func (fake *GitClient) PullReturns(result1 error)

func (*GitClient) PullReturnsOnCall 

func (fake *GitClient) PullReturnsOnCall(i int, result1 error)

func (*GitClient) ReadFile 

func (fake *GitClient) ReadFile(arg1 context.Context, arg2 string) ([]byte, error)

func (*GitClient) ReadFileArgsForCall 

func (fake *GitClient) ReadFileArgsForCall(i int) (context.Context, string)

func (*GitClient) ReadFileCallCount 

func (fake *GitClient) ReadFileCallCount() int

func (*GitClient) ReadFileCalls 

func (fake *GitClient) ReadFileCalls(stub func(context.Context, string) ([]byte, error))

func (*GitClient) ReadFileReturns 

func (fake *GitClient) ReadFileReturns(result1 []byte, result2 error)

func (*GitClient) ReadFileReturnsOnCall 

func (fake *GitClient) ReadFileReturnsOnCall(i int, result1 []byte, result2 error)

func (*GitClient) WriteFile 

func (fake *GitClient) WriteFile(arg1 context.Context, arg2 string, arg3 []byte) error

func (*GitClient) WriteFileArgsForCall 

func (fake *GitClient) WriteFileArgsForCall(i int) (context.Context, string, []byte)

func (*GitClient) WriteFileCallCount 

func (fake *GitClient) WriteFileCallCount() int

func (*GitClient) WriteFileCalls 

func (fake *GitClient) WriteFileCalls(stub func(context.Context, string, []byte) error)

func (*GitClient) WriteFileReturns 

func (fake *GitClient) WriteFileReturns(result1 error)

func (*GitClient) WriteFileReturnsOnCall 

func (fake *GitClient) WriteFileReturnsOnCall(i int, result1 error)

type GitRestClient 

type GitRestClient struct {
	DeleteStub func(context.Context, string) error

	GetStub func(context.Context, string) ([]byte, error)

	IsReadyStub func(context.Context) (bool, error)

	ListStub func(context.Context, string) ([]string, error)

	PostStub func(context.Context, string, []byte) error

	PostIfAbsentStub func(context.Context, string, []byte) error
	// contains filtered or unexported fields
}

func (*GitRestClient) Delete 

func (fake *GitRestClient) Delete(arg1 context.Context, arg2 string) error

func (*GitRestClient) DeleteArgsForCall 

func (fake *GitRestClient) DeleteArgsForCall(i int) (context.Context, string)

func (*GitRestClient) DeleteCallCount 

func (fake *GitRestClient) DeleteCallCount() int

func (*GitRestClient) DeleteCalls 

func (fake *GitRestClient) DeleteCalls(stub func(context.Context, string) error)

func (*GitRestClient) DeleteReturns 

func (fake *GitRestClient) DeleteReturns(result1 error)

func (*GitRestClient) DeleteReturnsOnCall 

func (fake *GitRestClient) DeleteReturnsOnCall(i int, result1 error)

func (*GitRestClient) Get 

func (fake *GitRestClient) Get(arg1 context.Context, arg2 string) ([]byte, error)

func (*GitRestClient) GetArgsForCall 

func (fake *GitRestClient) GetArgsForCall(i int) (context.Context, string)

func (*GitRestClient) GetCallCount 

func (fake *GitRestClient) GetCallCount() int

func (*GitRestClient) GetCalls 

func (fake *GitRestClient) GetCalls(stub func(context.Context, string) ([]byte, error))

func (*GitRestClient) GetReturns 

func (fake *GitRestClient) GetReturns(result1 []byte, result2 error)

func (*GitRestClient) GetReturnsOnCall 

func (fake *GitRestClient) GetReturnsOnCall(i int, result1 []byte, result2 error)

func (*GitRestClient) Invocations 

func (fake *GitRestClient) Invocations() map[string][][]interface{}

func (*GitRestClient) IsReady 

func (fake *GitRestClient) IsReady(arg1 context.Context) (bool, error)

func (*GitRestClient) IsReadyArgsForCall 

func (fake *GitRestClient) IsReadyArgsForCall(i int) context.Context

func (*GitRestClient) IsReadyCallCount 

func (fake *GitRestClient) IsReadyCallCount() int

func (*GitRestClient) IsReadyCalls 

func (fake *GitRestClient) IsReadyCalls(stub func(context.Context) (bool, error))

func (*GitRestClient) IsReadyReturns 

func (fake *GitRestClient) IsReadyReturns(result1 bool, result2 error)

func (*GitRestClient) IsReadyReturnsOnCall 

func (fake *GitRestClient) IsReadyReturnsOnCall(i int, result1 bool, result2 error)

func (*GitRestClient) List 

func (fake *GitRestClient) List(arg1 context.Context, arg2 string) ([]string, error)

func (*GitRestClient) ListArgsForCall 

func (fake *GitRestClient) ListArgsForCall(i int) (context.Context, string)

func (*GitRestClient) ListCallCount 

func (fake *GitRestClient) ListCallCount() int

func (*GitRestClient) ListCalls 

func (fake *GitRestClient) ListCalls(stub func(context.Context, string) ([]string, error))

func (*GitRestClient) ListReturns 

func (fake *GitRestClient) ListReturns(result1 []string, result2 error)

func (*GitRestClient) ListReturnsOnCall 

func (fake *GitRestClient) ListReturnsOnCall(i int, result1 []string, result2 error)

func (*GitRestClient) Post 

func (fake *GitRestClient) Post(arg1 context.Context, arg2 string, arg3 []byte) error

func (*GitRestClient) PostArgsForCall 

func (fake *GitRestClient) PostArgsForCall(i int) (context.Context, string, []byte)

func (*GitRestClient) PostCallCount 

func (fake *GitRestClient) PostCallCount() int

func (*GitRestClient) PostCalls 

func (fake *GitRestClient) PostCalls(stub func(context.Context, string, []byte) error)

func (*GitRestClient) PostIfAbsent added in v0.6.1 

func (fake *GitRestClient) PostIfAbsent(arg1 context.Context, arg2 string, arg3 []byte) error

func (*GitRestClient) PostIfAbsentArgsForCall added in v0.6.1 

func (fake *GitRestClient) PostIfAbsentArgsForCall(i int) (context.Context, string, []byte)

func (*GitRestClient) PostIfAbsentCallCount added in v0.6.1 

func (fake *GitRestClient) PostIfAbsentCallCount() int

func (*GitRestClient) PostIfAbsentCalls added in v0.6.1 

func (fake *GitRestClient) PostIfAbsentCalls(stub func(context.Context, string, []byte) error)

func (*GitRestClient) PostIfAbsentReturns added in v0.6.1 

func (fake *GitRestClient) PostIfAbsentReturns(result1 error)

func (*GitRestClient) PostIfAbsentReturnsOnCall added in v0.6.1 

func (fake *GitRestClient) PostIfAbsentReturnsOnCall(i int, result1 error)

func (*GitRestClient) PostReturns 

func (fake *GitRestClient) PostReturns(result1 error)

func (*GitRestClient) PostReturnsOnCall 

func (fake *GitRestClient) PostReturnsOnCall(i int, result1 error)

type Metrics 

type Metrics struct {
	ConflictResolutionsTotalStub func() prometheus.Counter

	FrontmatterCommandsTotalStub func(string, string) prometheus.Counter

	GitPushTotalStub func(string) prometheus.Counter

	GitRestCallsTotalStub func(string, string) prometheus.Counter

	KafkaConsumePausedTotalStub func() prometheus.Counter

	PlanningRetryTotalStub func(string) prometheus.Counter

	ResultsWrittenTotalStub func(string) prometheus.Counter

	ScanCyclesTotalStub func(string) prometheus.Counter

	SkippedFilesTotalStub func(metrics.SkipReason) prometheus.Counter

	TasksPublishedTotalStub func(string) prometheus.Counter
	// contains filtered or unexported fields
}

func (*Metrics) ConflictResolutionsTotal 

func (fake *Metrics) ConflictResolutionsTotal() prometheus.Counter

func (*Metrics) ConflictResolutionsTotalCallCount 

func (fake *Metrics) ConflictResolutionsTotalCallCount() int

func (*Metrics) ConflictResolutionsTotalCalls 

func (fake *Metrics) ConflictResolutionsTotalCalls(stub func() prometheus.Counter)

func (*Metrics) ConflictResolutionsTotalReturns 

func (fake *Metrics) ConflictResolutionsTotalReturns(result1 prometheus.Counter)

func (*Metrics) ConflictResolutionsTotalReturnsOnCall 

func (fake *Metrics) ConflictResolutionsTotalReturnsOnCall(i int, result1 prometheus.Counter)

func (*Metrics) FrontmatterCommandsTotal 

func (fake *Metrics) FrontmatterCommandsTotal(arg1 string, arg2 string) prometheus.Counter

func (*Metrics) FrontmatterCommandsTotalArgsForCall 

func (fake *Metrics) FrontmatterCommandsTotalArgsForCall(i int) (string, string)

func (*Metrics) FrontmatterCommandsTotalCallCount 

func (fake *Metrics) FrontmatterCommandsTotalCallCount() int

func (*Metrics) FrontmatterCommandsTotalCalls 

func (fake *Metrics) FrontmatterCommandsTotalCalls(stub func(string, string) prometheus.Counter)

func (*Metrics) FrontmatterCommandsTotalReturns 

func (fake *Metrics) FrontmatterCommandsTotalReturns(result1 prometheus.Counter)

func (*Metrics) FrontmatterCommandsTotalReturnsOnCall 

func (fake *Metrics) FrontmatterCommandsTotalReturnsOnCall(i int, result1 prometheus.Counter)

func (*Metrics) GitPushTotal 

func (fake *Metrics) GitPushTotal(arg1 string) prometheus.Counter

func (*Metrics) GitPushTotalArgsForCall 

func (fake *Metrics) GitPushTotalArgsForCall(i int) string

func (*Metrics) GitPushTotalCallCount 

func (fake *Metrics) GitPushTotalCallCount() int

func (*Metrics) GitPushTotalCalls 

func (fake *Metrics) GitPushTotalCalls(stub func(string) prometheus.Counter)

func (*Metrics) GitPushTotalReturns 

func (fake *Metrics) GitPushTotalReturns(result1 prometheus.Counter)

func (*Metrics) GitPushTotalReturnsOnCall 

func (fake *Metrics) GitPushTotalReturnsOnCall(i int, result1 prometheus.Counter)

func (*Metrics) GitRestCallsTotal 

func (fake *Metrics) GitRestCallsTotal(arg1 string, arg2 string) prometheus.Counter

func (*Metrics) GitRestCallsTotalArgsForCall 

func (fake *Metrics) GitRestCallsTotalArgsForCall(i int) (string, string)

func (*Metrics) GitRestCallsTotalCallCount 

func (fake *Metrics) GitRestCallsTotalCallCount() int

func (*Metrics) GitRestCallsTotalCalls 

func (fake *Metrics) GitRestCallsTotalCalls(stub func(string, string) prometheus.Counter)

func (*Metrics) GitRestCallsTotalReturns 

func (fake *Metrics) GitRestCallsTotalReturns(result1 prometheus.Counter)

func (*Metrics) GitRestCallsTotalReturnsOnCall 

func (fake *Metrics) GitRestCallsTotalReturnsOnCall(i int, result1 prometheus.Counter)

func (*Metrics) Invocations 

func (fake *Metrics) Invocations() map[string][][]interface{}

func (*Metrics) KafkaConsumePausedTotal 

func (fake *Metrics) KafkaConsumePausedTotal() prometheus.Counter

func (*Metrics) KafkaConsumePausedTotalCallCount 

func (fake *Metrics) KafkaConsumePausedTotalCallCount() int

func (*Metrics) KafkaConsumePausedTotalCalls 

func (fake *Metrics) KafkaConsumePausedTotalCalls(stub func() prometheus.Counter)

func (*Metrics) KafkaConsumePausedTotalReturns 

func (fake *Metrics) KafkaConsumePausedTotalReturns(result1 prometheus.Counter)

func (*Metrics) KafkaConsumePausedTotalReturnsOnCall 

func (fake *Metrics) KafkaConsumePausedTotalReturnsOnCall(i int, result1 prometheus.Counter)

func (*Metrics) PlanningRetryTotal added in v0.3.0 

func (fake *Metrics) PlanningRetryTotal(arg1 string) prometheus.Counter

func (*Metrics) PlanningRetryTotalArgsForCall added in v0.3.0 

func (fake *Metrics) PlanningRetryTotalArgsForCall(i int) string

func (*Metrics) PlanningRetryTotalCallCount added in v0.3.0 

func (fake *Metrics) PlanningRetryTotalCallCount() int

func (*Metrics) PlanningRetryTotalCalls added in v0.3.0 

func (fake *Metrics) PlanningRetryTotalCalls(stub func(string) prometheus.Counter)

func (*Metrics) PlanningRetryTotalReturns added in v0.3.0 

func (fake *Metrics) PlanningRetryTotalReturns(result1 prometheus.Counter)

func (*Metrics) PlanningRetryTotalReturnsOnCall added in v0.3.0 

func (fake *Metrics) PlanningRetryTotalReturnsOnCall(i int, result1 prometheus.Counter)

func (*Metrics) ResultsWrittenTotal 

func (fake *Metrics) ResultsWrittenTotal(arg1 string) prometheus.Counter

func (*Metrics) ResultsWrittenTotalArgsForCall 

func (fake *Metrics) ResultsWrittenTotalArgsForCall(i int) string

func (*Metrics) ResultsWrittenTotalCallCount 

func (fake *Metrics) ResultsWrittenTotalCallCount() int

func (*Metrics) ResultsWrittenTotalCalls 

func (fake *Metrics) ResultsWrittenTotalCalls(stub func(string) prometheus.Counter)

func (*Metrics) ResultsWrittenTotalReturns 

func (fake *Metrics) ResultsWrittenTotalReturns(result1 prometheus.Counter)

func (*Metrics) ResultsWrittenTotalReturnsOnCall 

func (fake *Metrics) ResultsWrittenTotalReturnsOnCall(i int, result1 prometheus.Counter)

func (*Metrics) ScanCyclesTotal 

func (fake *Metrics) ScanCyclesTotal(arg1 string) prometheus.Counter

func (*Metrics) ScanCyclesTotalArgsForCall 

func (fake *Metrics) ScanCyclesTotalArgsForCall(i int) string

func (*Metrics) ScanCyclesTotalCallCount 

func (fake *Metrics) ScanCyclesTotalCallCount() int

func (*Metrics) ScanCyclesTotalCalls 

func (fake *Metrics) ScanCyclesTotalCalls(stub func(string) prometheus.Counter)

func (*Metrics) ScanCyclesTotalReturns 

func (fake *Metrics) ScanCyclesTotalReturns(result1 prometheus.Counter)

func (*Metrics) ScanCyclesTotalReturnsOnCall 

func (fake *Metrics) ScanCyclesTotalReturnsOnCall(i int, result1 prometheus.Counter)

func (*Metrics) SkippedFilesTotal 

func (fake *Metrics) SkippedFilesTotal(arg1 metrics.SkipReason) prometheus.Counter

func (*Metrics) SkippedFilesTotalArgsForCall 

func (fake *Metrics) SkippedFilesTotalArgsForCall(i int) metrics.SkipReason

func (*Metrics) SkippedFilesTotalCallCount 

func (fake *Metrics) SkippedFilesTotalCallCount() int

func (*Metrics) SkippedFilesTotalCalls 

func (fake *Metrics) SkippedFilesTotalCalls(stub func(metrics.SkipReason) prometheus.Counter)

func (*Metrics) SkippedFilesTotalReturns 

func (fake *Metrics) SkippedFilesTotalReturns(result1 prometheus.Counter)

func (*Metrics) SkippedFilesTotalReturnsOnCall 

func (fake *Metrics) SkippedFilesTotalReturnsOnCall(i int, result1 prometheus.Counter)

func (*Metrics) TasksPublishedTotal 

func (fake *Metrics) TasksPublishedTotal(arg1 string) prometheus.Counter

func (*Metrics) TasksPublishedTotalArgsForCall 

func (fake *Metrics) TasksPublishedTotalArgsForCall(i int) string

func (*Metrics) TasksPublishedTotalCallCount 

func (fake *Metrics) TasksPublishedTotalCallCount() int

func (*Metrics) TasksPublishedTotalCalls 

func (fake *Metrics) TasksPublishedTotalCalls(stub func(string) prometheus.Counter)

func (*Metrics) TasksPublishedTotalReturns 

func (fake *Metrics) TasksPublishedTotalReturns(result1 prometheus.Counter)

func (*Metrics) TasksPublishedTotalReturnsOnCall 

func (fake *Metrics) TasksPublishedTotalReturnsOnCall(i int, result1 prometheus.Counter)

type PRCommenter 

type PRCommenter struct {
	PostCommentStub func(context.Context, lib.TaskFrontmatter, string) error
	// contains filtered or unexported fields
}

func (*PRCommenter) Invocations 

func (fake *PRCommenter) Invocations() map[string][][]interface{}

func (*PRCommenter) PostComment 

func (fake *PRCommenter) PostComment(arg1 context.Context, arg2 lib.TaskFrontmatter, arg3 string) error

func (*PRCommenter) PostCommentArgsForCall 

func (fake *PRCommenter) PostCommentArgsForCall(i int) (context.Context, lib.TaskFrontmatter, string)

func (*PRCommenter) PostCommentCallCount 

func (fake *PRCommenter) PostCommentCallCount() int

func (*PRCommenter) PostCommentCalls 

func (fake *PRCommenter) PostCommentCalls(stub func(context.Context, lib.TaskFrontmatter, string) error)

func (*PRCommenter) PostCommentReturns 

func (fake *PRCommenter) PostCommentReturns(result1 error)

func (*PRCommenter) PostCommentReturnsOnCall 

func (fake *PRCommenter) PostCommentReturnsOnCall(i int, result1 error)

type PlanningRetryGate 

type PlanningRetryGate struct {
	HandleStub func(context.Context, lib.Task) (bool, error)
	// contains filtered or unexported fields
}

func (*PlanningRetryGate) Handle 

func (fake *PlanningRetryGate) Handle(arg1 context.Context, arg2 lib.Task) (bool, error)

func (*PlanningRetryGate) HandleArgsForCall 

func (fake *PlanningRetryGate) HandleArgsForCall(i int) (context.Context, lib.Task)

func (*PlanningRetryGate) HandleCallCount 

func (fake *PlanningRetryGate) HandleCallCount() int

func (*PlanningRetryGate) HandleCalls 

func (fake *PlanningRetryGate) HandleCalls(stub func(context.Context, lib.Task) (bool, error))

func (*PlanningRetryGate) HandleReturns 

func (fake *PlanningRetryGate) HandleReturns(result1 bool, result2 error)

func (*PlanningRetryGate) HandleReturnsOnCall 

func (fake *PlanningRetryGate) HandleReturnsOnCall(i int, result1 bool, result2 error)

func (*PlanningRetryGate) Invocations 

func (fake *PlanningRetryGate) Invocations() map[string][][]interface{}

type ResultWriter 

type ResultWriter struct {
	WriteResultStub func(context.Context, lib.Task) error
	// contains filtered or unexported fields
}

func (*ResultWriter) Invocations 

func (fake *ResultWriter) Invocations() map[string][][]interface{}

func (*ResultWriter) WriteResult 

func (fake *ResultWriter) WriteResult(arg1 context.Context, arg2 lib.Task) error

func (*ResultWriter) WriteResultArgsForCall 

func (fake *ResultWriter) WriteResultArgsForCall(i int) (context.Context, lib.Task)

func (*ResultWriter) WriteResultCallCount 

func (fake *ResultWriter) WriteResultCallCount() int

func (*ResultWriter) WriteResultCalls 

func (fake *ResultWriter) WriteResultCalls(stub func(context.Context, lib.Task) error)

func (*ResultWriter) WriteResultReturns 

func (fake *ResultWriter) WriteResultReturns(result1 error)

func (*ResultWriter) WriteResultReturnsOnCall 

func (fake *ResultWriter) WriteResultReturnsOnCall(i int, result1 error)

type SyncLoop 

type SyncLoop struct {
	RunStub func(context.Context) error

	TriggerStub func()
	// contains filtered or unexported fields
}

func (*SyncLoop) Invocations 

func (fake *SyncLoop) Invocations() map[string][][]interface{}

func (*SyncLoop) Run 

func (fake *SyncLoop) Run(arg1 context.Context) error

func (*SyncLoop) RunArgsForCall 

func (fake *SyncLoop) RunArgsForCall(i int) context.Context

func (*SyncLoop) RunCallCount 

func (fake *SyncLoop) RunCallCount() int

func (*SyncLoop) RunCalls 

func (fake *SyncLoop) RunCalls(stub func(context.Context) error)

func (*SyncLoop) RunReturns 

func (fake *SyncLoop) RunReturns(result1 error)

func (*SyncLoop) RunReturnsOnCall 

func (fake *SyncLoop) RunReturnsOnCall(i int, result1 error)

func (*SyncLoop) Trigger 

func (fake *SyncLoop) Trigger()

func (*SyncLoop) TriggerCallCount 

func (fake *SyncLoop) TriggerCallCount() int

func (*SyncLoop) TriggerCalls 

func (fake *SyncLoop) TriggerCalls(stub func())

type TaskPublisher 

type TaskPublisher struct {
	PublishChangedStub func(context.Context, lib.Task) error

	PublishDeletedStub func(context.Context, lib.TaskIdentifier) error
	// contains filtered or unexported fields
}

func (*TaskPublisher) Invocations 

func (fake *TaskPublisher) Invocations() map[string][][]interface{}

func (*TaskPublisher) PublishChanged 

func (fake *TaskPublisher) PublishChanged(arg1 context.Context, arg2 lib.Task) error

func (*TaskPublisher) PublishChangedArgsForCall 

func (fake *TaskPublisher) PublishChangedArgsForCall(i int) (context.Context, lib.Task)

func (*TaskPublisher) PublishChangedCallCount 

func (fake *TaskPublisher) PublishChangedCallCount() int

func (*TaskPublisher) PublishChangedCalls 

func (fake *TaskPublisher) PublishChangedCalls(stub func(context.Context, lib.Task) error)

func (*TaskPublisher) PublishChangedReturns 

func (fake *TaskPublisher) PublishChangedReturns(result1 error)

func (*TaskPublisher) PublishChangedReturnsOnCall 

func (fake *TaskPublisher) PublishChangedReturnsOnCall(i int, result1 error)

func (*TaskPublisher) PublishDeleted 

func (fake *TaskPublisher) PublishDeleted(arg1 context.Context, arg2 lib.TaskIdentifier) error

func (*TaskPublisher) PublishDeletedArgsForCall 

func (fake *TaskPublisher) PublishDeletedArgsForCall(i int) (context.Context, lib.TaskIdentifier)

func (*TaskPublisher) PublishDeletedCallCount 

func (fake *TaskPublisher) PublishDeletedCallCount() int

func (*TaskPublisher) PublishDeletedCalls 

func (fake *TaskPublisher) PublishDeletedCalls(stub func(context.Context, lib.TaskIdentifier) error)

func (*TaskPublisher) PublishDeletedReturns 

func (fake *TaskPublisher) PublishDeletedReturns(result1 error)

func (*TaskPublisher) PublishDeletedReturnsOnCall 

func (fake *TaskPublisher) PublishDeletedReturnsOnCall(i int, result1 error)

type VaultScanner 

type VaultScanner struct {
	RunStub func(context.Context, chan<- scanner.ScanResult) error

	RunCycleStub func(context.Context, chan<- scanner.ScanResult)
	// contains filtered or unexported fields
}

func (*VaultScanner) Invocations 

func (fake *VaultScanner) Invocations() map[string][][]interface{}

func (*VaultScanner) Run 

func (fake *VaultScanner) Run(arg1 context.Context, arg2 chan<- scanner.ScanResult) error

func (*VaultScanner) RunArgsForCall 

func (fake *VaultScanner) RunArgsForCall(i int) (context.Context, chan<- scanner.ScanResult)

func (*VaultScanner) RunCallCount 

func (fake *VaultScanner) RunCallCount() int

func (*VaultScanner) RunCalls 

func (fake *VaultScanner) RunCalls(stub func(context.Context, chan<- scanner.ScanResult) error)

func (*VaultScanner) RunCycle 

func (fake *VaultScanner) RunCycle(arg1 context.Context, arg2 chan<- scanner.ScanResult)

func (*VaultScanner) RunCycleArgsForCall 

func (fake *VaultScanner) RunCycleArgsForCall(i int) (context.Context, chan<- scanner.ScanResult)

func (*VaultScanner) RunCycleCallCount 

func (fake *VaultScanner) RunCycleCallCount() int

func (*VaultScanner) RunCycleCalls 

func (fake *VaultScanner) RunCycleCalls(stub func(context.Context, chan<- scanner.ScanResult))

func (*VaultScanner) RunReturns 

func (fake *VaultScanner) RunReturns(result1 error)

func (*VaultScanner) RunReturnsOnCall 

func (fake *VaultScanner) RunReturnsOnCall(i int, result1 error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.