api

Documentation

Index

• Variables
• type API
• type IngestorAPI
  • func NewIngestorAPI(cfg *config.KubehoundConfig, puller puller.DataPuller, ...) *IngestorAPI
  • func (g *IngestorAPI) Ingest(_ context.Context, clusterName string, runID string) error
  • func (g *IngestorAPI) Notify(ctx context.Context, clusterName string, runID string) error
  • func (g *IngestorAPI) RehydrateLatest(ctx context.Context) ([]*grpc.IngestedCluster, error)

Variables

var (
	ErrAlreadyIngested = errors.New("ingestion already completed")
)

Types

type API

type API interface {
	Ingest(ctx context.Context, clusterName string, runID string) error
	Notify(ctx context.Context, clusterName string, runID string) error
}

type IngestorAPI

type IngestorAPI struct {
	Cfg *config.KubehoundConfig
	// contains filtered or unexported fields
}

func NewIngestorAPI

func NewIngestorAPI(cfg *config.KubehoundConfig, puller puller.DataPuller, notifier notifier.Notifier,
	p *providers.ProvidersFactoryConfig) *IngestorAPI

func (*IngestorAPI) Ingest

func (g *IngestorAPI) Ingest(_ context.Context, clusterName string, runID string) error

func (*IngestorAPI) Notify

func (g *IngestorAPI) Notify(ctx context.Context, clusterName string, runID string) error

Notify notifies the caller that the ingestion is completed

func (*IngestorAPI) RehydrateLatest

func (g *IngestorAPI) RehydrateLatest(ctx context.Context) ([]*grpc.IngestedCluster, error)

RehydrateLatest is just a GRPC wrapper around the Ingest method from the API package