generated

Documentation

Index

• func NewExecutableSchema(cfg Config) graphql.ExecutableSchema
• type AgentResolver
• type AgentSelectorResolver
• type AgentUpgradeResolver
• type ComplexityRoot
• type Config
• type ConfigurationResolver
• type DestinationResolver
• type DestinationTypeResolver
• type DirectiveRoot
• type MetadataResolver
• type MutationResolver
• type ParameterDefinitionResolver
• type ParameterOptionsResolver
• type ProcessorResolver
• type ProcessorTypeResolver
• type QueryResolver
• type RelevantIfConditionResolver
• type ResolverRoot
• type RolloutResolver
• type SourceResolver
• type SourceTypeResolver
• type SubscriptionResolver

Functions

func NewExecutableSchema

func NewExecutableSchema(cfg Config) graphql.ExecutableSchema

NewExecutableSchema creates an ExecutableSchema from the ResolverRoot interface.

Types

type AgentResolver

type AgentResolver interface {
	Labels(ctx context.Context, obj *model1.Agent) (map[string]interface{}, error)

	Status(ctx context.Context, obj *model1.Agent) (int, error)

	Configuration(ctx context.Context, obj *model1.Agent) (*model.AgentConfiguration, error)
	ConfigurationResource(ctx context.Context, obj *model1.Agent) (*model1.Configuration, error)

	UpgradeAvailable(ctx context.Context, obj *model1.Agent) (*string, error)
	Features(ctx context.Context, obj *model1.Agent) (int, error)
}

type AgentSelectorResolver

type AgentSelectorResolver interface {
	MatchLabels(ctx context.Context, obj *model1.AgentSelector) (map[string]interface{}, error)
}

type AgentUpgradeResolver

type AgentUpgradeResolver interface {
	Status(ctx context.Context, obj *model1.AgentUpgrade) (int, error)
}

type ComplexityRoot

