graph

Documentation

Index

• func NewExecutableSchema(cfg Config) graphql.ExecutableSchema
• type ComplexityRoot
• type ComputePlatformResolver
• type Config
• type DestinationResolver
• type DirectiveRoot
• type K8sActualNamespaceResolver
• type MutationResolver
• type QueryResolver
• type Resolver
  • func (r *Resolver) ComputePlatform() ComputePlatformResolver
  • func (r *Resolver) Destination() DestinationResolver
  • func (r *Resolver) K8sActualNamespace() K8sActualNamespaceResolver
  • func (r *Resolver) Mutation() MutationResolver
  • func (r *Resolver) Query() QueryResolver
• type ResolverRoot

Functions

func NewExecutableSchema

func NewExecutableSchema(cfg Config) graphql.ExecutableSchema

NewExecutableSchema creates an ExecutableSchema from the ResolverRoot interface.

Types

type ComplexityRoot

type ComplexityRoot struct {
	AddClusterInfoAction struct {
		Details func(childComplexity int) int
		Disable func(childComplexity int) int
		ID      func(childComplexity int) int
		Name    func(childComplexity int) int
		Notes   func(childComplexity int) int
		Signals func(childComplexity int) int
		Type    func(childComplexity int) int
	}

	ClusterCollectorAnalyze struct {
		CollectorGroup       func(childComplexity int) int
		CollectorReady       func(childComplexity int) int
		Deployed             func(childComplexity int) int
		DeployedError        func(childComplexity int) int
		DeploymentCreated    func(childComplexity int) int
		Enabled              func(childComplexity int) int
		ExpectedReplicas     func(childComplexity int) int
		FailedReplicas       func(childComplexity int) int
		FailedReplicasReason func(childComplexity int) int
		HealthyReplicas      func(childComplexity int) int
	}

	ClusterInfo struct {
		AttributeName        func(childComplexity int) int
		AttributeStringValue func(childComplexity int) int
	}

	ComputePlatform struct {
		Actions              func(childComplexity int) int
		ComputePlatformType  func(childComplexity int) int
		Destinations         func(childComplexity int) int
		InstrumentationRules func(childComplexity int) int
		K8sActualNamespace   func(childComplexity int, name string) int
		K8sActualNamespaces  func(childComplexity int) int
		K8sActualSource      func(childComplexity int, name *string, namespace *string, kind *string) int
		K8sActualSources     func(childComplexity int) int
	}

	Condition struct {
		LastTransitionTime func(childComplexity int) int
		Message            func(childComplexity int) int
		Reason             func(childComplexity int) int
		Status             func(childComplexity int) int
		Type               func(childComplexity int) int
	}

	ContainerRuntimeInfoAnalyze struct {
		ContainerName  func(childComplexity int) int
		EnvVars        func(childComplexity int) int
		Language       func(childComplexity int) int
		RuntimeVersion func(childComplexity int) int
	}

	ContainerWorkloadManifestAnalyze struct {
		ContainerName func(childComplexity int) int
		Devices       func(childComplexity int) int
		OriginalEnv   func(childComplexity int) int
	}

	DbQueryPayloadCollection struct {
		DropPartialPayloads func(childComplexity int) int
		MaxPayloadLength    func(childComplexity int) int
	}

	DeleteAttribute struct {
		AttributeName func(childComplexity int) int
	}

	DeleteAttributeAction struct {
		Details func(childComplexity int) int
		Disable func(childComplexity int) int
		ID      func(childComplexity int) int
		Name    func(childComplexity int) int
		Notes   func(childComplexity int) int
		Signals func(childComplexity int) int
		Type    func(childComplexity int) int
	}

	Destination struct {
		Conditions      func(childComplexity int) int
		DestinationType func(childComplexity int) int
		ExportedSignals func(childComplexity int) int
		Fields          func(childComplexity int) int
		Id              func(childComplexity int) int
		Name            func(childComplexity int) int
		Type            func(childComplexity int) int
	}

	DestinationDetails struct {
		Fields    func(childComplexity int) int
		Type      func(childComplexity int) int
		URLString func(childComplexity int) int
	}

	DestinationTypesCategoryItem struct {
		DisplayName             func(childComplexity int) int
		ImageUrl                func(childComplexity int) int
		SupportedSignals        func(childComplexity int) int
		TestConnectionSupported func(childComplexity int) int
		Type                    func(childComplexity int) int
	}

	DestinationsCategory struct {
		Items func(childComplexity int) int
		Name  func(childComplexity int) int
	}

	EntityProperty struct {
		Explain func(childComplexity int) int
		Name    func(childComplexity int) int
		Status  func(childComplexity int) int
		Value   func(childComplexity int) int
	}

	ErrorSamplerAction struct {
		Details func(childComplexity int) int
		Disable func(childComplexity int) int
		ID      func(childComplexity int) int
		Name    func(childComplexity int) int
		Notes   func(childComplexity int) int
		Signals func(childComplexity int) int
		Type    func(childComplexity int) int
	}

	ExportedSignals struct {
		Logs    func(childComplexity int) int
		Metrics func(childComplexity int) int
		Traces  func(childComplexity int) int
	}

	Field struct {
		ComponentProperties func(childComplexity int) int
		ComponentType       func(childComplexity int) int
		DisplayName         func(childComplexity int) int
		InitialValue        func(childComplexity int) int
		Name                func(childComplexity int) int
		ThumbnailURL        func(childComplexity int) int
		VideoURL            func(childComplexity int) int
	}

	GetConfigResponse struct {
		Installation func(childComplexity int) int
	}

	GetDestinationDetailsResponse struct {
		Fields func(childComplexity int) int
	}

	GetDestinationTypesResponse struct {
		Categories func(childComplexity int) int
	}

	HttpPayloadCollection struct {
		DropPartialPayloads func(childComplexity int) int
		MaxPayloadLength    func(childComplexity int) int
		MimeTypes           func(childComplexity int) int
	}

	IcaInstanceResponse struct {
		ID   func(childComplexity int) int
		Spec func(childComplexity int) int
		Type func(childComplexity int) int
	}

	InstrumentationConfigAnalyze struct {
		CreateTime func(childComplexity int) int
		Created    func(childComplexity int) int
	}

	InstrumentationDeviceAnalyze struct {
		Containers func(childComplexity int) int
		StatusText func(childComplexity int) int
	}

	InstrumentationInstanceAnalyze struct {
		Healthy               func(childComplexity int) int
		IdentifyingAttributes func(childComplexity int) int
		Message               func(childComplexity int) int
	}

	InstrumentationLabelsAnalyze struct {
		Instrumented     func(childComplexity int) int
		InstrumentedText func(childComplexity int) int
		Namespace        func(childComplexity int) int
		Workload         func(childComplexity int) int
	}

	InstrumentationLibrary struct {
		LibraryName func(childComplexity int) int
		Options     func(childComplexity int) int
	}

	InstrumentationLibraryGlobalId struct {
		Language func(childComplexity int) int
		Name     func(childComplexity int) int
		SpanKind func(childComplexity int) int
	}

	InstrumentationOption struct {
		OptionKey func(childComplexity int) int
		SpanKind  func(childComplexity int) int
	}

	InstrumentationRule struct {
		Disabled                 func(childComplexity int) int
		InstrumentationLibraries func(childComplexity int) int
		Notes                    func(childComplexity int) int
		PayloadCollection        func(childComplexity int) int
		RuleID                   func(childComplexity int) int
		RuleName                 func(childComplexity int) int
		Workloads                func(childComplexity int) int
	}

	InstrumentedApplicationAnalyze struct {
		Containers func(childComplexity int) int
		CreateTime func(childComplexity int) int
		Created    func(childComplexity int) int
	}

	InstrumentedApplicationDetails struct {
		Conditions             func(childComplexity int) int
		Containers             func(childComplexity int) int
		InstrumentationOptions func(childComplexity int) int
	}

	K8sActualNamespace struct {
		InstrumentationLabelEnabled func(childComplexity int) int
		K8sActualSources            func(childComplexity int, instrumentationLabeled *bool) int
		Name                        func(childComplexity int) int
	}

	K8sActualSource struct {
		AutoInstrumented               func(childComplexity int) int
		AutoInstrumentedDecision       func(childComplexity int) int
		InstrumentedApplicationDetails func(childComplexity int) int
		Kind                           func(childComplexity int) int
		Name                           func(childComplexity int) int
		Namespace                      func(childComplexity int) int
		NumberOfInstances              func(childComplexity int) int
		ReportedName                   func(childComplexity int) int
		ServiceName                    func(childComplexity int) int
	}

	LatencySamplerAction struct {
		Details func(childComplexity int) int
		Disable func(childComplexity int) int
		ID      func(childComplexity int) int
		Name    func(childComplexity int) int
		Notes   func(childComplexity int) int
		Signals func(childComplexity int) int
		Type    func(childComplexity int) int
	}

	MessagingPayloadCollection struct {
		DropPartialPayloads func(childComplexity int) int
		MaxPayloadLength    func(childComplexity int) int
	}

	Mutation struct {
		CreateAction                 func(childComplexity int, action model.ActionInput) int
		CreateInstrumentationRule    func(childComplexity int, instrumentationRule model.InstrumentationRuleInput) int
		CreateNewDestination         func(childComplexity int, destination model.DestinationInput) int
		DeleteAction                 func(childComplexity int, id string, actionType string) int
		DeleteDestination            func(childComplexity int, id string) int
		DeleteInstrumentationRule    func(childComplexity int, ruleID string) int
		PersistK8sNamespace          func(childComplexity int, namespace model.PersistNamespaceItemInput) int
		PersistK8sSources            func(childComplexity int, namespace string, sources []*model.PersistNamespaceSourceInput) int
		TestConnectionForDestination func(childComplexity int, destination model.DestinationInput) int
		UpdateAction                 func(childComplexity int, id string, action model.ActionInput) int
		UpdateDestination            func(childComplexity int, id string, destination model.DestinationInput) int
		UpdateInstrumentationRule    func(childComplexity int, ruleID string, instrumentationRule model.InstrumentationRuleInput) int
		UpdateK8sActualSource        func(childComplexity int, sourceID model.K8sSourceID, patchSourceRequest model.PatchSourceRequestInput) int
	}

	NodeCollectorAnalyze struct {
		AvailableNodes func(childComplexity int) int
		CollectorGroup func(childComplexity int) int
		CollectorReady func(childComplexity int) int
		CurrentNodes   func(childComplexity int) int
		DaemonSet      func(childComplexity int) int
		Deployed       func(childComplexity int) int
		DeployedError  func(childComplexity int) int
		DesiredNodes   func(childComplexity int) int
		Enabled        func(childComplexity int) int
		UpdatedNodes   func(childComplexity int) int
	}

	ObservabilitySignalSupport struct {
		Supported func(childComplexity int) int
	}

	OdigosAnalyze struct {
		ClusterCollector     func(childComplexity int) int
		HasErrors            func(childComplexity int) int
		IsSettled            func(childComplexity int) int
		NodeCollector        func(childComplexity int) int
		NumberOfDestinations func(childComplexity int) int
		NumberOfSources      func(childComplexity int) int
		OdigosVersion        func(childComplexity int) int
	}

	OverviewMetricsResponse struct {
		Destinations func(childComplexity int) int
		Sources      func(childComplexity int) int
	}

	PayloadCollection struct {
		DbQuery      func(childComplexity int) int
		HTTPRequest  func(childComplexity int) int
		HTTPResponse func(childComplexity int) int
		Messaging    func(childComplexity int) int
	}

	PiiMaskingAction struct {
		Details func(childComplexity int) int
		Disable func(childComplexity int) int
		ID      func(childComplexity int) int
		Name    func(childComplexity int) int
		Notes   func(childComplexity int) int
		Signals func(childComplexity int) int
		Type    func(childComplexity int) int
	}

	PodAnalyze struct {
		Containers func(childComplexity int) int
		NodeName   func(childComplexity int) int
		Phase      func(childComplexity int) int
		PodName    func(childComplexity int) int
	}

	PodContainerAnalyze struct {
		ActualDevices            func(childComplexity int) int
		ContainerName            func(childComplexity int) int
		InstrumentationInstances func(childComplexity int) int
	}

	PodWorkload struct {
		Kind      func(childComplexity int) int
		Name      func(childComplexity int) int
		Namespace func(childComplexity int) int
	}

	ProbabilisticSamplerAction struct {
		Details func(childComplexity int) int
		Disable func(childComplexity int) int
		ID      func(childComplexity int) int
		Name    func(childComplexity int) int
		Notes   func(childComplexity int) int
		Signals func(childComplexity int) int
		Type    func(childComplexity int) int
	}

	Query struct {
		ComputePlatform        func(childComplexity int) int
		Config                 func(childComplexity int) int
		DescribeOdigos         func(childComplexity int) int
		DescribeSource         func(childComplexity int, namespace string, kind string, name string) int
		DestinationTypeDetails func(childComplexity int, typeArg string) int
		DestinationTypes       func(childComplexity int) int
		GetOverviewMetrics     func(childComplexity int) int
		PotentialDestinations  func(childComplexity int) int
	}

	RenameAttributeAction struct {
		Details func(childComplexity int) int
		Disable func(childComplexity int) int
		ID      func(childComplexity int) int
		Name    func(childComplexity int) int
		Notes   func(childComplexity int) int
		Signals func(childComplexity int) int
		Type    func(childComplexity int) int
	}

	RuntimeInfoAnalyze struct {
		Containers func(childComplexity int) int
		Generation func(childComplexity int) int
	}

	SingleDestinationMetricsResponse struct {
		ID            func(childComplexity int) int
		Throughput    func(childComplexity int) int
		TotalDataSent func(childComplexity int) int
	}

	SingleSourceMetricsResponse struct {
		Kind          func(childComplexity int) int
		Name          func(childComplexity int) int
		Namespace     func(childComplexity int) int
		Throughput    func(childComplexity int) int
		TotalDataSent func(childComplexity int) int
	}

	SourceAnalyze struct {
		InstrumentationConfig   func(childComplexity int) int
		InstrumentationDevice   func(childComplexity int) int
		InstrumentedApplication func(childComplexity int) int
		Kind                    func(childComplexity int) int
		Labels                  func(childComplexity int) int
		Name                    func(childComplexity int) int
		Namespace               func(childComplexity int) int
		Pods                    func(childComplexity int) int
		PodsPhasesCount         func(childComplexity int) int
		RuntimeInfo             func(childComplexity int) int
		TotalPods               func(childComplexity int) int
	}

	SourceContainerRuntimeDetails struct {
		ContainerName  func(childComplexity int) int
		Language       func(childComplexity int) int
		OtherAgent     func(childComplexity int) int
		RuntimeVersion func(childComplexity int) int
	}

	SupportedSignals struct {
		Logs    func(childComplexity int) int
		Metrics func(childComplexity int) int
		Traces  func(childComplexity int) int
	}

	TestConnectionResponse struct {
		DestinationType func(childComplexity int) int
		Message         func(childComplexity int) int
		Reason          func(childComplexity int) int
		StatusCode      func(childComplexity int) int
		Succeeded       func(childComplexity int) int
	}
}

