utils

package

v0.3.0 Latest Latest Go to latest Published: Mar 22, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/edgefarm/provider-nats

Links

Open Source Insights

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
type Pub
type StreamInfo

Constants ¶

View Source

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

Variables ¶

View Source

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
}

Source Files ¶

View all Source files

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