resolvers

Documentation

Index

• type Resolver
  • func NewResolver(kubeFinder *kubefinder.KubeFinder, ...) *Resolver
  • func (r *Resolver) Mutation() generated.MutationResolver
  • func (r *Resolver) Query() generated.QueryResolver
  • func (r *Resolver) Register(e *echo.Echo)
  • func (r *Resolver) RunForever(ctx context.Context) error
• type Results
• type SourceType

Types

type Resolver

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

func NewResolver

func NewResolver(
	kubeFinder *kubefinder.KubeFinder,
	serviceIdResolver *serviceidresolver.Resolver,
	intentsHolder *intentsstore.IntentsHolder,
	externalTrafficHolder *externaltrafficholder.ExternalTrafficIntentsHolder,
	awsIntentsHolder *awsintentsholder.AWSIntentsHolder,
	azureIntentsHolder *azureintentsholder.AzureIntentsHolder,
	dnsCache *dnscache.DNSCache,
	incomingTrafficHolder *incomingtrafficholder.IncomingTrafficIntentsHolder,
) *Resolver

func (*Resolver) Mutation

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

Mutation returns generated.MutationResolver implementation.

func (*Resolver) Query

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

Query returns generated.QueryResolver implementation.

func (*Resolver) Register

func (r *Resolver) Register(e *echo.Echo)

func (*Resolver) RunForever

func (r *Resolver) RunForever(ctx context.Context) error

type Results

type Results interface {
	Length() int
}

type SourceType

type SourceType string

const (
	SourceTypeDNSCapture  SourceType = "Capture"
	SourceTypeTCPScan     SourceType = "TCPScan"
	SourceTypeSocketScan  SourceType = "SocketScan"
	SourceTypeKafkaMapper SourceType = "KafkaMapper"
	SourceTypeIstio       SourceType = "Istio"
)