type ComputePlatformResolver

type ComputePlatformResolver interface {
	K8sActualNamespace(ctx context.Context, obj *model.ComputePlatform, name string) (*model.K8sActualNamespace, error)
	K8sActualNamespaces(ctx context.Context, obj *model.ComputePlatform) ([]*model.K8sActualNamespace, error)
	K8sActualSource(ctx context.Context, obj *model.ComputePlatform, name *string, namespace *string, kind *string) (*model.K8sActualSource, error)
	K8sActualSources(ctx context.Context, obj *model.ComputePlatform) ([]*model.K8sActualSource, error)
	Destinations(ctx context.Context, obj *model.ComputePlatform) ([]*model.Destination, error)
	Actions(ctx context.Context, obj *model.ComputePlatform) ([]*model.IcaInstanceResponse, error)
	InstrumentationRules(ctx context.Context, obj *model.ComputePlatform) ([]*model.InstrumentationRule, error)
}

type Config

type Config struct {
	Schema     *ast.Schema
	Resolvers  ResolverRoot
	Directives DirectiveRoot
	Complexity ComplexityRoot
}

type DestinationResolver

type DestinationResolver interface {
	Type(ctx context.Context, obj *model.Destination) (string, error)

	Conditions(ctx context.Context, obj *model.Destination) ([]*model.Condition, error)
}

