webhook_creator

Documentation

Index

• type MockGitProviderClient
  • func (m *MockGitProviderClient) GetCorrelatingEvent(ctx context.Context, workflowEvent *v1alpha1.WorkflowPhase) (string, error)
  • func (m *MockGitProviderClient) GetFile(ctx context2.Context, repo string, branch string, path string) (*git_provider.CommitFile, error)
  • func (m *MockGitProviderClient) GetFiles(ctx context2.Context, repo string, branch string, paths []string) ([]*git_provider.CommitFile, error)
  • func (m *MockGitProviderClient) HandlePayload(ctx context2.Context, request *http.Request, secret []byte) (*git_provider.WebhookPayload, error)
  • func (m *MockGitProviderClient) ListFiles(ctx context2.Context, repo string, branch string, path string) ([]string, error)
  • func (m *MockGitProviderClient) PingHook(ctx context2.Context, hook *git_provider.HookWithStatus) error
  • func (m *MockGitProviderClient) SetStatus(ctx context2.Context, repo *string, commit *string, linkURL *string, ...) error
  • func (m *MockGitProviderClient) SetWebhook(ctx context2.Context, repo *string) (*git_provider.HookWithStatus, error)
  • func (m *MockGitProviderClient) UnsetWebhook(ctx context2.Context, hook *git_provider.HookWithStatus) error
• type WebhookCreator
• type WebhookCreatorImpl
  • func NewWebhookCreator(cfg *conf.GlobalConfig, clients *clients.Clients) *WebhookCreatorImpl
  • func (wc *WebhookCreatorImpl) GetHooks() *map[int64]*git_provider.HookWithStatus
  • func (wc *WebhookCreatorImpl) RunDiagnosis(ctx context.Context) error
  • func (wc *WebhookCreatorImpl) SetWebhookHealth(hookID int64, status bool) error
  • func (wc *WebhookCreatorImpl) Start(ctx context.Context)
  • func (wc *WebhookCreatorImpl) Stop(ctx context.Context)

Types

type MockGitProviderClient

type MockGitProviderClient struct {
	ListFilesFunc           func(ctx context.Context, repo string, branch string, path string) ([]string, error)
	GetFileFunc             func(ctx context.Context, repo string, branch string, path string) (*git_provider.CommitFile, error)
	GetFilesFunc            func(ctx context.Context, repo string, branch string, paths []string) ([]*git_provider.CommitFile, error)
	SetWebhookFunc          func(ctx context.Context, repo *string) (*git_provider.HookWithStatus, error)
	UnsetWebhookFunc        func(ctx context.Context, hook *git_provider.HookWithStatus) error
	HandlePayloadFunc       func(request *http.Request, secret []byte) (*git_provider.WebhookPayload, error)
	SetStatusFunc           func(ctx context.Context, repo *string, commit *string, linkURL *string, status *string, message *string) error
	PingHookFunc            func(ctx context.Context, hook *git_provider.HookWithStatus) error
	GetCorrelatingEventFunc func(ctx context.Context, workflowEvent *v1alpha1.WorkflowPhase) (string, error)
}

func (*MockGitProviderClient) GetCorrelatingEvent

func (m *MockGitProviderClient) GetCorrelatingEvent(ctx context.Context, workflowEvent *v1alpha1.WorkflowPhase) (string, error)

func (*MockGitProviderClient) GetFile

func (m *MockGitProviderClient) GetFile(ctx context2.Context, repo string, branch string, path string) (*git_provider.CommitFile, error)

func (*MockGitProviderClient) GetFiles

func (m *MockGitProviderClient) GetFiles(ctx context2.Context, repo string, branch string, paths []string) ([]*git_provider.CommitFile, error)

func (*MockGitProviderClient) HandlePayload

func (m *MockGitProviderClient) HandlePayload(ctx context2.Context, request *http.Request, secret []byte) (*git_provider.WebhookPayload, error)

func (*MockGitProviderClient) ListFiles

func (m *MockGitProviderClient) ListFiles(ctx context2.Context, repo string, branch string, path string) ([]string, error)

func (*MockGitProviderClient) PingHook

func (m *MockGitProviderClient) PingHook(ctx context2.Context, hook *git_provider.HookWithStatus) error

func (*MockGitProviderClient) SetStatus

func (m *MockGitProviderClient) SetStatus(ctx context2.Context, repo *string, commit *string, linkURL *string, status *string, message *string) error

func (*MockGitProviderClient) SetWebhook

func (m *MockGitProviderClient) SetWebhook(ctx context2.Context, repo *string) (*git_provider.HookWithStatus, error)

func (*MockGitProviderClient) UnsetWebhook

func (m *MockGitProviderClient) UnsetWebhook(ctx context2.Context, hook *git_provider.HookWithStatus) error

type WebhookCreator

type WebhookCreator interface {
	Stop(ctx *context.Context)
	Start()
	SetWebhookHealth(status bool, hookID *int64) error
	RunDiagnosis(ctx *context.Context) error
}

type WebhookCreatorImpl

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

func NewWebhookCreator

func NewWebhookCreator(cfg *conf.GlobalConfig, clients *clients.Clients) *WebhookCreatorImpl

func (*WebhookCreatorImpl) GetHooks

func (wc *WebhookCreatorImpl) GetHooks() *map[int64]*git_provider.HookWithStatus

func (*WebhookCreatorImpl) RunDiagnosis

func (wc *WebhookCreatorImpl) RunDiagnosis(ctx context.Context) error

func (*WebhookCreatorImpl) SetWebhookHealth

func (wc *WebhookCreatorImpl) SetWebhookHealth(hookID int64, status bool) error

func (*WebhookCreatorImpl) Start

func (wc *WebhookCreatorImpl) Start(ctx context.Context)

func (*WebhookCreatorImpl) Stop

func (wc *WebhookCreatorImpl) Stop(ctx context.Context)