rocketmq

type ConsumerConfig struct {
	Endpoint  []string
	AccessKey string
	SecretKey string
	Namespace string

	Topic string
	Gid   string
	Tags  []string

	Orderly bool
	// contains filtered or unexported fields
}

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

type ProducerConfig struct {
	Endpoint  []string
	AccessKey string
	SecretKey string
	Namespace string

	Retry       int
	SendTimeout time.Duration

	Topic string
	Tags  []string

	SlowSendDuration time.Duration
	// contains filtered or unexported fields
}

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