graph

Documentation

Index

• func NewHandler(config gengql.Config, log logrus.FieldLogger) (*handler.Server, error)
• type Metrics
  • func NewMetrics(meter metric.Meter) (*Metrics, error)
  • func (a *Metrics) ExtensionName() string
  • func (a *Metrics) InterceptField(ctx context.Context, next graphql.Resolver) (interface{}, error)
  • func (a *Metrics) InterceptResponse(ctx context.Context, next graphql.ResponseHandler) *graphql.Response
  • func (a *Metrics) Validate(_ graphql.ExecutableSchema) error
• type PubsubTopic
• type Resolver
  • func NewResolver(topic PubsubTopic, opts ...ResolverOption) *Resolver
  • func (r *Resolver) Application() gengql.ApplicationResolver
  • func (r *Resolver) BigQueryDataset() gengql.BigQueryDatasetResolver
  • func (r *Resolver) Bucket() gengql.BucketResolver
  • func (r *Resolver) ContainerImage() gengql.ContainerImageResolver
  • func (r *Resolver) ContainerImageWorkloadReference() gengql.ContainerImageWorkloadReferenceResolver
  • func (r *Resolver) DeleteApplicationPayload() gengql.DeleteApplicationPayloadResolver
  • func (r *Resolver) DeleteJobPayload() gengql.DeleteJobPayloadResolver
  • func (r *Resolver) Deployment() gengql.DeploymentResolver
  • func (r *Resolver) DeploymentInfo() gengql.DeploymentInfoResolver
  • func (r *Resolver) ImageVulnerability() gengql.ImageVulnerabilityResolver
  • func (r *Resolver) ImageVulnerabilityAnalysisTrail() gengql.ImageVulnerabilityAnalysisTrailResolver
  • func (r *Resolver) Ingress() gengql.IngressResolver
  • func (r *Resolver) Job() gengql.JobResolver
  • func (r *Resolver) JobRun() gengql.JobRunResolver
  • func (r *Resolver) KafkaTopic() gengql.KafkaTopicResolver
  • func (r *Resolver) KafkaTopicAcl() gengql.KafkaTopicAclResolver
  • func (r *Resolver) Mutation() gengql.MutationResolver
  • func (r *Resolver) NetworkPolicyRule() gengql.NetworkPolicyRuleResolver
  • func (r *Resolver) OpenSearch() gengql.OpenSearchResolver
  • func (r *Resolver) OpenSearchAccess() gengql.OpenSearchAccessResolver
  • func (r *Resolver) Query() gengql.QueryResolver
  • func (r *Resolver) Reconciler() gengql.ReconcilerResolver
  • func (r *Resolver) ReconcilerError() gengql.ReconcilerErrorResolver
  • func (r *Resolver) RedisInstance() gengql.RedisInstanceResolver
  • func (r *Resolver) RedisInstanceAccess() gengql.RedisInstanceAccessResolver
  • func (r *Resolver) RemoveTeamMemberPayload() gengql.RemoveTeamMemberPayloadResolver
  • func (r *Resolver) Repository() gengql.RepositoryResolver
  • func (r *Resolver) RestartApplicationPayload() gengql.RestartApplicationPayloadResolver
  • func (r *Resolver) Secret() gengql.SecretResolver
  • func (r *Resolver) SqlDatabase() gengql.SqlDatabaseResolver
  • func (r *Resolver) SqlInstance() gengql.SqlInstanceResolver
  • func (r *Resolver) SqlInstanceMetrics() gengql.SqlInstanceMetricsResolver
  • func (r *Resolver) Subscription() gengql.SubscriptionResolver
  • func (r *Resolver) Team() gengql.TeamResolver
  • func (r *Resolver) TeamCost() gengql.TeamCostResolver
  • func (r *Resolver) TeamDeleteKey() gengql.TeamDeleteKeyResolver
  • func (r *Resolver) TeamEnvironment() gengql.TeamEnvironmentResolver
  • func (r *Resolver) TeamEnvironmentCost() gengql.TeamEnvironmentCostResolver
  • func (r *Resolver) TeamInventoryCounts() gengql.TeamInventoryCountsResolver
  • func (r *Resolver) TeamMember() gengql.TeamMemberResolver
  • func (r *Resolver) TeamMemberAddedAuditEntryData() gengql.TeamMemberAddedAuditEntryDataResolver
  • func (r *Resolver) TeamMemberRemovedAuditEntryData() gengql.TeamMemberRemovedAuditEntryDataResolver
  • func (r *Resolver) TeamMemberSetRoleAuditEntryData() gengql.TeamMemberSetRoleAuditEntryDataResolver
  • func (r *Resolver) TeamServiceUtilization() gengql.TeamServiceUtilizationResolver
  • func (r *Resolver) TeamServiceUtilizationSqlInstances() gengql.TeamServiceUtilizationSqlInstancesResolver
  • func (r *Resolver) TeamUtilizationData() gengql.TeamUtilizationDataResolver
  • func (r *Resolver) TeamUtilizationEnvironmentDataPoint() gengql.TeamUtilizationEnvironmentDataPointResolver
  • func (r *Resolver) TeamVulnerabilitySummary() gengql.TeamVulnerabilitySummaryResolver
  • func (r *Resolver) TriggerJobPayload() gengql.TriggerJobPayloadResolver
  • func (r *Resolver) UnleashInstance() gengql.UnleashInstanceResolver
  • func (r *Resolver) UnleashInstanceMetrics() gengql.UnleashInstanceMetricsResolver
  • func (r *Resolver) User() gengql.UserResolver
  • func (r *Resolver) WorkloadCost() gengql.WorkloadCostResolver
  • func (r *Resolver) WorkloadCostPoint() gengql.WorkloadCostPointResolver
  • func (r *Resolver) WorkloadUtilization() gengql.WorkloadUtilizationResolver
  • func (r *Resolver) WorkloadUtilizationData() gengql.WorkloadUtilizationDataResolver