type ComplexityRoot struct {
	AdditionalInfo struct {
		Documentation func(childComplexity int) int
		Message       func(childComplexity int) int
	}

	Agent struct {
		Architecture          func(childComplexity int) int
		Configuration         func(childComplexity int) int
		ConfigurationResource func(childComplexity int) int
		ConnectedAt           func(childComplexity int) int
		DisconnectedAt        func(childComplexity int) int
		ErrorMessage          func(childComplexity int) int
		Features              func(childComplexity int) int
		Home                  func(childComplexity int) int
		HostName              func(childComplexity int) int
		ID                    func(childComplexity int) int
		Labels                func(childComplexity int) int
		MacAddress            func(childComplexity int) int
		Name                  func(childComplexity int) int
		OperatingSystem       func(childComplexity int) int
		Platform              func(childComplexity int) int
		RemoteAddress         func(childComplexity int) int
		Status                func(childComplexity int) int
		Type                  func(childComplexity int) int
		Upgrade               func(childComplexity int) int
		UpgradeAvailable      func(childComplexity int) int
		Version               func(childComplexity int) int
	}

	AgentChange struct {
		Agent      func(childComplexity int) int
		ChangeType func(childComplexity int) int
	}

	AgentConfiguration struct {
		Collector func(childComplexity int) int
		Logging   func(childComplexity int) int
		Manager   func(childComplexity int) int
	}

	AgentSelector struct {
		MatchLabels func(childComplexity int) int
	}

	AgentUpgrade struct {
		Error   func(childComplexity int) int
		Status  func(childComplexity int) int
		Version func(childComplexity int) int
	}

	Agents struct {
		Agents        func(childComplexity int) int
		LatestVersion func(childComplexity int) int
		Query         func(childComplexity int) int
		Suggestions   func(childComplexity int) int
	}

	Configuration struct {
		APIVersion  func(childComplexity int) int
		ActiveTypes func(childComplexity int) int
		AgentCount  func(childComplexity int) int
		Graph       func(childComplexity int) int
		Kind        func(childComplexity int) int
		Metadata    func(childComplexity int) int
		Rendered    func(childComplexity int) int
		Spec        func(childComplexity int) int
		Status      func(childComplexity int) int
	}

	ConfigurationChange struct {
		Configuration func(childComplexity int) int
		EventType     func(childComplexity int) int
	}

	ConfigurationSpec struct {
		ContentType         func(childComplexity int) int
		Destinations        func(childComplexity int) int
		MeasurementInterval func(childComplexity int) int
		Raw                 func(childComplexity int) int
		Selector            func(childComplexity int) int
		Sources             func(childComplexity int) int
	}

	ConfigurationStatus struct {
		Current        func(childComplexity int) int
		CurrentVersion func(childComplexity int) int
		Latest         func(childComplexity int) int
		Pending        func(childComplexity int) int
		Rollout        func(childComplexity int) int
	}

	Configurations struct {
		Configurations func(childComplexity int) int
		Query          func(childComplexity int) int
		Suggestions    func(childComplexity int) int
	}

	Destination struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		Metadata   func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	DestinationType struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		Metadata   func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	DestinationWithType struct {
		Destination     func(childComplexity int) int
		DestinationType func(childComplexity int) int
	}

	DocumentationLink struct {
		Text func(childComplexity int) int
		URL  func(childComplexity int) int
	}

	Edge struct {
		ID     func(childComplexity int) int
		Source func(childComplexity int) int
		Target func(childComplexity int) int
	}

	EdgeMetric struct {
		EdgeID       func(childComplexity int) int
		Name         func(childComplexity int) int
		PipelineType func(childComplexity int) int
		Unit         func(childComplexity int) int
		Value        func(childComplexity int) int
	}

	Graph struct {
		Attributes    func(childComplexity int) int
		Edges         func(childComplexity int) int
		Intermediates func(childComplexity int) int
		Sources       func(childComplexity int) int
		Targets       func(childComplexity int) int
	}

	GraphMetric struct {
		AgentID      func(childComplexity int) int
		Name         func(childComplexity int) int
		NodeID       func(childComplexity int) int
		PipelineType func(childComplexity int) int
		Unit         func(childComplexity int) int
		Value        func(childComplexity int) int
	}

	GraphMetrics struct {
		EdgeMetrics    func(childComplexity int) int
		MaxLogValue    func(childComplexity int) int
		MaxMetricValue func(childComplexity int) int
		MaxTraceValue  func(childComplexity int) int
		Metrics        func(childComplexity int) int
	}

	Log struct {
		Attributes func(childComplexity int) int
		Body       func(childComplexity int) int
		Resource   func(childComplexity int) int
		Severity   func(childComplexity int) int
		Timestamp  func(childComplexity int) int
	}

	Metadata struct {
		AdditionalInfo func(childComplexity int) int
		DateModified   func(childComplexity int) int
		Deprecated     func(childComplexity int) int
		Description    func(childComplexity int) int
		DisplayName    func(childComplexity int) int
		ID             func(childComplexity int) int
		Icon           func(childComplexity int) int
		Labels         func(childComplexity int) int
		Name           func(childComplexity int) int
		Version        func(childComplexity int) int
	}

	Metric struct {
		Attributes func(childComplexity int) int
		Name       func(childComplexity int) int
		Resource   func(childComplexity int) int
		Timestamp  func(childComplexity int) int
		Type       func(childComplexity int) int
		Unit       func(childComplexity int) int
		Value      func(childComplexity int) int
	}

	MetricCategory struct {
		Column  func(childComplexity int) int
		Label   func(childComplexity int) int
		Metrics func(childComplexity int) int
	}

	MetricOption struct {
		DefaultDisabled func(childComplexity int) int
		Description     func(childComplexity int) int
		KPI             func(childComplexity int) int
		Name            func(childComplexity int) int
	}

	Mutation struct {
		ClearAgentUpgradeError       func(childComplexity int, input model.ClearAgentUpgradeErrorInput) int
		EditConfigurationDescription func(childComplexity int, input model.EditConfigurationDescriptionInput) int
		RemoveAgentConfiguration     func(childComplexity int, input *model.RemoveAgentConfigurationInput) int
		UpdateProcessors             func(childComplexity int, input model.UpdateProcessorsInput) int
	}

	Node struct {
		Attributes func(childComplexity int) int
		ID         func(childComplexity int) int
		Label      func(childComplexity int) int
		Type       func(childComplexity int) int
	}

	OverviewPage struct {
		Graph func(childComplexity int) int
	}

	Parameter struct {
		Name      func(childComplexity int) int
		Sensitive func(childComplexity int) int
		Value     func(childComplexity int) int
	}

	ParameterDefinition struct {
		AdvancedConfig func(childComplexity int) int
		Default        func(childComplexity int) int
		Description    func(childComplexity int) int
		Documentation  func(childComplexity int) int
		Label          func(childComplexity int) int
		Name           func(childComplexity int) int
		Options        func(childComplexity int) int
		RelevantIf     func(childComplexity int) int
		Required       func(childComplexity int) int
		Type           func(childComplexity int) int
		ValidValues    func(childComplexity int) int
	}

	ParameterOptions struct {
		Creatable         func(childComplexity int) int
		GridColumns       func(childComplexity int) int
		HorizontalDivider func(childComplexity int) int
		Labels            func(childComplexity int) int
		MetricCategories  func(childComplexity int) int
		Multiline         func(childComplexity int) int
		Password          func(childComplexity int) int
		SectionHeader     func(childComplexity int) int
		Sensitive         func(childComplexity int) int
		SubHeader         func(childComplexity int) int
		TrackUnchecked    func(childComplexity int) int
	}

	ParameterizedSpec struct {
		Disabled   func(childComplexity int) int
		Parameters func(childComplexity int) int
		Processors func(childComplexity int) int
		Type       func(childComplexity int) int
	}

	PhaseAgentCount struct {
		Initial    func(childComplexity int) int
		Maximum    func(childComplexity int) int
		Multiplier func(childComplexity int) int
	}

	Processor struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		Metadata   func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	ProcessorType struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		Metadata   func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	ProcessorWithType struct {
		Processor     func(childComplexity int) int
		ProcessorType func(childComplexity int) int
	}

	Query struct {
		Agent                func(childComplexity int, id string) int
		AgentMetrics         func(childComplexity int, period string, ids []string) int
		Agents               func(childComplexity int, selector *string, query *string) int
		Configuration        func(childComplexity int, name string) int
		ConfigurationHistory func(childComplexity int, name string) int
		ConfigurationMetrics func(childComplexity int, period string, name *string) int
		Configurations       func(childComplexity int, selector *string, query *string, onlyDeployedConfigurations *bool) int
		Destination          func(childComplexity int, name string) int
		DestinationType      func(childComplexity int, name string) int
		DestinationTypes     func(childComplexity int) int
		DestinationWithType  func(childComplexity int, name string) int
		Destinations         func(childComplexity int, query *string, filterUnused *bool) int
		OverviewMetrics      func(childComplexity int, period string, configIDs []string, destinationIDs []string) int
		OverviewPage         func(childComplexity int, configIDs []string, destinationIDs []string, period string, telemetryType string) int
		Processor            func(childComplexity int, name string) int
		ProcessorType        func(childComplexity int, name string) int
		ProcessorTypes       func(childComplexity int) int
		ProcessorWithType    func(childComplexity int, name string) int
		Processors           func(childComplexity int) int
		Snapshot             func(childComplexity int, agentID string, pipelineType otel.PipelineType, position *string, resourceName *string) int
		Source               func(childComplexity int, name string) int
		SourceType           func(childComplexity int, name string) int
		SourceTypes          func(childComplexity int) int
		SourceWithType       func(childComplexity int, name string) int
		Sources              func(childComplexity int) int
	}

	RelevantIfCondition struct {
		Name     func(childComplexity int) int
		Operator func(childComplexity int) int
		Value    func(childComplexity int) int
	}

	ResourceConfiguration struct {
		Disabled    func(childComplexity int) int
		DisplayName func(childComplexity int) int
		ID          func(childComplexity int) int
		Name        func(childComplexity int) int
		Parameters  func(childComplexity int) int
		Processors  func(childComplexity int) int
		Type        func(childComplexity int) int
	}

	ResourceTypeSpec struct {
		Parameters         func(childComplexity int) int
		SupportedPlatforms func(childComplexity int) int
		TelemetryTypes     func(childComplexity int) int
		Version            func(childComplexity int) int
	}

	Rollout struct {
		Completed func(childComplexity int) int
		Errors    func(childComplexity int) int
		Options   func(childComplexity int) int
		Pending   func(childComplexity int) int
		Phase     func(childComplexity int) int
		Status    func(childComplexity int) int
		Waiting   func(childComplexity int) int
	}

	RolloutOptions struct {
		MaxErrors          func(childComplexity int) int
		PhaseAgentCount    func(childComplexity int) int
		RollbackOnFailure  func(childComplexity int) int
		StartAutomatically func(childComplexity int) int
	}

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

	Source struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		Metadata   func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	SourceType struct {
		APIVersion func(childComplexity int) int
		Kind       func(childComplexity int) int
		Metadata   func(childComplexity int) int
		Spec       func(childComplexity int) int
	}

	SourceWithType struct {
		Source     func(childComplexity int) int
		SourceType func(childComplexity int) int
	}

	Subscription struct {
		AgentChanges         func(childComplexity int, selector *string, query *string) int
		AgentMetrics         func(childComplexity int, period string, ids []string) int
		ConfigurationChanges func(childComplexity int, selector *string, query *string) int
		ConfigurationMetrics func(childComplexity int, period string, name *string, agent *string) int
		OverviewMetrics      func(childComplexity int, period string, configIDs []string, destinationIDs []string) int
	}

	Suggestion struct {
		Label func(childComplexity int) int
		Query func(childComplexity int) int
	}

	Trace struct {
		Attributes   func(childComplexity int) int
		End          func(childComplexity int) int
		Name         func(childComplexity int) int
		ParentSpanID func(childComplexity int) int
		Resource     func(childComplexity int) int
		SpanID       func(childComplexity int) int
		Start        func(childComplexity int) int
		TraceID      func(childComplexity int) int
	}
}

