qmq

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

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

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

type AudioRequest struct {
	Filename string `protobuf:"bytes,1,opt,name=filename,proto3" json:"filename,omitempty"`
	// contains filtered or unexported fields
}

type Bool struct {
	Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

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

type Connection interface {
	Connect() error
	Disconnect()
}

type ConnectionProvider interface {
	Get(key string) Connection
	Set(key string, connection Connection)
	ForEach(func(key string, connection Connection))
}

type ConnectionProviderFactory interface {
	Create() ConnectionProvider
}

type ConnectionState struct {
	Value ConnectionState_ConnectionStateEnum `protobuf:"varint,1,opt,name=value,proto3,enum=qmq.ConnectionState_ConnectionStateEnum" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type ConnectionState_ConnectionStateEnum int32

type Consumable interface {
	Ack()
	Nack()
	Data() interface{}
}

type Consumer interface {
	Pop() chan Consumable
	Close()
}

type ConsumerFactory interface {
	Create(key string, components EngineComponentProvider) Consumer
}

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

type DefaultConnectionProviderFactory struct{}

type DefaultConsumerFactory struct{}

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

type DefaultEngineConfig struct {
	NameProvider               NameProvider
	TransformerProviderFactory TransformerProviderFactory
	ConnectionProviderFactory  ConnectionProviderFactory
	ConsumerFactory            ConsumerFactory
	ProducerFactory            ProducerFactory
	LoggerFactory              LoggerFactory
	EngineProcessor            EngineProcessor
}

type DefaultEngineProcessor struct{}

type DefaultLoggerFactory struct{}

type DefaultProducerFactory struct{}

type DefaultRedisConnectionDetailsProvider struct{}

type DefaultSchemaFactory struct{}

type DefaultTransformer struct{}

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

type DefaultTransformerProviderFactory struct{}

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

type DefaultWebClientConfig struct {
	Connection                  *websocket.Conn
	WebServiceComponentProvider WebServiceComponentProvider
	OnClose                     func(uint64)
	RequestTransformers         []Transformer
	ResponseTransformers        []Transformer
}

type DefaultWebClientHandler struct{}

type DefaultWebClientHandlerFactory struct{}

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

type DefaultWebServiceConfig struct {
	Logger                  Logger
	Schema                  Schema
	WebClientHandlerFactory WebClientHandlerFactory
	RequestTransformers     []Transformer
	ResponseTransformers    []Transformer
}

type DefaultWebServiceFactory struct{}

type Engine interface {
	Run()
}

type EngineComponentProvider interface {
	WithNameProvider() NameProvider
	WithTransformerProvider() TransformerProvider
	WithConnectionProvider() ConnectionProvider
	WithProducer(key string) Producer
	WithConsumer(key string) Consumer
	WithLogger() Logger
}

type EngineProcessor interface {
	Process(componentProvider EngineComponentProvider)
}

type Float struct {
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type GarageDoorState struct {
	Value GarageDoorState_GarageDoorStateEnum `protobuf:"varint,1,opt,name=value,proto3,enum=qmq.GarageDoorState_GarageDoorStateEnum" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type GarageDoorState_GarageDoorStateEnum int32

type Int struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Log struct {
	Application string                 `protobuf:"bytes,1,opt,name=application,proto3" json:"application,omitempty"`
	Level       Log_LogLevelEnum       `protobuf:"varint,2,opt,name=level,proto3,enum=qmq.Log_LogLevelEnum" json:"level,omitempty"`
	Message     string                 `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

type Log_LogLevelEnum int32

type Logger interface {
	Trace(message string)
	Debug(message string)
	Advise(message string)
	Warn(message string)
	Error(message string)
	Panic(message string)

	Close()
}

type LoggerFactory interface {
	Create(components EngineComponentProvider) Logger
}

type Message struct {
	Id      string     `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	From    string     `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	To      string     `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
	Subject string     `protobuf:"bytes,4,opt,name=subject,proto3" json:"subject,omitempty"`
	Content *anypb.Any `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

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

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

type MqttMessage struct {
	Id        uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Qos       int32  `protobuf:"varint,2,opt,name=qos,proto3" json:"qos,omitempty"`
	Topic     string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload   []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	Retained  bool   `protobuf:"varint,5,opt,name=retained,proto3" json:"retained,omitempty"`
	Duplicate bool   `protobuf:"varint,6,opt,name=duplicate,proto3" json:"duplicate,omitempty"`
	// contains filtered or unexported fields
}

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

type NameProvider interface {
	Get() string
}

type Prayer struct {
	Name string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

type Producer interface {
	Push(i interface{})
	Close()
}

type ProducerFactory interface {
	Create(key string, components EngineComponentProvider) Producer
}

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

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

type RedisConnectionDetailsProvider interface {
	Address() string
	Password() string
}

type RedisConnectionError int

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

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

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

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

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

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

type RedisStream struct {
	Context RedisStreamContext
	Length  int64
	Locker  *RedisLocker
	// contains filtered or unexported fields
}

type RedisStreamContext struct {
	LastConsumedId string `protobuf:"bytes,1,opt,name=last_consumed_id,json=lastConsumedId,proto3" json:"last_consumed_id,omitempty"`
	LastProducedId string `protobuf:"bytes,2,opt,name=last_produced_id,json=lastProducedId,proto3" json:"last_produced_id,omitempty"`
	TotalConsumed  int64  `protobuf:"varint,3,opt,name=total_consumed,json=totalConsumed,proto3" json:"total_consumed,omitempty"`
	TotalProduced  int64  `protobuf:"varint,4,opt,name=total_produced,json=totalProduced,proto3" json:"total_produced,omitempty"`
	// contains filtered or unexported fields
}

type Schema interface {
	Get(key string) proto.Message
	GetFull(key string) (proto.Message, *SchemaData)
	Set(key string, value proto.Message)
	Ch() chan string
}

type SchemaData struct {
	Data      *anypb.Any             `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Writer    string                 `protobuf:"bytes,2,opt,name=writer,proto3" json:"writer,omitempty"`
	Writetime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=writetime,proto3" json:"writetime,omitempty"`
	// contains filtered or unexported fields
}

type SchemaFactory interface {
	Create(components EngineComponentProvider, kv map[string]proto.Message) Schema
}

type String struct {
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type TextToSpeechRequest struct {
	Text string `protobuf:"bytes,1,opt,name=text,proto3" json:"text,omitempty"`
	// contains filtered or unexported fields
}

type Timestamp struct {
	Value *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type Transformer interface {
	Transform(i interface{}) interface{}
}

type TransformerProvider interface {
	Get(key string) []Transformer
	Set(key string, transformers []Transformer)
}

type TransformerProviderFactory interface {
	Create(components EngineComponentProvider) TransformerProvider
}

type WebClient interface {
	Read() chan interface{}
	Write(i interface{})
}

type WebClientHandler interface {
	Handle(client WebClient, componentProvider WebServiceComponentProvider)
}

type WebClientHandlerFactory interface {
	Create() WebClientHandler
}

type WebClientNotifier interface {
	NotifyAll(keys []string)
}

type WebService interface {
	Start(componentProvider EngineComponentProvider)
	WithComponentProvider() WebServiceComponentProvider
}

type WebServiceComponentProvider interface {
	WithLogger() Logger
	WithSchema() Schema
	WithWebClientNotifier() WebClientNotifier
}

type WebServiceCustomProcessor interface {
	Process(engineComponentProvider EngineComponentProvider, webServiceComponentProvider WebServiceComponentProvider)
}

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

type WebServiceEngineProcessorConfig struct {
	SchemaFactory             SchemaFactory
	WebServiceFactory         WebServiceFactory
	SchemaMapping             map[string]proto.Message
	WebServiceCustomProcessor WebServiceCustomProcessor
}

type WebServiceFactory interface {
	Create(Schema, EngineComponentProvider) WebService
}

type WebServiceGetRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type WebServiceGetResponse struct {
	Key   string     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *anypb.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type WebServiceNotification struct {
	Key   string     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *anypb.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type WebServiceSetRequest struct {
	Key   string     `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value *anypb.Any `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

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