Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 1 of 1 for checkAndInitClient (0.1 sec)

  1. internal/event/target/elasticsearch.go

    	}
    	return target.isActive()
    }
    
    func (target *ElasticsearchTarget) isActive() (bool, error) {
    	ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
    	defer cancel()
    
    	err := target.checkAndInitClient(ctx)
    	if err != nil {
    		return false, err
    	}
    
    	return target.client.ping(ctx, target.args)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
Back to top