Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func DumpCassandra ¶
DumpCassandra load all existing cassandra data.
Types ¶
type AmqpConfig ¶
type AmqpConfig struct {
// contains filtered or unexported fields
}
AmqpConfig groups config fields for AMQP
type AmqpEventProcessor ¶
type AmqpEventProcessor struct {
// contains filtered or unexported fields
}
AmqpEventProcessor implements EventProcessor
func NewAmqpEventProcessor ¶
func NewAmqpEventProcessor() *AmqpEventProcessor
NewAmqpEventProcessor return Amqp event processor
type AmqpMessage ¶
type AmqpMessage struct { RequestID string `json:"request_id"` Oper string `json:"oper"` Type string `json:"type"` UUID string `json:"uuid"` FqName []string `json:"fq_name"` Data json.RawMessage `json:"obj_dict"` }
AmqpMessage type
type EventProcessor ¶
type EventProcessor struct {
// contains filtered or unexported fields
}
EventProcessor writes events to cassandra and implements service.EventProcessor interface
func NewEventProcessor ¶
func NewEventProcessor() *EventProcessor
NewEventProcessor returns new cassandra.EventProcessor
type EventProducer ¶
type EventProducer struct { Processor services.EventProcessor // contains filtered or unexported fields }
EventProducer send db update for processor. Event will be harvest from cassandra db and from amqp later on.
func NewEventProducer ¶
func NewEventProducer( processor services.EventProcessor, ) *EventProducer
NewEventProducer makes event producer and couple it with processor given.
Click to show internal directories.
Click to hide internal directories.