type Config

type Config struct {
	Resolvers  ResolverRoot
	Directives DirectiveRoot
	Complexity ComplexityRoot
}

type ConfigurationResolver

type ConfigurationResolver interface {
	Kind(ctx context.Context, obj *model1.Configuration) (string, error)

	AgentCount(ctx context.Context, obj *model1.Configuration) (*int, error)
	ActiveTypes(ctx context.Context, obj *model1.Configuration) ([]string, error)
	Graph(ctx context.Context, obj *model1.Configuration) (*graph.Graph, error)
	Rendered(ctx context.Context, obj *model1.Configuration) (*string, error)
}

type DestinationResolver

type DestinationResolver interface {
	Kind(ctx context.Context, obj *model1.Destination) (string, error)
}

type DestinationTypeResolver

type DestinationTypeResolver interface {
	Kind(ctx context.Context, obj *model1.DestinationType) (string, error)
}

type DirectiveRoot

type DirectiveRoot struct {
}

type MetadataResolver

type MetadataResolver interface {
	Labels(ctx context.Context, obj *model1.Metadata) (map[string]interface{}, error)
}

type MutationResolver

type MutationResolver interface {
	UpdateProcessors(ctx context.Context, input model.UpdateProcessorsInput) (*bool, error)
	RemoveAgentConfiguration(ctx context.Context, input *model.RemoveAgentConfigurationInput) (*model1.Agent, error)
	ClearAgentUpgradeError(ctx context.Context, input model.ClearAgentUpgradeErrorInput) (*bool, error)
	EditConfigurationDescription(ctx context.Context, input model.EditConfigurationDescriptionInput) (*bool, error)
}

