network

Documentation

Index

• Constants
• type Jetstream
  • func NewJetstream(creds string) (*Jetstream, error)
  • func (j *Jetstream) Cleanup()
  • func (j *Jetstream) CreateForMainDomain(network string, streamConfig networkv1alpha1.StreamSpec) error
  • func (j *Jetstream) CreateWithDomain(domain string, network string, streamConfig networkv1alpha1.StreamSpec) error
  • func (j *Jetstream) DeleteForMainDomain(network string, names []string) error
  • func (j *Jetstream) DeleteWithDomain(domain string, network string, names []string) error
  • func (j *Jetstream) JetstreamExistsWithDomain(domain string, streamName string) (bool, error)
• type NetworksReconciler
  • func (r *NetworksReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *NetworksReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ParticipantsReconciler
  • func (r *ParticipantsReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ParticipantsReconciler) SetupWithManager(mgr ctrl.Manager) error
• type PodsReconiler
  • func (r *PodsReconiler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *PodsReconiler) SetupWithManager(mgr ctrl.Manager) error

Constants

const (
	// DefaultMainDomain is the default domain for the main jetstream cluster
	DefaultMainDomain = "main"
)

const (

	// NetworkFinalizer is the name of the finalizer which will be added to the
	NetworkFinalizer = "network.edgefarm.io/finalizer"
)

const (
	// PodFinalizer is the name of the finalizer which will be added to the
	PodFinalizer = "applications.edgefarm.io/finalizer"
)

Types

type Jetstream

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

Jetstream is a type that handle jetstreams

func NewJetstream

func NewJetstream(creds string) (*Jetstream, error)

NewJetstream creates a new jetstream handler instance

func (*Jetstream) Cleanup

func (j *Jetstream) Cleanup()

Cleanup clears the jetstream handler

func (*Jetstream) CreateForMainDomain

func (j *Jetstream) CreateForMainDomain(network string, streamConfig networkv1alpha1.StreamSpec) error

CreateForMainDomain creates a new jetstream stream with a given configuration fot domain `main`

func (*Jetstream) CreateWithDomain

func (j *Jetstream) CreateWithDomain(domain string, network string, streamConfig networkv1alpha1.StreamSpec) error

CreateWithDomain creates a new jetstream stream with a given configuration for a given domain

func (*Jetstream) DeleteForMainDomain

func (j *Jetstream) DeleteForMainDomain(network string, names []string) error

DeleteForMainDomain deletes a jetstream stream for a domain 'main'

func (*Jetstream) DeleteWithDomain

func (j *Jetstream) DeleteWithDomain(domain string, network string, names []string) error

DeleteWithDomain deletes a jetstream stream for a given domain

func (*Jetstream) JetstreamExistsWithDomain

func (j *Jetstream) JetstreamExistsWithDomain(domain string, streamName string) (bool, error)

JetstreamExistsWithDomain checks if a jetstream stream exists

type NetworksReconciler

type NetworksReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

NetworksReconciler reconciles a Network object

func (*NetworksReconciler) Reconcile

func (r *NetworksReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the Network object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.10.0/pkg/reconcile

func (*NetworksReconciler) SetupWithManager

func (r *NetworksReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type ParticipantsReconciler

type ParticipantsReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

ParticipantsReconciler reconciles a Participants object

func (*ParticipantsReconciler) Reconcile

func (r *ParticipantsReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the Participants object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.0/pkg/reconcile

func (*ParticipantsReconciler) SetupWithManager

func (r *ParticipantsReconciler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.

type PodsReconiler

type PodsReconiler struct {
	client.Client
	Scheme *runtime.Scheme
}

PodsReconiler reconciles a Participants object

func (*PodsReconiler) Reconcile

func (r *PodsReconiler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state. TODO(user): Modify the Reconcile function to compare the state specified by the Participants object against the actual cluster state, and then perform operations to make the cluster state reflect the state specified by the user.

For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.0/pkg/reconcile

func (*PodsReconiler) SetupWithManager

func (r *PodsReconiler) SetupWithManager(mgr ctrl.Manager) error

SetupWithManager sets up the controller with the Manager.