alikafkamq

type Consumer struct {
	Name string

	GroupName string
	// contains filtered or unexported fields
}

type Handler func(*M) error

type KafkaMQCredentials struct {
	AppName   string
	Endpoints []string
	User      string
	Password  string
}

type M struct {
	MsgId           string
	Topic           string
	Tag             string
	Key             string
	Body            []byte
	ReConsumerTimes int32
}

type OtsConfig struct {
	EndPoint        string `json:"end_point"`
	InstanceName    string `json:"instance_name"`
	AccessKeyID     string `json:"access_key_id"`
	AccessKeySecret string `json:"access_key_secret"`
}

type RedisConfig struct {
	DB       int    `json:"db"`
	Address  string `json:"address"`
	Password string `json:"password"`
	PoolSize int    `json:"pool_size"`
}

type Subscription struct {
	Topic   string
	Tag     string
	Key     string
	Partion int32
	Offset  int32
	Fn      []Handler
}