type ParameterDefinitionResolver

type ParameterDefinitionResolver interface {
	Type(ctx context.Context, obj *model1.ParameterDefinition) (model.ParameterType, error)
}

type ParameterOptionsResolver

type ParameterOptionsResolver interface {
	Labels(ctx context.Context, obj *model1.ParameterOptions) (map[string]interface{}, error)
}

type ProcessorResolver

type ProcessorResolver interface {
	Kind(ctx context.Context, obj *model1.Processor) (string, error)
}

type ProcessorTypeResolver

type ProcessorTypeResolver interface {
	Kind(ctx context.Context, obj *model1.ProcessorType) (string, error)
}

type QueryResolver

type QueryResolver interface {
	OverviewPage(ctx context.Context, configIDs []string, destinationIDs []string, period string, telemetryType string) (*model.OverviewPage, error)
	Agents(ctx context.Context, selector *string, query *string) (*model.Agents, error)
	Agent(ctx context.Context, id string) (*model1.Agent, error)
	Configurations(ctx context.Context, selector *string, query *string, onlyDeployedConfigurations *bool) (*model.Configurations, error)
	Configuration(ctx context.Context, name string) (*model1.Configuration, error)
	ConfigurationHistory(ctx context.Context, name string) ([]*model1.Configuration, error)
	Sources(ctx context.Context) ([]*model1.Source, error)
	Source(ctx context.Context, name string) (*model1.Source, error)
	SourceTypes(ctx context.Context) ([]*model1.SourceType, error)
	SourceType(ctx context.Context, name string) (*model1.SourceType, error)
	SourceWithType(ctx context.Context, name string) (*model.SourceWithType, error)
	Processors(ctx context.Context) ([]*model1.Processor, error)
	Processor(ctx context.Context, name string) (*model1.Processor, error)
	ProcessorWithType(ctx context.Context, name string) (*model.ProcessorWithType, error)
	ProcessorTypes(ctx context.Context) ([]*model1.ProcessorType, error)
	ProcessorType(ctx context.Context, name string) (*model1.ProcessorType, error)
	Destinations(ctx context.Context, query *string, filterUnused *bool) ([]*model1.Destination, error)
	Destination(ctx context.Context, name string) (*model1.Destination, error)
	DestinationWithType(ctx context.Context, name string) (*model.DestinationWithType, error)
	DestinationTypes(ctx context.Context) ([]*model1.DestinationType, error)
	DestinationType(ctx context.Context, name string) (*model1.DestinationType, error)
	Snapshot(ctx context.Context, agentID string, pipelineType otel.PipelineType, position *string, resourceName *string) (*model.Snapshot, error)
	AgentMetrics(ctx context.Context, period string, ids []string) (*model.GraphMetrics, error)
	ConfigurationMetrics(ctx context.Context, period string, name *string) (*model.GraphMetrics, error)
	OverviewMetrics(ctx context.Context, period string, configIDs []string, destinationIDs []string) (*model.GraphMetrics, error)
}

