build

Documentation

Index

• type DefaultKafkaFactory
  • func NewDefaultKafkaFactory() *DefaultKafkaFactory
• type KafkaMessageQueueFactory
  • func NewKafkaMessageQueueFactory() *KafkaMessageQueueFactory
  • func (c *KafkaMessageQueueFactory) CreateQueue(name string) cqueues.IMessageQueue

Types

type DefaultKafkaFactory

type DefaultKafkaFactory struct {
	*cbuild.Factory
}

Creates KafkaMessageQueue components by their descriptors. See KafkaMessageQueue

func NewDefaultKafkaFactory

func NewDefaultKafkaFactory() *DefaultKafkaFactory

NewDefaultKafkaFactory method are create a new instance of the factory.

type KafkaMessageQueueFactory

type KafkaMessageQueueFactory struct {
	build.MessageQueueFactory
}

KafkaMessageQueueFactory are creates KafkaMessageQueue components by their descriptors. Name of created message queue is taken from its descriptor.

See Factory See KafkaMessageQueue

func NewKafkaMessageQueueFactory

func NewKafkaMessageQueueFactory() *KafkaMessageQueueFactory

NewKafkaMessageQueueFactory method are create a new instance of the factory.

func (*KafkaMessageQueueFactory) CreateQueue

func (c *KafkaMessageQueueFactory) CreateQueue(name string) cqueues.IMessageQueue

Creates a message queue component and assigns its name.

Parameters:

• name: a name of the created message queue.