utils

Documentation

Index

• Constants
• Variables
• func CreateFramework(ctx context.Context, scheme *runtime.Scheme) error
• func UnmarshalAnyYaml[T any](path string, out *T) (*T, error)
• type Framework
  • func (f *Framework) ApplyOrUpdate(obj ctrlclient.Object) error
  • func (f *Framework) Cleanup() error
  • func (f *Framework) CreateConsumer(consumer *v1alpha1.Consumer) error
  • func (f *Framework) CreateNamespace(ns string) error
  • func (f *Framework) CreateOrLeaveStream(stream *v1alpha1.Stream) error
  • func (f *Framework) CreateStream(stream *v1alpha1.Stream) error
  • func (f *Framework) DeleteConsumer(consumer string) error
  • func (f *Framework) DeleteNamespace(ns string, waitUntilDeleted bool) error
  • func (f *Framework) DeleteObj(obj ctrlclient.Object) error
  • func (f *Framework) DeleteStream(stream string) error
  • func (f *Framework) GetConsumer(consumer string) (*v1alpha1.Consumer, error)
  • func (f *Framework) GetConsumerParameters(name string) (*v1alpha1.ConsumerParameters, error)
  • func (f *Framework) GetDefaultSecurityContext() *corev1.SecurityContext
  • func (f *Framework) GetSecret(nameSpace string, secretName string) (map[string][]byte, error)
  • func (f *Framework) GetStream(stream string) (*v1alpha1.Stream, error)
  • func (f *Framework) GetStreamAccountPublicKey(name string) (string, error)
  • func (f *Framework) GetStreamDomain(name string) (string, error)
  • func (f *Framework) GetStreamParameters(name string) (*v1alpha1.StreamParameters, error)
  • func (f *Framework) GetStreamUserPublicKey(name string) (string, error)
  • func (f *Framework) ListConsumer() (*v1alpha1.ConsumerList, error)
  • func (f *Framework) ListStream() (*v1alpha1.StreamList, error)
  • func (f *Framework) NatsCheckMessages(p *StreamInfo) error
  • func (f *Framework) NatsPublish(p *Pub) error
  • func (f *Framework) UpdateConsumer(consumer *v1alpha1.Consumer) error
  • func (f *Framework) UpdateStream(stream *v1alpha1.Stream) error
  • func (f *Framework) WairForDeleted(obj ctrlclient.Object) error
  • func (f *Framework) WaitForConsumerCondition(name string, condition *v1.Condition) error
  • func (f *Framework) WaitForConsumerConditionsAvailable(name string, amount int) error
  • func (f *Framework) WaitForConsumerDeleted(name string) error
  • func (f *Framework) WaitForConsumerSyncAndReady(name string) error
  • func (f *Framework) WaitForJobFinished(name string, namespace string) error
  • func (f *Framework) WaitForPodFinished(name string, namespace string) error
  • func (f *Framework) WaitForStreamConditionsAvailable(name string, amount int) error
  • func (f *Framework) WaitForStreamDeleted(name string) error
  • func (f *Framework) WaitForStreamMessags(name string, messages uint64) error
  • func (f *Framework) WaitForStreamSyncAndReady(name string) error
• type Pub
• type StreamInfo

Constants

const (
	PollTimeout          = 2 * time.Minute
	DefaultClientTimeout = 32 * time.Second // the default in client-go is 32
)

Variables

var DefaultFramework = &Framework{}

Functions

func CreateFramework

func CreateFramework(ctx context.Context, scheme *runtime.Scheme) error

func UnmarshalAnyYaml

func UnmarshalAnyYaml[T any](path string, out *T) (*T, error)

UnmarshalAnyYaml unmarshals a yaml file into a struct

Types

type Framework

type Framework struct {
	// The context to use for testing
	Context context.Context

	// ClientSet is the kubernetes client of the current
	// host kubernetes cluster were we are testing in
	ClientSet *kubernetes.Clientset

	StreamsClientset *streamclientv1.StreamV1alpha1Client

	ConsumersClientset *consumerclientv1.ConsumerV1alpha1Client

	// CtrlClient is the kubernetes client originally supposed
	// to write controllers. It provides some convinience methods
	// e.g. create objects
	CtrlClient ctrlclient.Client

	// Scheme is the global scheme to use
	Scheme *runtime.Scheme

	// ClientTimeout value used in the clients
	ClientTimeout time.Duration
}

func (*Framework) ApplyOrUpdate

func (f *Framework) ApplyOrUpdate(obj ctrlclient.Object) error

ApplyOrUpdate applies or updates the given object.

