Documentation
¶
Overview ¶
Package clusteragent provides tarian cluster agent functionality
Index ¶
- func SetLogger(l *zap.SugaredLogger)
- type ActionHandler
- type ClusterAgent
- type ClusterAgentConfig
- type ConfigCache
- type 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
- type FalcoSidekickListener
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SetLogger ¶
func SetLogger(l *zap.SugaredLogger)
Types ¶
type ActionHandler ¶
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 ¶ added in v0.0.8
type FalcoSidekickListener struct {
// contains filtered or unexported fields
}
func NewFalcoSidekickListener ¶ added in v0.0.8
func NewFalcoSidekickListener( addr string, tarianServerAddress string, opts []grpc.DialOption, informers informers.SharedInformerFactory, configCache *ConfigCache, actionHandler *actionHandler) *FalcoSidekickListener
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
Package webhookserver provides kubernetes admission webhook server
|
Package webhookserver provides kubernetes admission webhook server |
Click to show internal directories.
Click to hide internal directories.