graph

package
v0.0.0-...-8dae2d9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 5, 2026 License: MIT Imports: 80 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewHandler 

func NewHandler(config gengql.Config, log logrus.FieldLogger) (*handler.Server, error)

func SendError 

func SendError(w http.ResponseWriter, code int, errors ...*gqlerror.Error)

SendError sends a best effort error to a raw response writer. It assumes the client can understand the standard json error response.

func SendErrorf 

func SendErrorf(w http.ResponseWriter, code int, format string, args ...any)

SendErrorf wraps SendError to add formatted messages.

Types

type Metrics 

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

func NewMetrics 

func NewMetrics(meter metric.Meter) (*Metrics, error)

func (*Metrics) ExtensionName 

func (a *Metrics) ExtensionName() string

func (*Metrics) InterceptField 

func (a *Metrics) InterceptField(ctx context.Context, next graphql.Resolver) (any, error)

func (*Metrics) InterceptResponse 

func (a *Metrics) InterceptResponse(ctx context.Context, next graphql.ResponseHandler) *graphql.Response

func (*Metrics) InterceptRootField 

func (a *Metrics) InterceptRootField(ctx context.Context, next graphql.RootResolver) graphql.Marshaler

func (*Metrics) Validate 

func (a *Metrics) Validate(_ graphql.ExecutableSchema) error

type PubsubTopic 

type PubsubTopic interface {
	Publish(ctx context.Context, msg protoreflect.ProtoMessage, attrs map[string]string) (string, error)
	String() string
}

type Resolver 

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

func NewResolver 

func NewResolver(topic PubsubTopic, opts ...ResolverOption) *Resolver

func (*Resolver) Application 

func (r *Resolver) Application() gengql.ApplicationResolver

func (*Resolver) ApplicationInstance 

func (r *Resolver) ApplicationInstance() gengql.ApplicationInstanceResolver

func (*Resolver) BigQueryDataset 

func (r *Resolver) BigQueryDataset() gengql.BigQueryDatasetResolver

func (*Resolver) Bucket 

func (r *Resolver) Bucket() gengql.BucketResolver

func (*Resolver) CVE 

func (r *Resolver) CVE() gengql.CVEResolver

func (*Resolver) ContainerImage 

func (r *Resolver) ContainerImage() gengql.ContainerImageResolver

func (*Resolver) ContainerImageWorkloadReference 

func (r *Resolver) ContainerImageWorkloadReference() gengql.ContainerImageWorkloadReferenceResolver

func (*Resolver) CurrentUnitPrices 

func (r *Resolver) CurrentUnitPrices() gengql.CurrentUnitPricesResolver

func (*Resolver) DeleteApplicationPayload 

func (r *Resolver) DeleteApplicationPayload() gengql.DeleteApplicationPayloadResolver

func (*Resolver) DeleteJobPayload 

func (r *Resolver) DeleteJobPayload() gengql.DeleteJobPayloadResolver

func (*Resolver) Deployment 

func (r *Resolver) Deployment() gengql.DeploymentResolver

func (*Resolver) DeprecatedIngressIssue 

func (r *Resolver) DeprecatedIngressIssue() gengql.DeprecatedIngressIssueResolver

func (*Resolver) DeprecatedRegistryIssue 

func (r *Resolver) DeprecatedRegistryIssue() gengql.DeprecatedRegistryIssueResolver

func (*Resolver) Environment 

func (r *Resolver) Environment() gengql.EnvironmentResolver

func (*Resolver) ExternalIngressCriticalVulnerabilityIssue 

func (r *Resolver) ExternalIngressCriticalVulnerabilityIssue() gengql.ExternalIngressCriticalVulnerabilityIssueResolver

func (*Resolver) FailedSynchronizationIssue 

func (r *Resolver) FailedSynchronizationIssue() gengql.FailedSynchronizationIssueResolver

func (*Resolver) Ingress 

func (r *Resolver) Ingress() gengql.IngressResolver

func (*Resolver) IngressMetrics 

func (r *Resolver) IngressMetrics() gengql.IngressMetricsResolver

func (*Resolver) InvalidSpecIssue 

func (r *Resolver) InvalidSpecIssue() gengql.InvalidSpecIssueResolver

func (*Resolver) Job 