func (*Framework) Cleanup

func (f *Framework) Cleanup() error

func (*Framework) CreateConsumer

func (f *Framework) CreateConsumer(consumer *v1alpha1.Consumer) error

func (*Framework) CreateNamespace

func (f *Framework) CreateNamespace(ns string) error

func (*Framework) CreateOrLeaveStream

func (f *Framework) CreateOrLeaveStream(stream *v1alpha1.Stream) error

func (*Framework) CreateStream

func (f *Framework) CreateStream(stream *v1alpha1.Stream) error

func (*Framework) DeleteConsumer

func (f *Framework) DeleteConsumer(consumer string) error

func (*Framework) DeleteNamespace

func (f *Framework) DeleteNamespace(ns string, waitUntilDeleted bool) error

func (*Framework) DeleteObj

func (f *Framework) DeleteObj(obj ctrlclient.Object) error

DeleteObj deletes or updates the given object.

func (*Framework) DeleteStream

func (f *Framework) DeleteStream(stream string) error

func (*Framework) GetConsumer

func (f *Framework) GetConsumer(consumer string) (*v1alpha1.Consumer, error)

func (*Framework) GetConsumerParameters

func (f *Framework) GetConsumerParameters(name string) (*v1alpha1.ConsumerParameters, error)

func (*Framework) GetDefaultSecurityContext

func (f *Framework) GetDefaultSecurityContext() *corev1.SecurityContext

func (*Framework) GetSecret

func (f *Framework) GetSecret(nameSpace string, secretName string) (map[string][]byte, error)

GetSecret from Kubernetes

func (*Framework) GetStream

func (f *Framework) GetStream(stream string) (*v1alpha1.Stream, error)

func (*Framework) GetStreamAccountPublicKey

func (f *Framework) GetStreamAccountPublicKey(name string) (string, error)

func (*Framework) GetStreamDomain

func (f *Framework) GetStreamDomain(name string) (string, error)

func (*Framework) GetStreamParameters

func (f *Framework) GetStreamParameters(name string) (*v1alpha1.StreamParameters, error)

func (*Framework) GetStreamUserPublicKey

func (f *Framework) GetStreamUserPublicKey(name string) (string, error)

func (*Framework) ListConsumer

func (f *Framework) ListConsumer() (*v1alpha1.ConsumerList, error)

func (*Framework) ListStream

func (f *Framework) ListStream() (*v1alpha1.StreamList, error)

func (*Framework) NatsCheckMessages

func (f *Framework) NatsCheckMessages(p *StreamInfo) error

func (*Framework) NatsPublish

func (f *Framework) NatsPublish(p *Pub) error

func (*Framework) UpdateConsumer

func (f *Framework) UpdateConsumer(consumer *v1alpha1.Consumer) error

func (*Framework) UpdateStream

func (f *Framework) UpdateStream(stream *v1alpha1.Stream) error

func (*Framework) WairForDeleted

func (f *Framework) WairForDeleted(obj ctrlclient.Object) error

WairForDeleted waits for the given object to be deleted.

func (*Framework) WaitForConsumerCondition

func (f *Framework) WaitForConsumerCondition(name string, condition *v1.Condition) error

func (*Framework) WaitForConsumerConditionsAvailable

func (f *Framework) WaitForConsumerConditionsAvailable(name string, amount int) error

func (*Framework) WaitForConsumerDeleted

func (f *Framework) WaitForConsumerDeleted(name string) error

func (*Framework) WaitForConsumerSyncAndReady

func (f *Framework) WaitForConsumerSyncAndReady(name string) error

func (*Framework) WaitForJobFinished

func (f *Framework) WaitForJobFinished(name string, namespace string) error

func (*Framework) WaitForPodFinished

func (f *Framework) WaitForPodFinished(name string, namespace string) error

func (*Framework) WaitForStreamConditionsAvailable

func (f *Framework) WaitForStreamConditionsAvailable(name string, amount int) error

func (*Framework) WaitForStreamDeleted

func (f *Framework) WaitForStreamDeleted(name string) error

func (*Framework) WaitForStreamMessags

func (f *Framework) WaitForStreamMessags(name string, messages uint64) error

func (*Framework) WaitForStreamSyncAndReady

func (f *Framework) WaitForStreamSyncAndReady(name string) error

type Pub

type Pub struct {
	JWT     string
	Seed    string
	Address string
	Subject string
	Count   string
	Data    string
}

type StreamInfo

type StreamInfo struct {
	JWT      string
	Seed     string
	Address  string
	Count    string
	Stream   string
	Timeout  string
	Interval string
	Domain   string
}