versions

Documentation

Index

• Variables
• type KuberpultEvent
• type VersionClient
  • func New(oclient api.OverviewServiceClient, vclient api.VersionServiceClient, ...) VersionClient
• type VersionEventProcessor
• type VersionInfo
  • func (v *VersionInfo) Equal(w *VersionInfo) bool

Variables

var ErrNotFound error = fmt.Errorf("not found")

var RolloutServiceUser auth.User = auth.User{
	Email: "kuberpult-rollout-service@local",
	Name:  "kuberpult-rollout-service",
}

This is a the user that the rollout service uses to query the versions. It is not written to the repository.

Types

type KuberpultEvent

type KuberpultEvent struct {
	Environment      string
	Application      string
	EnvironmentGroup string
	IsProduction     bool
	Team             string
	Version          *VersionInfo
}

type VersionClient

type VersionClient interface {
	GetVersion(ctx context.Context, revision, environment, application string) (*VersionInfo, error)
	ConsumeEvents(ctx context.Context, processor VersionEventProcessor, hr *setup.HealthReporter) error
	GetArgoProcessor() *argo.ArgoAppProcessor
}

func New

func New(oclient api.OverviewServiceClient, vclient api.VersionServiceClient, appClient application.ApplicationServiceClient, manageArgoApplicationEnabled bool, manageArgoApplicationFilter []string) VersionClient

type VersionEventProcessor

type VersionEventProcessor interface {
	ProcessKuberpultEvent(ctx context.Context, ev KuberpultEvent)
}

type VersionInfo

type VersionInfo struct {
	Version        uint64
	SourceCommitId string
	DeployedAt     time.Time
}

var ZeroVersion VersionInfo

func (*VersionInfo) Equal

func (v *VersionInfo) Equal(w *VersionInfo) bool