clients

Documentation

Index

• type Artifact
• type ArtifactMetadata
• type ArtifactType
• type CachedPropagationBackendClient
  • func NewCachedPropagationBackendClient(client PropagationBackendClient) CachedPropagationBackendClient
  • func (c *CachedPropagationBackendClient) Fetch(metadata ArtifactMetadata) (Artifact, error)
  • func (c *CachedPropagationBackendClient) Publish(metadata ArtifactMetadata, a Artifact) error
• type OCIPropagationBackendClient
  • func NewOCIPropagationBackendClient(repository name.Repository) OCIPropagationBackendClient
  • func (c *OCIPropagationBackendClient) Digest(m ArtifactMetadata) (string, error)
  • func (c *OCIPropagationBackendClient) Fetch(m ArtifactMetadata) (Artifact, error)
  • func (*OCIPropagationBackendClient) NewArtifact(data any) (Artifact, error)
  • func (c *OCIPropagationBackendClient) ParseArtifact(a Artifact, dest any) error
  • func (c *OCIPropagationBackendClient) Publish(m ArtifactMetadata, a Artifact) error
• type PropagationBackendClient
• type PropagationClient
  • func NewPropagationClient(client PropagationBackendClient) PropagationClient
  • func (c *PropagationClient) GetConfig() (*config.Config, error)
  • func (c *PropagationClient) GetStatus(deployment string) (*v1alpha1.DeploymentStatus, error)
  • func (c *PropagationClient) Propagate(deployment, version string) error
  • func (c *PropagationClient) PublishConfig(config config.Config) error
  • func (c *PropagationClient) PublishStatus(deployment string, status v1alpha1.DeploymentStatus) error
• type PropagationClientset
  • func NewPropagationClientset(k8sClient client.Client) PropagationClientset
  • func (pc *PropagationClientset) Propagation(propagation v1alpha1.Propagation) (*PropagationClient, error)

Types

type Artifact

type Artifact interface {
	DigestString() (string, error)
	Bytes() ([]byte, error)
}

type ArtifactMetadata

type ArtifactMetadata struct {
	Deployment string
	Type       ArtifactType
	Version    string
}

type ArtifactType

type ArtifactType int

const (
	DeployStatusArtifactType ArtifactType = iota
	ManifestArtifactType
	DeployArtifactType
	PropagationConfigArtifactType
)

type CachedPropagationBackendClient

type CachedPropagationBackendClient struct {
	PropagationBackendClient
	// contains filtered or unexported fields
}

func NewCachedPropagationBackendClient

func NewCachedPropagationBackendClient(client PropagationBackendClient) CachedPropagationBackendClient

func (*CachedPropagationBackendClient) Fetch

func (c *CachedPropagationBackendClient) Fetch(metadata ArtifactMetadata) (Artifact, error)

Fetch implements PropagationBackendClient.

func (*CachedPropagationBackendClient) Publish

func (c *CachedPropagationBackendClient) Publish(metadata ArtifactMetadata, a Artifact) error

Publish implements PropagationBackendClient.

type OCIPropagationBackendClient

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

func NewOCIPropagationBackendClient

func NewOCIPropagationBackendClient(repository name.Repository) OCIPropagationBackendClient

func (*OCIPropagationBackendClient) Digest

func (c *OCIPropagationBackendClient) Digest(m ArtifactMetadata) (string, error)

Digest implements PropagationBackendClient.

func (*OCIPropagationBackendClient) Fetch

func (c *OCIPropagationBackendClient) Fetch(m ArtifactMetadata) (Artifact, error)

Fetch implements PropagationBackendClient.

func (*OCIPropagationBackendClient) NewArtifact

func (*OCIPropagationBackendClient) NewArtifact(data any) (Artifact, error)

NewArtifact implements PropagationBackendClient.

func (*OCIPropagationBackendClient) ParseArtifact

func (c *OCIPropagationBackendClient) ParseArtifact(a Artifact, dest any) error

ParseArtifact implements PropagationBackendClient.

func (*OCIPropagationBackendClient) Publish

func (c *OCIPropagationBackendClient) Publish(m ArtifactMetadata, a Artifact) error

Publish implements PropagationBackendClient.

type PropagationBackendClient

type PropagationBackendClient interface {
	Fetch(ArtifactMetadata) (Artifact, error)
	Digest(ArtifactMetadata) (string, error)
	Publish(ArtifactMetadata, Artifact) error
	NewArtifact(data any) (Artifact, error)
	ParseArtifact(a Artifact, dest any) error
}

type PropagationClient

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

func NewPropagationClient

func NewPropagationClient(client PropagationBackendClient) PropagationClient

func (*PropagationClient) GetConfig

func (c *PropagationClient) GetConfig() (*config.Config, error)

func (*PropagationClient) GetStatus

func (c *PropagationClient) GetStatus(deployment string) (*v1alpha1.DeploymentStatus, error)

func (*PropagationClient) Propagate

func (c *PropagationClient) Propagate(deployment, version string) error

func (*PropagationClient) PublishConfig

func (c *PropagationClient) PublishConfig(config config.Config) error

func (*PropagationClient) PublishStatus

func (c *PropagationClient) PublishStatus(deployment string, status v1alpha1.DeploymentStatus) error

type PropagationClientset

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

func NewPropagationClientset

func NewPropagationClientset(k8sClient client.Client) PropagationClientset

func (*PropagationClientset) Propagation

func (pc *PropagationClientset) Propagation(propagation v1alpha1.Propagation) (*PropagationClient, error)