func (r *Resolver) Job() gengql.JobResolver

func (*Resolver) JobRun 

func (r *Resolver) JobRun() gengql.JobRunResolver

func (*Resolver) KafkaTopic 

func (r *Resolver) KafkaTopic() gengql.KafkaTopicResolver

func (*Resolver) KafkaTopicAcl 

func (r *Resolver) KafkaTopicAcl() gengql.KafkaTopicAclResolver

func (*Resolver) LastRunFailedIssue 

func (r *Resolver) LastRunFailedIssue() gengql.LastRunFailedIssueResolver

func (*Resolver) MissingSbomIssue 

func (r *Resolver) MissingSbomIssue() gengql.MissingSbomIssueResolver

func (*Resolver) Mutation 

func (r *Resolver) Mutation() gengql.MutationResolver

func (*Resolver) NetworkPolicyRule 

func (r *Resolver) NetworkPolicyRule() gengql.NetworkPolicyRuleResolver

func (*Resolver) NoRunningInstancesIssue 

func (r *Resolver) NoRunningInstancesIssue() gengql.NoRunningInstancesIssueResolver

func (*Resolver) OpenSearch 

func (r *Resolver) OpenSearch() gengql.OpenSearchResolver

func (*Resolver) OpenSearchAccess 

func (r *Resolver) OpenSearchAccess() gengql.OpenSearchAccessResolver

func (*Resolver) OpenSearchIssue 

func (r *Resolver) OpenSearchIssue() gengql.OpenSearchIssueResolver

func (*Resolver) OpenSearchMaintenance 

func (r *Resolver) OpenSearchMaintenance() gengql.OpenSearchMaintenanceResolver

func (*Resolver) PostgresInstance 

func (r *Resolver) PostgresInstance() gengql.PostgresInstanceResolver

func (*Resolver) PostgresInstanceAudit 

func (r *Resolver) PostgresInstanceAudit() gengql.PostgresInstanceAuditResolver

func (*Resolver) PrometheusAlert 

func (r *Resolver) PrometheusAlert() gengql.PrometheusAlertResolver

func (*Resolver) Query 

func (r *Resolver) Query() gengql.QueryResolver

func (*Resolver) Reconciler 

func (r *Resolver) Reconciler() gengql.ReconcilerResolver

func (*Resolver) ReconcilerError 

func (r *Resolver) ReconcilerError() gengql.ReconcilerErrorResolver

func (*Resolver) RemoveTeamMemberPayload 

func (r *Resolver) RemoveTeamMemberPayload() gengql.RemoveTeamMemberPayloadResolver

func (*Resolver) Repository 

func (r *Resolver) Repository() gengql.RepositoryResolver

func (*Resolver) RestartApplicationPayload 

func (r *Resolver) RestartApplicationPayload() gengql.RestartApplicationPayloadResolver

func (*Resolver) Secret 

func (r *Resolver) Secret() gengql.SecretResolver

func (*Resolver) ServiceAccount 

func (r *Resolver) ServiceAccount() gengql.ServiceAccountResolver

func (*Resolver) SqlDatabase 

func (r *Resolver) SqlDatabase() gengql.SqlDatabaseResolver

func (*Resolver) SqlInstance 

func (r *Resolver) SqlInstance() gengql.SqlInstanceResolver

func (*Resolver) SqlInstanceMetrics 

func (r *Resolver) SqlInstanceMetrics() gengql.SqlInstanceMetricsResolver

func (*Resolver) SqlInstanceStateIssue 

func (r *Resolver) SqlInstanceStateIssue() gengql.SqlInstanceStateIssueResolver

func (*Resolver) SqlInstanceVersionIssue 

func (r *Resolver) SqlInstanceVersionIssue() gengql.SqlInstanceVersionIssueResolver

func (*Resolver) Subscription 

func (r *Resolver) Subscription() gengql.SubscriptionResolver

func (*Resolver) Team 

func (r *Resolver) Team() gengql.TeamResolver

func (*Resolver) TeamCost 

func (r *Resolver) TeamCost() gengql.TeamCostResolver

func (*Resolver) TeamDeleteKey 

func (r *Resolver) TeamDeleteKey() gengql.TeamDeleteKeyResolver

func (*Resolver) TeamEnvironment 

