func newEventMeshQueue()

in internal/queue/eventmesh_queue.go [56:84]

• 29 lines of code
• 2 McCabe index (conditional complexity)

func newEventMeshQueue(workflowConfig *conf.Config) ObserveQueue {
	eventMeshConfig := workflowConfig.EventMesh
	grpcConfig := &sdk_conf.GRPCConfig{
		Host:         eventMeshConfig.Host,
		Port:         eventMeshConfig.GRPC.Port,
		ENV:          eventMeshConfig.Env,
		IDC:          eventMeshConfig.IDC,
		SYS:          eventMeshConfig.Sys,
		Username:     eventMeshConfig.UserName,
		Password:     eventMeshConfig.Password,
		ProtocolType: sdk.EventmeshMessage,
		ConsumerConfig: sdk_conf.ConsumerConfig{
			Enabled:       true,
			ConsumerGroup: eventMeshConfig.ConsumerGroup,
		},
	}
	client, err := sdk.New(grpcConfig)
	if err != nil {
		log.Get(constants.LogQueue).Errorf("EventMesh task queue, fail to init EventMesh client , error=%v", err)
		panic(err)
	}
	return &eventMeshQueue{
		grpcClient:     client,
		grpcConfig:     grpcConfig,
		workflowConfig: workflowConfig,
		observeTopic:   workflowConfig.Flow.Queue.Topic,
		workflowDAL:    dal.NewWorkflowDAL(),
	}
}