nats

Documentation

Index

• func GetNatsURL(m *v1.AstraConnector) string
• type Deployer
  • func NewNatsDeployer() *Deployer
  • func (n *Deployer) GetConfigMapObject(m *v1.AstraConnector) (*corev1.ConfigMap, error)
  • func (n *Deployer) GetDeploymentObject(m *v1.AstraConnector, ctx context.Context) (*appsv1.Deployment, error)
  • func (n *Deployer) GetNatsClusterServiceObject(m *v1.AstraConnector) (*corev1.Service, error)
  • func (n *Deployer) GetNatsServiceObject(m *v1.AstraConnector) (*corev1.Service, error)
  • func (n *Deployer) GetRoleBindingObject(m *v1.AstraConnector) (*rbacv1.RoleBinding, error)
  • func (n *Deployer) GetRoleObject(m *v1.AstraConnector) (*rbacv1.Role, error)
  • func (n *Deployer) GetServiceAccountObject(m *v1.AstraConnector) (*corev1.ServiceAccount, error)
  • func (n *Deployer) GetServiceObject(m *v1.AstraConnector, serviceName string) (*corev1.Service, error)
  • func (n *Deployer) GetStatefulsetObject(m *v1.AstraConnector, ctx context.Context) (*appsv1.StatefulSet, error)

Functions

func GetNatsURL

func GetNatsURL(m *v1.AstraConnector) string

GetNatsURL returns the nats URL

Types

type Deployer

type Deployer struct{}

func NewNatsDeployer

func NewNatsDeployer() *Deployer

func (*Deployer) GetConfigMapObject

func (n *Deployer) GetConfigMapObject(m *v1.AstraConnector) (*corev1.ConfigMap, error)

GetConfigMapObject returns a ConfigMap object for nats

func (*Deployer) GetDeploymentObject

func (n *Deployer) GetDeploymentObject(m *v1.AstraConnector, ctx context.Context) (*appsv1.Deployment, error)

func (*Deployer) GetNatsClusterServiceObject

func (n *Deployer) GetNatsClusterServiceObject(m *v1.AstraConnector) (*corev1.Service, error)

GetNatsClusterServiceObject returns a cluster Service object for Nats

func (*Deployer) GetNatsServiceObject

func (n *Deployer) GetNatsServiceObject(m *v1.AstraConnector) (*corev1.Service, error)

GetNatsServiceObject returns a Service object for nats

func (*Deployer) GetRoleBindingObject

func (n *Deployer) GetRoleBindingObject(m *v1.AstraConnector) (*rbacv1.RoleBinding, error)

func (*Deployer) GetRoleObject

func (n *Deployer) GetRoleObject(m *v1.AstraConnector) (*rbacv1.Role, error)

func (*Deployer) GetServiceAccountObject

func (n *Deployer) GetServiceAccountObject(m *v1.AstraConnector) (*corev1.ServiceAccount, error)

GetServiceAccountObject returns a ServiceAccount object for nats

func (*Deployer) GetServiceObject

func (n *Deployer) GetServiceObject(m *v1.AstraConnector, serviceName string) (*corev1.Service, error)

GetServiceObject returns a Service object for nats

func (*Deployer) GetStatefulsetObject

func (n *Deployer) GetStatefulsetObject(m *v1.AstraConnector, ctx context.Context) (*appsv1.StatefulSet, error)

GetStatefulsetObject returns a NATS Statefulset object