type DirectiveRoot

type DirectiveRoot struct {
}

type K8sActualNamespaceResolver

type K8sActualNamespaceResolver interface {
	K8sActualSources(ctx context.Context, obj *model.K8sActualNamespace, instrumentationLabeled *bool) ([]*model.K8sActualSource, error)
}

type MutationResolver

type MutationResolver interface {
	CreateNewDestination(ctx context.Context, destination model.DestinationInput) (*model.Destination, error)
	PersistK8sNamespace(ctx context.Context, namespace model.PersistNamespaceItemInput) (bool, error)
	PersistK8sSources(ctx context.Context, namespace string, sources []*model.PersistNamespaceSourceInput) (bool, error)
	TestConnectionForDestination(ctx context.Context, destination model.DestinationInput) (*model.TestConnectionResponse, error)
	UpdateK8sActualSource(ctx context.Context, sourceID model.K8sSourceID, patchSourceRequest model.PatchSourceRequestInput) (bool, error)
	UpdateDestination(ctx context.Context, id string, destination model.DestinationInput) (*model.Destination, error)
	DeleteDestination(ctx context.Context, id string) (bool, error)
	CreateAction(ctx context.Context, action model.ActionInput) (model.Action, error)
	UpdateAction(ctx context.Context, id string, action model.ActionInput) (model.Action, error)
	DeleteAction(ctx context.Context, id string, actionType string) (bool, error)
	CreateInstrumentationRule(ctx context.Context, instrumentationRule model.InstrumentationRuleInput) (*model.InstrumentationRule, error)
	UpdateInstrumentationRule(ctx context.Context, ruleID string, instrumentationRule model.InstrumentationRuleInput) (*model.InstrumentationRule, error)
	DeleteInstrumentationRule(ctx context.Context, ruleID string) (bool, error)
}