func (r *Resolver) TeamEnvironment() gengql.TeamEnvironmentResolver

func (*Resolver) TeamEnvironmentCost 

func (r *Resolver) TeamEnvironmentCost() gengql.TeamEnvironmentCostResolver

func (*Resolver) TeamInventoryCounts 

func (r *Resolver) TeamInventoryCounts() gengql.TeamInventoryCountsResolver

func (*Resolver) TeamMember 

func (r *Resolver) TeamMember() gengql.TeamMemberResolver

func (*Resolver) TeamServiceUtilization 

func (r *Resolver) TeamServiceUtilization() gengql.TeamServiceUtilizationResolver

func (*Resolver) TeamServiceUtilizationSqlInstances 

func (r *Resolver) TeamServiceUtilizationSqlInstances() gengql.TeamServiceUtilizationSqlInstancesResolver

func (*Resolver) TeamUtilizationData 

func (r *Resolver) TeamUtilizationData() gengql.TeamUtilizationDataResolver

func (*Resolver) TeamVulnerabilitySummary 

func (r *Resolver) TeamVulnerabilitySummary() gengql.TeamVulnerabilitySummaryResolver

func (*Resolver) TriggerJobPayload 

func (r *Resolver) TriggerJobPayload() gengql.TriggerJobPayloadResolver

func (*Resolver) UnleashInstance 

func (r *Resolver) UnleashInstance() gengql.UnleashInstanceResolver

func (*Resolver) UnleashInstanceMetrics 

func (r *Resolver) UnleashInstanceMetrics() gengql.UnleashInstanceMetricsResolver

func (*Resolver) UnleashReleaseChannelIssue 

func (r *Resolver) UnleashReleaseChannelIssue() gengql.UnleashReleaseChannelIssueResolver

func (*Resolver) UpdateTeamEnvironmentPayload 

func (r *Resolver) UpdateTeamEnvironmentPayload() gengql.UpdateTeamEnvironmentPayloadResolver

func (*Resolver) User 

func (r *Resolver) User() gengql.UserResolver

func (*Resolver) Valkey 

func (r *Resolver) Valkey() gengql.ValkeyResolver

func (*Resolver) ValkeyAccess 

func (r *Resolver) ValkeyAccess() gengql.ValkeyAccessResolver

func (*Resolver) ValkeyIssue 

func (r *Resolver) ValkeyIssue() gengql.ValkeyIssueResolver

func (*Resolver) ValkeyMaintenance 

func (r *Resolver) ValkeyMaintenance() gengql.ValkeyMaintenanceResolver

func (*Resolver) VulnerableImageIssue 

func (r *Resolver) VulnerableImageIssue() gengql.VulnerableImageIssueResolver

func (*Resolver) WorkloadCost 

func (r *Resolver) WorkloadCost() gengql.WorkloadCostResolver

func (*Resolver) WorkloadCostSample 

func (r *Resolver) WorkloadCostSample() gengql.WorkloadCostSampleResolver

func (*Resolver) WorkloadUtilization 

func (r *Resolver) WorkloadUtilization() gengql.WorkloadUtilizationResolver

func (*Resolver) WorkloadUtilizationData 

func (r *Resolver) WorkloadUtilizationData() gengql.WorkloadUtilizationDataResolver

func (*Resolver) WorkloadVulnerabilitySummary 

func (r *Resolver) WorkloadVulnerabilitySummary() gengql.WorkloadVulnerabilitySummaryResolver

type ResolverOption 

type ResolverOption func(*Resolver)

func WithLogger 

func WithLogger(log logrus.FieldLogger) ResolverOption

type SSE 

type SSE struct {
	KeepAlivePingInterval time.Duration
}

func (SSE) Do 

func (t SSE) Do(w http.ResponseWriter, r *http.Request, exec graphql.GraphExecutor)

func (SSE) Supports 

func (t SSE) Supports(r *http.Request) bool

type TopicWrapper 

type TopicWrapper struct {
	Topic *pubsub.Topic
}

func (*TopicWrapper) Publish 

func (t *TopicWrapper) Publish(ctx context.Context, msg protoreflect.ProtoMessage, attrs map[string]string) (string, error)

func (*TopicWrapper) String 

func (t *TopicWrapper) String() string

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.