messaging

Documentation

Index

• type Messaging
  • func (m *Messaging) CreateMessagingSystem(applications []deploymanager.Application) (err error)

Types

type Messaging

type Messaging struct {
	KubeClient    artifact.KubeClient
	SiddhiProcess *siddhiv1alpha2.SiddhiProcess
}

Messaging creates a specific messaging system like NATS

func (*Messaging) CreateMessagingSystem

func (m *Messaging) CreateMessagingSystem(
	applications []deploymanager.Application,
) (err error)

CreateMessagingSystem creates the messaging system if CR needed. If user specify only the messaging system type then this will creates the messaging system.