Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 2 of 2 for NewConversation (0.07 seconds)

  1. internal/event/target/kafka_scram_client_contrib.go

    func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) {
    	x.Client, err = x.NewClient(userName, password, authzID)
    	if err != nil {
    		return err
    	}
    	x.ClientConversation = x.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  2. internal/logger/target/kafka/kafka_scram_client_contrib.go

    func (x *XDGSCRAMClient) Begin(userName, password, authzID string) (err error) {
    	x.Client, err = x.NewClient(userName, password, authzID)
    	if err != nil {
    		return err
    	}
    	x.ClientConversation = x.NewConversation()
    	return nil
    }
    
    // Step takes a string provided from a server (or just an empty string for the
    // very first conversation step) and attempts to move the authentication
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 3.3K bytes
    - Click Count (0)
Back to Top