broker

Documentation

Index

• Constants
• type Broker
  • func NewBroker(service *service.Service, config *config.Broker) (*Broker, error)
• type BrokerConsume
  • func NewConsumer(service *service.Service, conf *config.Broker) (*BrokerConsume, error)
  • func (k *BrokerConsume) ProcessEvent(event domain.Event)
  • func (k *BrokerConsume) Subscribe() error
• type BrokerProduce
  • func NewProducer(conf *config.Broker) (*BrokerProduce, error)
  • func (k *BrokerProduce) Produce(evetType domain.EventType, eventTopic string, eventPayload interface{}) error
• type Consumer
• type Producer

Constants

const (
	SECURITY_PROTOCOL = "SASL_SSL"
	SASL_MECHANISMS   = "PLAIN" // "SCRAM-SHA-256"
)

const (
	AUTO_OFFSET_RESET = "earliest"
)

Types

type Broker

type Broker struct {
	Producer
	Consumer
	TopicAccountBE, TopicAccountCUD   string
	TopicProductBE, TopicProductCUD   string
	TopicOrderBE, TopicOrderCUD       string
	TopicDeliveryBE, TopicDeliveryCUD string
	TopicBillingBE, TopicBillingCUD   string
}

Broker

func NewBroker

func NewBroker(service *service.Service, config *config.Broker) (*Broker, error)

NewBroker - constructor

type BrokerConsume

type BrokerConsume struct {
	TopicAccountBE, TopicAccountCUD   string
	TopicProductBE, TopicProductCUD   string
	TopicOrderBE, TopicOrderCUD       string
	TopicDeliveryBE, TopicDeliveryCUD string
	TopicBillingBE, TopicBillingCUD   string
	// contains filtered or unexported fields
}

func NewConsumer

func NewConsumer(service *service.Service, conf *config.Broker) (*BrokerConsume, error)

func (*BrokerConsume) ProcessEvent

func (k *BrokerConsume) ProcessEvent(event domain.Event)

func (*BrokerConsume) Subscribe

func (k *BrokerConsume) Subscribe() error

type BrokerProduce

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

func NewProducer

func NewProducer(conf *config.Broker) (*BrokerProduce, error)

func (*BrokerProduce) Produce

func (k *BrokerProduce) Produce(evetType domain.EventType, eventTopic string, eventPayload interface{}) error

type Consumer

type Consumer interface {
	Subscribe() error
	ProcessEvent(event domain.Event)
}

type Producer

type Producer interface {
	Produce(evetType domain.EventType, eventTopic string, eventPayload interface{}) error
}