mq

type AsyncProducer interface {
	Send(ctx context.Context, topicName string, msg *Message) error
	Close() error
}

type Config struct {
	MqName    string        `toml:"mq_name"`
	Endpoints []string      `toml:"endpoints"`
	Instance  string        `toml:"instance"`
	AccessKey string        `toml:"access_key"`
	SecretKey string        `toml:"secret_key"`
	Group     string        `toml:"group"`
	Topics    []TopicConfig `toml:"topics"`
}

type Consumer interface {
	Recv(topicName string, h Handler) error
	Start() error
	Close() error
}

type Event interface {
	Topic() string
	Message() *Message
	Ack() error
}

type GroupHandler struct {
	Handler       Handler
	ConsumerGroup sarama.ConsumerGroup
	TopicName     string
}

type Handler func(ctx context.Context, event Event) error

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

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

type KafkaConsumerGroup struct {
	Topic         string
	ConsumerGroup sarama.ConsumerGroup
}

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

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

type Message struct {
	Header map[string]string
	Body   []byte
}

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

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

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

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

type SyncProducer interface {
	Send(ctx context.Context, topicName string, msg *Message) error
	Close() error
}

type TopicConfig struct {
	Name  string `toml:"name"`
	Topic string `toml:"topic"`
}