ingestendpoint

Documentation

Index

• Constants
• type EndpointSecretGenerator
  • func NewEndpointSecretGenerator(client client.Client, apiReader client.Reader, ns string) *EndpointSecretGenerator
  • func (g *EndpointSecretGenerator) GenerateForDynakube(ctx context.Context, dk *dynatracev1beta1.DynaKube) error
  • func (g *EndpointSecretGenerator) GenerateForNamespace(ctx context.Context, dkName, targetNs string) error
  • func (g *EndpointSecretGenerator) PrepareFields(ctx context.Context, dk *dynatracev1beta1.DynaKube) (map[string]string, error)
  • func (g *EndpointSecretGenerator) RemoveEndpointSecrets(ctx context.Context, dk *dynatracev1beta1.DynaKube) error

Constants

const (
	MetricsUrlSecretField   = "DT_METRICS_INGEST_URL"
	MetricsTokenSecretField = "DT_METRICS_INGEST_API_TOKEN"
)

Types

type EndpointSecretGenerator

type EndpointSecretGenerator struct {
	// contains filtered or unexported fields
}

EndpointSecretGenerator manages the mint endpoint secret generation for the user namespaces.

func NewEndpointSecretGenerator

func NewEndpointSecretGenerator(client client.Client, apiReader client.Reader, ns string) *EndpointSecretGenerator

func (*EndpointSecretGenerator) GenerateForDynakube

func (g *EndpointSecretGenerator) GenerateForDynakube(ctx context.Context, dk *dynatracev1beta1.DynaKube) error

GenerateForDynakube creates/updates the data-ingest-endpoint secret for EVERY namespace for the given dynakube. Used by the dynakube controller during reconcile.

func (*EndpointSecretGenerator) GenerateForNamespace

func (g *EndpointSecretGenerator) GenerateForNamespace(ctx context.Context, dkName, targetNs string) error

GenerateForNamespace creates the data-ingest-endpoint secret for namespace while only having the name of the corresponding dynakube Used by the podInjection webhook in case the namespace lacks the secret.

func (*EndpointSecretGenerator) PrepareFields

func (g *EndpointSecretGenerator) PrepareFields(ctx context.Context, dk *dynatracev1beta1.DynaKube) (map[string]string, error)

func (*EndpointSecretGenerator) RemoveEndpointSecrets

func (g *EndpointSecretGenerator) RemoveEndpointSecrets(ctx context.Context, dk *dynatracev1beta1.DynaKube) error