clusteragent

Documentation

Index

• func SetLogger(l *zap.SugaredLogger)
• type ClusterAgent
  • func NewClusterAgent(config *ClusterAgentConfig) *ClusterAgent
  • func (ca *ClusterAgent) Close()
  • func (ca *ClusterAgent) GetFalcoAlertsSubscriber() *FalcoAlertsSubscriber
  • func (ca *ClusterAgent) GetGrpcServer() *grpc.Server
• type ClusterAgentConfig
• type ConfigServer
  • func NewConfigServer(tarianServerAddress string, opts []grpc.DialOption) *ConfigServer
  • func (cs *ConfigServer) AddConstraint(reqCtx context.Context, request *tarianpb.AddConstraintRequest) (*tarianpb.AddConstraintResponse, error)
  • func (cs *ConfigServer) Close()
  • func (cs *ConfigServer) EnableAddConstraint(value bool)
  • func (cs *ConfigServer) GetConstraints(reqCtx context.Context, request *tarianpb.GetConstraintsRequest) (*tarianpb.GetConstraintsResponse, error)
  • func (cs *ConfigServer) RemoveConstraint(reqCtx context.Context, request *tarianpb.RemoveConstraintRequest) (*tarianpb.RemoveConstraintResponse, error)
• type EventServer
  • func NewEventServer(tarianServerAddress string, opts []grpc.DialOption) *EventServer
  • func (es *EventServer) Close()
  • func (es *EventServer) IngestEvent(requestContext context.Context, request *tarianpb.IngestEventRequest) (*tarianpb.IngestEventResponse, error)
• type FalcoAlertsSubscriber
  • func NewFalcoAlertsSubscriber(tarianServerAddress string, opts []grpc.DialOption, config *client.Config) (*FalcoAlertsSubscriber, error)
  • func (f *FalcoAlertsSubscriber) Close()
  • func (f *FalcoAlertsSubscriber) ProcessFalcoOutput(res *outputs.Response) error
  • func (f *FalcoAlertsSubscriber) Start()

Functions

func SetLogger

func SetLogger(l *zap.SugaredLogger)

Types

type ClusterAgent

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

func NewClusterAgent

func NewClusterAgent(config *ClusterAgentConfig) *ClusterAgent

func (*ClusterAgent) Close

func (ca *ClusterAgent) Close()

func (*ClusterAgent) GetFalcoAlertsSubscriber

func (ca *ClusterAgent) GetFalcoAlertsSubscriber() *FalcoAlertsSubscriber

func (*ClusterAgent) GetGrpcServer

func (ca *ClusterAgent) GetGrpcServer() *grpc.Server

type ClusterAgentConfig

type ClusterAgentConfig struct {
	ServerAddress          string
	ServerGrpcDialOptions  []grpc.DialOption
	EnableFalcoIntegration bool
	EnableAddConstraint    bool
	FalcoClientConfig      *falcoclient.Config
}

type ConfigServer

type ConfigServer struct {
	tarianpb.UnimplementedConfigServer
	// contains filtered or unexported fields
}

func NewConfigServer

func NewConfigServer(tarianServerAddress string, opts []grpc.DialOption) *ConfigServer

func (*ConfigServer) AddConstraint

func (cs *ConfigServer) AddConstraint(reqCtx context.Context, request *tarianpb.AddConstraintRequest) (*tarianpb.AddConstraintResponse, error)

func (*ConfigServer) Close

func (cs *ConfigServer) Close()

func (*ConfigServer) EnableAddConstraint

func (cs *ConfigServer) EnableAddConstraint(value bool)

func (*ConfigServer) GetConstraints

func (cs *ConfigServer) GetConstraints(reqCtx context.Context, request *tarianpb.GetConstraintsRequest) (*tarianpb.GetConstraintsResponse, error)

func (*ConfigServer) RemoveConstraint

func (cs *ConfigServer) RemoveConstraint(reqCtx context.Context, request *tarianpb.RemoveConstraintRequest) (*tarianpb.RemoveConstraintResponse, error)

type EventServer

type EventServer struct {
	tarianpb.UnimplementedEventServer
	// contains filtered or unexported fields
}

func NewEventServer

func NewEventServer(tarianServerAddress string, opts []grpc.DialOption) *EventServer

func (*EventServer) Close

func (es *EventServer) Close()

func (*EventServer) IngestEvent

func (es *EventServer) IngestEvent(requestContext context.Context, request *tarianpb.IngestEventRequest) (*tarianpb.IngestEventResponse, error)

type FalcoAlertsSubscriber

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

func NewFalcoAlertsSubscriber

func NewFalcoAlertsSubscriber(tarianServerAddress string, opts []grpc.DialOption, config *client.Config) (*FalcoAlertsSubscriber, error)

func (*FalcoAlertsSubscriber) Close

func (f *FalcoAlertsSubscriber) Close()

func (*FalcoAlertsSubscriber) ProcessFalcoOutput

func (f *FalcoAlertsSubscriber) ProcessFalcoOutput(res *outputs.Response) error

func (*FalcoAlertsSubscriber) Start

func (f *FalcoAlertsSubscriber) Start()