Method Start

sasl/aws_msk_iam_v2/msk_iam.go:78–86

Start produces the authentication values required for AWS_MSK_IAM. It produces the following json as a byte array, making use of the aws-sdk to produce the signed output. { "version" : "2020_10_22", "host" : "<broker host>", "user-agent": "<user agent string from the client>", "action"

(ctx context.Context)

//	  "x-amz-signature" : "<AWS SigV4 signature computed by the client>"
//	}
func (m *Mechanism) Start(ctx context.Context) (sess sasl.StateMachine, ir []byte, err error) {
	signedMap, err := m.preSign(ctx)
	if err != nil {
		return nil, nil, err
	}

	signedJson, err := json.Marshal(signedMap)
	return m, signedJson, err
}

// preSign produces the authentication values required for AWS_MSK_IAM.
func (m *Mechanism) preSign(ctx context.Context) (map[string]string, error) {