amqp

type Config struct {
	SourceID        string            `json:"source_id" yaml:"source_id"`
	URL             string            `json:"url" yaml:"url"`
	Queue           string            `json:"queue" yaml:"queue"`
	Exchange        string            `json:"exchange" yaml:"exchange"`
	RoutingKey      string            `json:"routing_key" yaml:"routing_key"`
	ConsumerTag     string            `json:"consumer_tag" yaml:"consumer_tag"`
	AutoAck         bool              `json:"auto_ack" yaml:"auto_ack"`
	Prefetch        int               `json:"prefetch" yaml:"prefetch"`
	Format          string            `json:"format" yaml:"format"` // json or raw
	SchemaName      string            `json:"schema_name" yaml:"schema_name"`
	SchemaVersion   string            `json:"schema_version" yaml:"schema_version"`
	SchemaHeader    string            `json:"schema_header" yaml:"schema_header"`
	QueueDeclare    bool              `json:"queue_declare" yaml:"queue_declare"`
	QueueDurable    bool              `json:"queue_durable" yaml:"queue_durable"`
	QueueExclusive  bool              `json:"queue_exclusive" yaml:"queue_exclusive"`
	QueueAutoDel    bool              `json:"queue_auto_delete" yaml:"queue_auto_delete"`
	ExchangeType    string            `json:"exchange_type" yaml:"exchange_type"`
	ExchangeDeclare bool              `json:"exchange_declare" yaml:"exchange_declare"`
	Headers         map[string]string `json:"headers" yaml:"headers"`
	BufferSize      int               `json:"buffer_size" yaml:"buffer_size"`
}

type Factory struct{}

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