Documentation
¶
Index ¶
Constants ¶
View Source
const ( // DefaultDockerTimeout is the default timeout for Docker operations DefaultDockerTimeout = 30 * time.Second )
Variables ¶
This section is empty.
Functions ¶
func RunWithSignalHandling ¶
func RunWithSignalHandling(ctx context.Context, serviceName string, logLevel string, handler EventHandler) error
RunWithSignalHandling is a convenience function that sets up a complete service lifecycle
Types ¶
type EventHandler ¶
type EventHandler interface {
// HandleInitialScan performs initial processing of existing containers
HandleInitialScan(ctx context.Context) error
// HandleEvent processes a Docker event
HandleEvent(ctx context.Context, event events.Message) error
// GetName returns the service name for logging
GetName() string
// SetDependencies injects Docker client and logger
SetDependencies(client *client.Client, logger *logger.Logger)
}
EventHandler defines the interface for processing Docker events
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service represents a Docker-event-driven service
func NewService ¶
func NewService(ctx context.Context, serviceName string, logLevel string, handler EventHandler) (*Service, error)
NewService creates a new Docker event-driven service
func (*Service) GetDockerClient ¶
GetDockerClient returns the Docker client for use by handlers
Click to show internal directories.
Click to hide internal directories.