rhmotransport

Documentation

Index

• func GetCatalogServerService(k8sclient client.Client, deployedNamespace string) (*corev1.Service, error)
• func GetCertFromConfigMap(k8sclient client.Client, deployedNamespace string, reqLogger logr.Logger) ([]byte, error)
• func SetTransportForKubeServiceAuth(authBuilder IAuthBuilder, reqLogger logr.Logger) (*http.Client, error)
• func WithBearerAuth(rt http.RoundTripper, token string) http.RoundTripper
• type AuthBuilderConfig
  • func ProvideAuthBuilder(k8sclient client.Client, operatorConfig *config.OperatorConfig, ...) *AuthBuilderConfig
  • func (a *AuthBuilderConfig) FindAuthOffCluster() (*AuthValues, error)
• type AuthValues
• type IAuthBuilder
• type ServiceAccountClient
  • func ProvideServiceAccountClient(namespace string, kubernetesInterface kubernetes.Interface) *ServiceAccountClient
  • func (s *ServiceAccountClient) GetToken(targetServiceAccount string, client typedv1.ServiceAccountInterface, ...) (string, error)
  • func (s *ServiceAccountClient) NewServiceAccountToken(targetServiceAccountName string, audience string, expireSecs int64, ...) (string, error)
• type Token
• type TransportWithHeader
  • func WithHeader(rt http.RoundTripper) TransportWithHeader
  • func (m TransportWithHeader) RoundTrip(req *http.Request) (*http.Response, error)

Functions

func GetCatalogServerService

func GetCatalogServerService(k8sclient client.Client, deployedNamespace string) (*corev1.Service, error)

func GetCertFromConfigMap

func GetCertFromConfigMap(k8sclient client.Client, deployedNamespace string, reqLogger logr.Logger) ([]byte, error)

func SetTransportForKubeServiceAuth

func SetTransportForKubeServiceAuth(authBuilder IAuthBuilder, reqLogger logr.Logger) (*http.Client, error)

func WithBearerAuth

func WithBearerAuth(rt http.RoundTripper, token string) http.RoundTripper

Types

type AuthBuilderConfig

type AuthBuilderConfig struct {
	K8sclient         client.Client
	DeployedNamespace string
	*ServiceAccountClient
	Logger logr.Logger
	*AuthValues
	Error error
}

func ProvideAuthBuilder

func ProvideAuthBuilder(k8sclient client.Client, operatorConfig *config.OperatorConfig, kubeInterface kubernetes.Interface, reqLogger logr.Logger) *AuthBuilderConfig

func (*AuthBuilderConfig) FindAuthOffCluster

func (a *AuthBuilderConfig) FindAuthOffCluster() (*AuthValues, error)

type AuthValues

type AuthValues struct {
	ServiceFound bool
	Cert         []byte
	AuthToken    string
}

type IAuthBuilder

type IAuthBuilder interface {
	FindAuthOffCluster() (*AuthValues, error)
}

type ServiceAccountClient

type ServiceAccountClient struct {
	KubernetesInterface kubernetes.Interface
	Token               *Token
	TokenRequestObj     *authv1.TokenRequest
	Client              typedv1.ServiceAccountInterface
	sync.Mutex
}

func ProvideServiceAccountClient

func ProvideServiceAccountClient(namespace string, kubernetesInterface kubernetes.Interface) *ServiceAccountClient

func (*ServiceAccountClient) GetToken

func (s *ServiceAccountClient) GetToken(targetServiceAccount string, client typedv1.ServiceAccountInterface, tr *authv1.TokenRequest, opts metav1.CreateOptions) (string, error)

func (*ServiceAccountClient) NewServiceAccountToken

func (s *ServiceAccountClient) NewServiceAccountToken(targetServiceAccountName string, audience string, expireSecs int64, reqLogger logr.Logger) (string, error)

type Token

type Token struct {
	AuthToken           *string
	ExpirationTimestamp metav1.Time
}

type TransportWithHeader

type TransportWithHeader struct {
	http.Header
	// contains filtered or unexported fields
}

func WithHeader

func WithHeader(rt http.RoundTripper) TransportWithHeader

func (TransportWithHeader) RoundTrip

func (m TransportWithHeader) RoundTrip(req *http.Request) (*http.Response, error)