type QueryResolver

type QueryResolver interface {
	ComputePlatform(ctx context.Context) (*model.ComputePlatform, error)
	Config(ctx context.Context) (*model.GetConfigResponse, error)
	DestinationTypes(ctx context.Context) (*model.GetDestinationTypesResponse, error)
	DestinationTypeDetails(ctx context.Context, typeArg string) (*model.GetDestinationDetailsResponse, error)
	PotentialDestinations(ctx context.Context) ([]*model.DestinationDetails, error)
	GetOverviewMetrics(ctx context.Context) (*model.OverviewMetricsResponse, error)
	DescribeOdigos(ctx context.Context) (*model.OdigosAnalyze, error)
	DescribeSource(ctx context.Context, namespace string, kind string, name string) (*model.SourceAnalyze, error)
}

type Resolver

type Resolver struct {
	MetricsConsumer *collectormetrics.OdigosMetricsConsumer
}

func (*Resolver) ComputePlatform

func (r *Resolver) ComputePlatform() ComputePlatformResolver

ComputePlatform returns ComputePlatformResolver implementation.

func (*Resolver) Destination

func (r *Resolver) Destination() DestinationResolver

Destination returns DestinationResolver implementation.

func (*Resolver) K8sActualNamespace

func (r *Resolver) K8sActualNamespace() K8sActualNamespaceResolver

K8sActualNamespace returns K8sActualNamespaceResolver implementation.

func (*Resolver) Mutation

func (r *Resolver) Mutation() MutationResolver

Mutation returns MutationResolver implementation.

func (*Resolver) Query

func (r *Resolver) Query() QueryResolver

Query returns QueryResolver implementation.

type ResolverRoot

type ResolverRoot interface {
	ComputePlatform() ComputePlatformResolver
	Destination() DestinationResolver
	K8sActualNamespace() K8sActualNamespaceResolver
	Mutation() MutationResolver
	Query() QueryResolver
}