controller

Dec 11, 2024

Changes in this version

+ var ErrFalcoEventIsNotFlow = errors.New("ignoring falco event, not a network flow")

+ func GetTLSConfig(skipVerify bool) *tls.Config

+ func GetTokenSource(ctx context.Context, config clientcredentials.Config, tlsConfig *tls.Config) oauth2.TokenSource

+ func NewFalcoEventHandler(eventChan chan<- string) http.HandlerFunc

+ func ParseToken(tokenString string) (jwt.MapClaims, error)

+ type FalcoEvent struct

+ DstIP string

+ DstPort string

+ IpVersion string

+ Proto string

+ SrcIP string

+ SrcPort string

type ResourceManager

+ func (r *ResourceManager) ExtractObjectMetas(resources *unstructured.UnstructuredList) ([]metav1.ObjectMeta, error)

+ func (r *ResourceManager) FetchResources(ctx context.Context, resource schema.GroupVersionResource, namespace string) (*unstructured.UnstructuredList, error)

+ func (r *ResourceManager) ListResources(ctx context.Context, resource schema.GroupVersionResource, namespace string) ([]metav1.ObjectMeta, string, error)

Oct 10, 2024

Changes in this version

+ var ErrHubbleNotFound = errors.New("hubble Relay service not found; disabling Cilium flow collection")

+ var ErrNoPortsAvailable = errors.New("hubble Relay service has no ports; disabling Cilium flow collection")

+ var ErrStopRetries = errors.New("stop retries")

+ func ConnectStreams(ctx context.Context, logger *zap.SugaredLogger, envMap EnvironmentConfig, ...)

+ func NewAuthenticatedConnection(ctx context.Context, logger *zap.SugaredLogger, envMap EnvironmentConfig) (*grpc.ClientConn, pb.KubernetesInfoServiceClient, error)

+ type Authenticator struct

+ Logger *zap.SugaredLogger

+ func (authn *Authenticator) DoesK8sSecretExist(ctx context.Context, secretName string) bool

+ func (authn *Authenticator) GetOnboardingCredentials(ctx context.Context, clientID string, clientSecret string) (Credentials, error)

+ func (authn *Authenticator) ReadCredentialsK8sSecrets(ctx context.Context, secretName string) (string, string, error)

+ func (authn *Authenticator) WriteK8sSecret(ctx context.Context, keyData OnboardResponse, ClusterCreds string) error

+ type Cache struct

type OnboardResponse

+ func Onboard(ctx context.Context, TlsSkipVerify bool, OnboardingEndpoint string, ...) (OnboardResponse, error)

Sep 26, 2024

Changes in this version

+ type CiliumFlowCollector struct

type EnvironmentConfig

+ CiliumNamespace string

Sep 11, 2024

Changes in this version

+ func NewGRPClogger(grpcSyncer *BufferedGrpcWriteSyncer) *zap.SugaredLogger

+ func NewStreams(ctx context.Context, logger *zap.SugaredLogger, conn *grpc.ClientConn) (*streamManager, error)

+ type BufferedGrpcWriteSyncer struct

+ func NewBufferedGrpcWriteSyncer() *BufferedGrpcWriteSyncer

+ func (b *BufferedGrpcWriteSyncer) Close() error

+ func (b *BufferedGrpcWriteSyncer) ListenToLogStream()

+ func (b *BufferedGrpcWriteSyncer) UpdateClient(client pb.KubernetesInfoService_SendLogsClient, conn ClientConnInterface)

+ type ClientConnInterface interface

+ Close func() error

+ GetState func() connectivity.State

Sep 6, 2024

Changes in this version

+ func ExponentialStreamConnect(ctx context.Context, logger *zap.SugaredLogger, envMap EnvironmentConfig)

+ func GetClusterID(ctx context.Context, logger *zap.SugaredLogger) (string, error)

+ func IsRunningInCluster() bool

+ func NewClientSet() (*kubernetes.Clientset, error)

+ func NewStream(ctx context.Context, logger *zap.SugaredLogger, conn *grpc.ClientConn) (*streamManager, error)

+ func ServerIsHealthy() bool

+ func SetUpOAuthConnection(ctx context.Context, logger *zap.SugaredLogger, tokenURL string, ...) (*grpc.ClientConn, error)

+ type CacheManager struct

+ type Credentials struct

+ ClientID string

+ ClientSecret string

+ type CredentialsManager struct

+ Credentials Credentials

+ Logger *zap.SugaredLogger

+ func (am *CredentialsManager) Onboard(ctx context.Context, TlsSkipVerify bool, OnboardingEndpoint string) (OnboardResponse, error)

+ type EnvironmentConfig struct

+ ClusterCreds string

+ OnboardingClientId string

+ OnboardingClientSecret string

+ OnboardingEndpoint string

+ TlsSkipVerify bool

+ TokenEndpoint string

+ type OnboardResponse struct

+ ClusterClientId string

+ ClusterClientSecret string

+ type ResourceManager struct

+ func (r *ResourceManager) DyanmicListAndWatchResources(ctx context.Context, cancel context.CancelFunc, resource string, ...)

+ func (r *ResourceManager) DynamicListResources(ctx context.Context, resource string) (string, CacheManager, error)

+ type SecretManager struct

+ Logger *zap.SugaredLogger

+ func (sm *SecretManager) DoesK8sSecretExist(ctx context.Context, secretName string) bool

+ func (sm *SecretManager) GetOnboardingCredentials(ctx context.Context, clientID string, clientSecret string) (Credentials, error)

+ func (sm *SecretManager) ReadCredentialsK8sSecrets(ctx context.Context, secretName string) (string, string, error)

+ func (sm *SecretManager) WriteK8sSecret(ctx context.Context, keyData OnboardResponse, ClusterCreds string) error