Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions apricot/apricot.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package apricot implements the ALICE configuration service with templating,
// load balancing and caching capabilities on top of the configuration store.
package apricot

import (
Expand Down
2 changes: 2 additions & 0 deletions apricot/cacheproxy/service.go
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
// Package cacheproxy provides a caching proxy implementation for the
// configuration service, optimizing detector inventory lookups.
package cacheproxy

import (
Expand Down
2 changes: 2 additions & 0 deletions apricot/local/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package local implements a local configuration backend for the configuration
// service, providing direct access to the backend storage without gRPC.
package local

import (
Expand Down
2 changes: 2 additions & 0 deletions apricot/remote/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package remote implements a remote configuration backend for the configuration
// service, accessing configuration handled by a different application via gRPC.
package remote

import (
Expand Down
2 changes: 2 additions & 0 deletions coconut/app/constants.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package app provides application constants and metadata for the coconut
// command line interface and its components.
package app

const (
Expand Down
2 changes: 2 additions & 0 deletions coconut/cmd/environment.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,8 @@

//go:generate protoc -I=../../core -I=../../common --go_out=.. --go_opt=paths=source_relative --go-grpc_opt=paths=source_relative --go-grpc_out=require_unimplemented_servers=false:.. protos/o2control.proto

// Package cmd implements the command line interface for coconut, providing
// various subcommands for managing O² Control environments and configurations.
package cmd

import (
Expand Down
1 change: 1 addition & 0 deletions common/event/topic/topic.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package topic defines constants and types for event system topics.
package topic

type Topic string
Expand Down
2 changes: 2 additions & 0 deletions common/event/writer.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package event provides event publishing and streaming functionality for
// O² Control components, supporting Kafka and dummy event writers.
package event

import (
Expand Down
2 changes: 2 additions & 0 deletions common/golangmetrics/metrics.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package golangmetrics provides Go runtime metrics collection and reporting
// functionality for monitoring system resource usage and performance.
package golangmetrics

import (
Expand Down
2 changes: 2 additions & 0 deletions common/logger/infologger/protocols.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package infologger provides InfoLogger protocol implementation for
// integration with the ALICE InfoLogger logging system.
package infologger

type protoVersion string
Expand Down
2 changes: 2 additions & 0 deletions common/monitoring/monitoring.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package monitoring provides monitoring and metrics collection functionality
// for O² Control components.
package monitoring

import (
Expand Down
2 changes: 2 additions & 0 deletions common/product/constants.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package product provides version information and build metadata for
// O² Control products and components.
package product

import (
Expand Down
2 changes: 2 additions & 0 deletions common/utils/safeacks/safeacks.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package safeacks provides thread-safe acknowledgment handling for managing
// communication between multiple senders and a single receiver.
package safeacks

import (
Expand Down
1 change: 1 addition & 0 deletions common/utils/uid/uid.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package uid provides unique identifier generation functionality.
package uid

import (
Expand Down
2 changes: 2 additions & 0 deletions common/utils/utils.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package utils provides common utility functions for string manipulation,
// data conversion, and various helper operations used across O² Control components.
package utils

import (
Expand Down
2 changes: 2 additions & 0 deletions configuration/componentcfg/componentcfg.go
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package componentcfg provides component configuration management functionality,
// including query handling and template processing for O² components.
package componentcfg

import (
Expand Down
2 changes: 2 additions & 0 deletions configuration/service.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package configuration provides interfaces and implementations for managing
// runtime configuration of O² Control components and detectors.
package configuration

import (
Expand Down
2 changes: 2 additions & 0 deletions configuration/template/fields.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package template provides template processing functionality for configuration
// files, including custom field handling and template execution.
package template

import (
Expand Down
2 changes: 2 additions & 0 deletions core/core.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package core implements the main AliECS core functionality including
// the gRPC API server, environment management, and integration with various services.
package core

import (
Expand Down
2 changes: 2 additions & 0 deletions core/integration/bookkeeping/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,8 @@
//go:generate protoc --go_out=. --go_opt=paths=source_relative --go-grpc_opt=paths=source_relative --go-grpc_out=require_unimplemented_servers=false:. protos/run.proto
//go:generate protoc --go_out=. --go_opt=paths=source_relative --go-grpc_opt=paths=source_relative --go-grpc_out=require_unimplemented_servers=false:. protos/lhcFill.proto

// Package bookkeeping provides integration with the ALICE Bookkeeping system
// for tracking runs and retrieving LHC fill information.
package bookkeeping

import (
Expand Down
2 changes: 2 additions & 0 deletions core/integration/ccdb/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package ccdb provides integration with the Condition and Calibration Database (CCDB)
// for creating and managing General Run Parameters (GRP) objects.
package ccdb

import (
Expand Down
2 changes: 2 additions & 0 deletions core/integration/dcs/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,8 @@

//go:generate protoc --go_out=. --go_opt=paths=source_relative --go-grpc_opt=paths=source_relative --go-grpc_out=require_unimplemented_servers=false:. protos/dcs.proto

// Package dcs provides integration with the ALICE Detector Control System (DCS)
// for managing detector operations and state compatibility checks.
package dcs

import (
Expand Down
2 changes: 2 additions & 0 deletions core/integration/ddsched/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,8 @@

//go:generate protoc --go_out=. --go_opt=paths=source_relative --go-grpc_opt=paths=source_relative --go-grpc_out=require_unimplemented_servers=false:. protos/ddsched.proto

// Package ddsched provides integration with the Data Distribution (DD) scheduler
// for managing the pool of FLPs participating in data taking operations.
package ddsched

import (
Expand Down
2 changes: 2 additions & 0 deletions core/integration/odc/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,6 +24,8 @@

//go:generate protoc --go_out=. --go_opt=paths=source_relative --go-grpc_opt=paths=source_relative --go-grpc_out=require_unimplemented_servers=false:. protos/odc.proto

// Package odc provides integration with the Online Device Control (ODC) system
// for managing the ALICE event processing farm during data taking and offline processing.
package odc

import (
Expand Down
2 changes: 2 additions & 0 deletions core/integration/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package integration provides the plugin system for integrating O² Control
// with external services like DCS, Bookkeeping, ODC, and other ALICE systems.
package integration

import (
Expand Down
2 changes: 2 additions & 0 deletions core/integration/testplugin/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package testplugin provides a test integration plugin that serves as an example
// and is used for testing the plugin system functionality.
package testplugin

import (
Expand Down
1 change: 1 addition & 0 deletions core/integration/trg/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,7 @@

//go:generate protoc --go_out=. --go_opt=paths=source_relative --go-grpc_opt=paths=source_relative --go-grpc_out=require_unimplemented_servers=false:. protos/ctpecs.proto

// Package trg provides integration with the ALICE trigger system.
package trg

import (
Expand Down
1 change: 1 addition & 0 deletions core/integration/trg/trgutil.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package trg provides integration with the ALICE trigger system.
package trg

import (
Expand Down
2 changes: 2 additions & 0 deletions core/repos/sshrepo.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package repos provides repository management functionality for accessing
// and synchronizing Git repositories containing workflow templates and configurations.
package repos

import (
Expand Down
2 changes: 2 additions & 0 deletions core/repos/varsource/varsource.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package varsource provides variable source management functionality for
// tracking the origin and precedence of configuration variables in workflows.
package varsource

type Source int
Expand Down
2 changes: 2 additions & 0 deletions core/task/channel/channel.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package channel provides functionality for managing task communication channels,
// including inbound and outbound channel configuration and message routing.
package channel

import (
Expand Down
2 changes: 2 additions & 0 deletions core/task/schedutil/mesosutil.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package schedutil provides scheduler utility functions for Apache Mesos
// integration, including resource management and task scheduling helpers.
package schedutil

import (
Expand Down
2 changes: 2 additions & 0 deletions core/task/sm/machine.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package sm provides state machine functionality for task lifecycle management,
// including state transitions and event handling.
package sm

type Transition struct {
Expand Down
2 changes: 2 additions & 0 deletions core/task/taskclass/port/range.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package port provides port range management functionality for task
// communication, including port range parsing and validation.
package port

import (
Expand Down
2 changes: 2 additions & 0 deletions core/task/taskclass/resourcelimits.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package taskclass provides task class definitions and resource management
// for different types of tasks.
package taskclass

import "strconv"
Expand Down
2 changes: 2 additions & 0 deletions core/task/taskop/messagetype.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package taskop provides task operation types and message handling functionality
// for controlling task lifecycle and communication.
package taskop

import (
Expand Down
2 changes: 2 additions & 0 deletions core/the/eventwriter.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package the provides global event handling and state management for
// the core system, including event writers and system-wide notifications.
package the

import (
Expand Down
2 changes: 2 additions & 0 deletions core/workflow/callable/utils.go
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
// Package callable provides utility functions for workflow callable operations,
// including timeout handling and trigger expression parsing.
package callable

import (
Expand Down
2 changes: 2 additions & 0 deletions executor/executable/task.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package executable provides platform-specific executable management functionality
// for running and controlling tasks in the executor environment.
package executable

import (
Expand Down
2 changes: 2 additions & 0 deletions executor/executorcmd/nopb/jsoncodec.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package nopb provides non-protobuf encoding functionality including
// JSON codec implementations for gRPC communication.
package nopb

import (
Expand Down
2 changes: 2 additions & 0 deletions executor/executorutil/executorutil.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package executorutil provides utility functions for the executor,
// including resource management and task execution helpers.
package executorutil

import (
Expand Down
2 changes: 2 additions & 0 deletions occ/peanut/peanut.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
* Intergovernmental Organization or submit itself to any jurisdiction.
*/

// Package peanut implements a process execution and control utility for
// OCClib-based O² processes, providing debugging and development support.
package peanut

import (
Expand Down
Loading