azuredevops

Documentation

Overview

Package azuredevops contains Azure DevOps specific implementations of source-related functionality.

Index

• Variables
• type Source
  • func NewSource() (*Source, error)
  • func (s *Source) Close(ctx context.Context, _ time.Duration) error
  • func (s *Source) GetWebhook(ctx context.Context, typesToStream map[string]source.Extra, ...) (source.Webhook, error)
  • func (s *Source) StartSyncProcess(ctx context.Context, typesToFilter map[string]source.Extra, ...) error

Variables

var (
	// ErrMissingEnvVariable reports missing mandatory environment variables.
	ErrMissingEnvVariable = errors.New("missing environment variable")
	// ErrInvalidEnvVariable reports malformed environment variable values.
	ErrInvalidEnvVariable = errors.New("invalid environment value")
)

var (
	ErrDevOpsSource = errors.New("azure devops source")

	ErrNoAuthenticationHeaderFound        = errors.New("no authentication header found in request")
	ErrMultipleAuthenticationHeadersFound = errors.New("multiple authentication headers found in request")
	ErrInvalidAuthenticationType          = errors.New("invalid authentication type in request")
	ErrUnauthorized                       = errors.New("unauthorized request")

	ErrInvalidWebhookPayload = errors.New("invalid webhook payload")
)

Types

type Source

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

Source implement both source.WebhookSource and source.SyncableSource for Azure DevOps.

func NewSource

func NewSource() (*Source, error)

NewSource creates a new Azure DevOps Source reading the needed configuration from the env variables.

func (*Source) Close

func (s *Source) Close(ctx context.Context, _ time.Duration) error

Close implement source.ClosableSource interface.

func (*Source) GetWebhook

func (s *Source) GetWebhook(ctx context.Context, typesToStream map[string]source.Extra, results chan<- source.Data) (source.Webhook, error)

GetWebhook implement source.WebhookSource interface.

func (*Source) StartSyncProcess

func (s *Source) StartSyncProcess(ctx context.Context, typesToFilter map[string]source.Extra, dataChannel chan<- source.Data) error

StartSyncProcess implement source.SyncableSource interface.