Method GetSecrets

plugin/resolver.go:37–46

(ctx context.Context, c *connect.Request[resolverv1.GetSecretsRequest])

}

func (r *resolverService) GetSecrets(ctx context.Context, c *connect.Request[resolverv1.GetSecretsRequest]) (*connect.Response[resolverv1.GetSecretsResponse], error) {
	select {
	case <-r.setupCompleted:
	case <-ctx.Done():
		return nil, connect.NewError(connect.CodeInternal, errors.New("context cancelled while waiting for registration"))
	case <-time.After(r.registrationTimeout):
		return nil, connect.NewError(connect.CodeDeadlineExceeded, fmt.Errorf("registration incomplete (timeout after %s)", r.registrationTimeout))
	}
	return r.handler.GetSecrets(ctx, c)
}