clusteragent

Documentation

Overview

Package clusteragent provides tarian cluster agent functionality

Index

• func SetLogger(l *zap.SugaredLogger)
• type ActionHandler
• type ClusterAgent
  • func NewClusterAgent(config *ClusterAgentConfig) *ClusterAgent
  • func (ca *ClusterAgent) Close()
  • func (ca *ClusterAgent) GetGrpcServer() *grpc.Server
  • func (ca *ClusterAgent) Run()
• type ClusterAgentConfig
• type ConfigCache
  • func NewConfigCache(ctx context.Context, configClient tarianpb.ConfigClient) *ConfigCache
  • func (cc *ConfigCache) GetConstraints() []*tarianpb.Constraint
  • func (cc *ConfigCache) IsConstraintInitialized() bool
  • func (cc *ConfigCache) Run()
  • func (cc *ConfigCache) SetConstraints(constraints []*tarianpb.Constraint)
  • func (cc *ConfigCache) SyncConstraints()
• 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 FalcoSidekickListener
  • func NewFalcoSidekickListener(addr string, tarianServerAddress string, opts []grpc.DialOption, ...) *FalcoSidekickListener

Functions

func SetLogger

func SetLogger(l *zap.SugaredLogger)

Types

type ActionHandler

type ActionHandler interface {
	QueueEvent(*tarianpb.Event)
}

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

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

func (*ClusterAgent) Run

func (ca *ClusterAgent) Run()

type ClusterAgentConfig

type ClusterAgentConfig struct {
	ServerAddress         string
	ServerGrpcDialOptions []grpc.DialOption
	EnableAddConstraint   bool
}

type ConfigCache

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

func NewConfigCache

func NewConfigCache(ctx context.Context, configClient tarianpb.ConfigClient) *ConfigCache

func (*ConfigCache) GetConstraints

func (cc *ConfigCache) GetConstraints() []*tarianpb.Constraint

func (*ConfigCache) IsConstraintInitialized

func (cc *ConfigCache) IsConstraintInitialized() bool

func (*ConfigCache) Run

func (cc *ConfigCache) Run()

func (*ConfigCache) SetConstraints

func (cc *ConfigCache) SetConstraints(constraints []*tarianpb.Constraint)

func (*ConfigCache) SyncConstraints

func (cc *ConfigCache) SyncConstraints()

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, actionHandler *actionHandler) *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 FalcoSidekickListener

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

func NewFalcoSidekickListener

func NewFalcoSidekickListener(
	addr string,
	tarianServerAddress string,
	opts []grpc.DialOption,
	informers informers.SharedInformerFactory,
	configCache *ConfigCache,
	actionHandler *actionHandler) *FalcoSidekickListener