consumer

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

type ConsumerGroupConfig struct {
	ConsumerGroup string

	// key is topic, value is  ConsumerGroupTopicConfig
	ConsumerGroupTopicConfigs *sync.Map
}

type ConsumerGroupMetadata struct {
	ConsumerGroup              string
	ConsumerGroupTopicMetadata *sync.Map
}

type ConsumerGroupStateEvent struct {
	ConsumerGroup            string
	ConsumerGroupConfig      *ConsumerGroupConfig
	ConsumerGroupStateAction StateAction
}

type ConsumerGroupTopicConfChangeEvent struct {
	Action                   StateAction
	ConsumerGroup            string
	ConsumerGroupTopicConfig *ConsumerGroupTopicConfig
}

type ConsumerGroupTopicConfig struct {
	ConsumerGroup    string
	Topic            string
	SubscriptionMode pb.Subscription_SubscriptionItem_SubscriptionMode
	GRPCType         consts.GRPCType
	// IDCWebhookURLs webhook urls seperated by IDC
	// key is IDC, value is vector.Vector
	IDCWebhookURLs *sync.Map

	// AllURLs all webhook urls, ignore idc
	AllURLs *set.Set
}

type ConsumerGroupTopicMetadata struct {
	ConsumerGroup string
	Topic         string
	AllURLs       *set.Set
}

type ConsumerGroupTopicOption interface {
	ConsumerGroup() string
	Topic() string
	SubscriptionMode() pb.Subscription_SubscriptionItem_SubscriptionMode
	GRPCType() consts.GRPCType
	RegisterClient() RegisterClient
	DeregisterClient() DeregisterClient
	IDCURLs() *sync.Map
	AllURLs() *set.Set
	AllEmiters() *set.Set
	IDCEmiters() *sync.Map
	Size() int
}

type ConsumerManager interface {
	GetConsumer(consumerGroup string) (EventMeshConsumer, error)
	RegisterClient(cli *GroupClient) error
	DeRegisterClient(cli *GroupClient) error
	UpdateClientTime(cli *GroupClient)
	RestartConsumer(consumerGroup string) error
	Start() error
	Stop() error
}

type ConsumerService struct {
	pb.UnimplementedConsumerServiceServer
	// contains filtered or unexported fields
}

type DeregisterClient func(*GroupClient)

type EventMeshConsumer interface {
	Init() error
	Start() error
	ServiceState() consts.ServiceState
	RegisterClient(cli *GroupClient) bool
	DeRegisterClient(cli *GroupClient) bool
	Shutdown() error
}

type GroupClient struct {
	ENV              string
	IDC              string
	ConsumerGroup    string
	Topic            string
	GRPCType         consts.GRPCType
	URL              string
	SubscriptionMode pb.Subscription_SubscriptionItem_SubscriptionMode
	SYS              string
	IP               string
	PID              string
	Hostname         string
	APIVersion       string
	LastUPTime       time.Time
	Emiter           emitter.EventEmitter
}

type MessageContext struct {
	MsgRandomNo      string
	SubscriptionMode pb.Subscription_SubscriptionItem_SubscriptionMode
	GrpcType         consts.GRPCType
	ConsumerGroup    string
	Event            *cloudv2.Event
	TopicConfig      ConsumerGroupTopicOption
}

type MessageHandler interface {
	Handler(mctx *MessageContext) error
}

type Processor interface {
	Subscribe(consumerMgr ConsumerManager, msg *pb.Subscription) (*pb.Response, error)
	UnSubscribe(consumerMgr ConsumerManager, msg *pb.Subscription) (*pb.Response, error)
	SubscribeStream(consumerMgr ConsumerManager, emiter emitter.EventEmitter, msg *pb.Subscription) error
	Heartbeat(consumerMgr ConsumerManager, msg *pb.Heartbeat) (*pb.Response, error)
	ReplyMessage(ctx context.Context, producerMgr producer.ProducerManager, emiter emitter.EventEmitter, msg *pb.SimpleMessage) error
}

type RegisterClient func(*GroupClient)

type Request struct {
	*retry.Retry

	MessageContext *MessageContext
	CreateTime     time.Time
	LastPushTime   time.Time
	Complete       *atomic.Bool
	SimpleMessage  *pb.SimpleMessage
	Try            func() error
}

type Response struct {
	RetCode string `json:"retCode"`
	ErrMsg  string `json:"errMsg"`
}

type StateAction string

type StreamGroupTopicOption struct {
	*BaseConsumerGroupTopicOption
	// contains filtered or unexported fields
}

type StreamRequest struct {
	*Request
	// contains filtered or unexported fields
}

type WebhookGroupTopicOption struct {
	*BaseConsumerGroupTopicOption
	// contains filtered or unexported fields
}

type WebhookRequest struct {
	*Request
	// IDCWebhookURLs webhook urls seperated by IDC
	// key is IDC, value is set.Set
	IDCWebhookURLs *sync.Map

	// AllURLs all webhook urls, ignore idc
	AllURLs *set.Set
	// contains filtered or unexported fields
}