db

package
v0.8.0 Latest Latest
Warning

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

Go to latest
Published: Sep 5, 2018 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AnnotationsFromConnectionState added in v0.5.0

func AnnotationsFromConnectionState(connectionState *appv1.ConnectionState) map[string]string

func ConnectionStateFromAnnotations added in v0.5.0

func ConnectionStateFromAnnotations(annotations map[string]string) appv1.ConnectionState

func SecretToCluster added in v0.5.0

func SecretToCluster(s *apiv1.Secret) *appv1.Cluster

SecretToCluster converts a secret into a repository object

func SecretToRepo added in v0.5.0

func SecretToRepo(s *apiv1.Secret) *appsv1.Repository

SecretToRepo converts a secret into a repository object, optionally redacting sensitive information

Types

type ArgoDB

type ArgoDB interface {
	// ListClusters lists configured clusters
	ListClusters(ctx context.Context) (*appv1.ClusterList, error)
	// CreateCluster creates a cluster
	CreateCluster(ctx context.Context, c *appv1.Cluster) (*appv1.Cluster, error)
	// WatchClusters allow watching for cluster events
	WatchClusters(ctx context.Context, callback func(*ClusterEvent)) error
	// Get returns a cluster from a query
	GetCluster(ctx context.Context, name string) (*appv1.Cluster, error)
	// UpdateCluster updates a cluster
	UpdateCluster(ctx context.Context, c *appv1.Cluster) (*appv1.Cluster, error)
	// DeleteCluster deletes a cluster by name
	DeleteCluster(ctx context.Context, name string) error

	// ListRepositories lists repositories
	ListRepositories(ctx context.Context) (*appv1.RepositoryList, error)
	// CreateRepository creates a repository
	CreateRepository(ctx context.Context, r *appv1.Repository) (*appv1.Repository, error)
	// GetRepository returns a repository by URL
	GetRepository(ctx context.Context, name string) (*appv1.Repository, error)
	// UpdateRepository updates a repository
	UpdateRepository(ctx context.Context, r *appv1.Repository) (*appv1.Repository, error)
	// DeleteRepository updates a repository
	DeleteRepository(ctx context.Context, name string) error
}

func NewDB

func NewDB(namespace string, kubeclientset kubernetes.Interface) ArgoDB

NewDB returns a new instance of the argo database

type ClusterEvent

type ClusterEvent struct {
	Type    watch.EventType
	Cluster *appv1.Cluster
}

ClusterEvent contains information about cluster event

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL