Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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.
type ResolverRoot ¶
type ResolverRoot interface {
ComputePlatform() ComputePlatformResolver
Destination() DestinationResolver
K8sActualNamespace() K8sActualNamespaceResolver
Mutation() MutationResolver
Query() QueryResolver
}
Click to show internal directories.
Click to hide internal directories.