kubernetes

Documentation

Index

• Constants
• Variables
• func ApplyPodRequest(ctx context.Context, client k8cl.Client, namespace string, update bool, ...) error
• func GetClient(kubeConfig string, dryRun bool) (client.Client, error)
• func GetConfig(kubeConfig string) (*rest.Config, error)
• func GetResource(kind string) interface{}
• func GetScheme() (*runtime.Scheme, error)
• func NewHttpSo(namespace, name string) *kedahttpv1alpha1.HTTPScaledObject
• func NewService(port *pb.Container_Port, portName string, ...) (*corev1.Service, int32, error)
• func NewTrustedPodsNamespace(name string, paymentChannel *pb.PaymentChannel) *corev1.Namespace
• func RunInNamespaceOrRevert(ctx context.Context, cl client.Client, namespace *corev1.Namespace, ...) error
• func TrustedPodsNamespaceGetChannel(namespace *corev1.Namespace) (*pb.PaymentChannel, error)
• type FetchSecret

Constants

const (
	LabelTrustedPodsNamespace            string = "coop.comrade/apocryph-namespace"
	AnnotationsTrustedPodsPaymentChannel string = "coop.comrade/apocryph-payment-contract"
	LabelIpfsP2P                         string = "coop.comrade/apocryph-p2p-helper"
	AnnotationsIpfsP2P                   string = "coop.comrade/apocryph-p2p-helper"
)

Variables

var TrustedPodsNamespaceFilter = client.HasLabels{LabelTrustedPodsNamespace}

Functions

func ApplyPodRequest

func ApplyPodRequest(
	ctx context.Context,
	client k8cl.Client,
	namespace string,
	update bool,
	podManifest *pb.Pod,
	images map[string]string,
	secrets map[string][]byte,
	response *pb.ProvisionPodResponse,
) error

func GetClient

func GetClient(kubeConfig string, dryRun bool) (client.Client, error)

func GetConfig

func GetConfig(kubeConfig string) (*rest.Config, error)

func GetResource

func GetResource(kind string) interface{}

func GetScheme

func GetScheme() (*runtime.Scheme, error)

func NewHttpSo

func NewHttpSo(namespace, name string) *kedahttpv1alpha1.HTTPScaledObject

func NewService

func NewService(port *pb.Container_Port, portName string, httpSO *kedahttpv1alpha1.HTTPScaledObject, labels map[string]string) (*corev1.Service, int32, error)

func NewTrustedPodsNamespace

func NewTrustedPodsNamespace(name string, paymentChannel *pb.PaymentChannel) *corev1.Namespace

func RunInNamespaceOrRevert

func RunInNamespaceOrRevert(ctx context.Context, cl client.Client, namespace *corev1.Namespace, dryRun bool, block func(client.Client) error) error

func TrustedPodsNamespaceGetChannel

func TrustedPodsNamespaceGetChannel(namespace *corev1.Namespace) (*pb.PaymentChannel, error)

Types

type FetchSecret

type FetchSecret func(cid []byte) (map[string][]byte, error)