• type ResolverOption
  • func WithLogger(log logrus.FieldLogger) ResolverOption
• type SSE
  • func (t SSE) Do(w http.ResponseWriter, r *http.Request, exec graphql.GraphExecutor)
  • func (t SSE) Supports(r *http.Request) bool
• type TopicWrapper
  • func (t *TopicWrapper) Publish(ctx context.Context, msg protoreflect.ProtoMessage, attrs map[string]string) (string, error)
  • func (t *TopicWrapper) String() string

Functions

func NewHandler

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

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) (interface{}, error)

func (*Metrics) InterceptResponse

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

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) BigQueryDataset

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

func (*Resolver) Bucket

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

func (*Resolver) ContainerImage

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

func (*Resolver) ContainerImageWorkloadReference

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

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) DeploymentInfo

func (r *Resolver) DeploymentInfo() gengql.DeploymentInfoResolver

func (*Resolver) ImageVulnerability

func (r *Resolver) ImageVulnerability() gengql.ImageVulnerabilityResolver

func (*Resolver) ImageVulnerabilityAnalysisTrail

func (r *Resolver) ImageVulnerabilityAnalysisTrail() gengql.ImageVulnerabilityAnalysisTrailResolver

func (*Resolver) Ingress

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

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) Mutation

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

func (*Resolver) NetworkPolicyRule

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

func (*Resolver) OpenSearch

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

func (*Resolver) OpenSearchAccess

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

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) RedisInstance

func (r *Resolver) RedisInstance() gengql.RedisInstanceResolver

func (*Resolver) RedisInstanceAccess

func (r *Resolver) RedisInstanceAccess() gengql.RedisInstanceAccessResolver

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) 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) 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) TeamMemberAddedAuditEntryData

func (r *Resolver) TeamMemberAddedAuditEntryData() gengql.TeamMemberAddedAuditEntryDataResolver

func (*Resolver) TeamMemberRemovedAuditEntryData

func (r *Resolver) TeamMemberRemovedAuditEntryData() gengql.TeamMemberRemovedAuditEntryDataResolver

func (*Resolver) TeamMemberSetRoleAuditEntryData

func (r *Resolver) TeamMemberSetRoleAuditEntryData() gengql.TeamMemberSetRoleAuditEntryDataResolver

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) TeamUtilizationEnvironmentDataPoint

func (r *Resolver) TeamUtilizationEnvironmentDataPoint() gengql.TeamUtilizationEnvironmentDataPointResolver

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) User

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

func (*Resolver) WorkloadCost

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

func (*Resolver) WorkloadCostPoint

func (r *Resolver) WorkloadCostPoint() gengql.WorkloadCostPointResolver

func (*Resolver) WorkloadUtilization

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

func (*Resolver) WorkloadUtilizationData

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

type ResolverOption

type ResolverOption func(*Resolver)

func WithLogger

func WithLogger(log logrus.FieldLogger) ResolverOption

type SSE

type SSE struct{}

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