type RelevantIfConditionResolver

type RelevantIfConditionResolver interface {
	Operator(ctx context.Context, obj *model1.RelevantIfCondition) (model.RelevantIfOperatorType, error)
}

type ResolverRoot

type ResolverRoot interface {
	Agent() AgentResolver
	AgentSelector() AgentSelectorResolver
	AgentUpgrade() AgentUpgradeResolver
	Configuration() ConfigurationResolver
	Destination() DestinationResolver
	DestinationType() DestinationTypeResolver
	Metadata() MetadataResolver
	Mutation() MutationResolver
	ParameterDefinition() ParameterDefinitionResolver
	ParameterOptions() ParameterOptionsResolver
	Processor() ProcessorResolver
	ProcessorType() ProcessorTypeResolver
	Query() QueryResolver
	RelevantIfCondition() RelevantIfConditionResolver
	Rollout() RolloutResolver
	Source() SourceResolver
	SourceType() SourceTypeResolver
	Subscription() SubscriptionResolver
}

type RolloutResolver

type RolloutResolver interface {
	Completed(ctx context.Context, obj *model1.Rollout) (int, error)
	Errors(ctx context.Context, obj *model1.Rollout) (int, error)
	Pending(ctx context.Context, obj *model1.Rollout) (int, error)
	Waiting(ctx context.Context, obj *model1.Rollout) (int, error)
}

type SourceResolver

type SourceResolver interface {
	Kind(ctx context.Context, obj *model1.Source) (string, error)
}

type SourceTypeResolver

type SourceTypeResolver interface {
	Kind(ctx context.Context, obj *model1.SourceType) (string, error)
}

type SubscriptionResolver

type SubscriptionResolver interface {
	AgentChanges(ctx context.Context, selector *string, query *string) (<-chan []*model.AgentChange, error)
	ConfigurationChanges(ctx context.Context, selector *string, query *string) (<-chan []*model.ConfigurationChange, error)
	AgentMetrics(ctx context.Context, period string, ids []string) (<-chan *model.GraphMetrics, error)
	ConfigurationMetrics(ctx context.Context, period string, name *string, agent *string) (<-chan *model.GraphMetrics, error)
	OverviewMetrics(ctx context.Context, period string, configIDs []string, destinationIDs []string) (<-chan *model.GraphMetrics, error)
}