odc

package
v1.42.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 21, 2025 License: GPL-3.0 Imports: 37 Imported by: 0

Documentation

Overview

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

Index

Constants

View Source 
const (
	ODC_DIAL_TIMEOUT                = 2 * time.Second
	ODC_GENERAL_OP_TIMEOUT          = 5 * time.Second
	ODC_CONFIGURE_TIMEOUT           = 60 * time.Second
	ODC_PARTITIONINITIALIZE_TIMEOUT = 60 * time.Second
	ODC_START_TIMEOUT               = 15 * time.Second
	ODC_STOP_TIMEOUT                = 15 * time.Second
	ODC_RESET_TIMEOUT               = 30 * time.Second
	ODC_PARTITIONTERMINATE_TIMEOUT  = 30 * time.Second
	ODC_PADDING_TIMEOUT             = 3 * time.Second
	ODC_STATUS_TIMEOUT              = 3 * time.Second
	ODC_POLLING_INTERVAL            = 3 * time.Second
	ODC_MAX_INBOUND_MESSAGE_SIZE    = 32 * 1024 * 1024 // 16 MiB
	TOPIC                           = topic.IntegratedService + topic.Separator + "odc"
)
View Source 
const ODC_ERROR_MAX_LENGTH = 250

Variables

This section is empty.

Functions

func NewPlugin 

func NewPlugin(endpoint string) integration.Plugin

Types

type OdcDevice added in v0.71.0 

type OdcDevice struct {
	TaskId     string   `json:"taskId"`
	State      string   `json:"state"`
	EcsState   sm.State `json:"ecsState"`
	Path       string   `json:"path"`
	Ignored    bool     `json:"ignored"`
	Host       string   `json:"host"`
	Expendable bool     `json:"expendable"`
	Rmsjobid   string   `json:"rmsjobid"`
}

type OdcDeviceId added in v1.12.0 

type OdcDeviceId uint64

func (OdcDeviceId) MarshalJSON added in v1.12.0 

func (o OdcDeviceId) MarshalJSON() ([]byte, error)

type OdcPartitionInfo added in v0.38.0 

type OdcPartitionInfo struct {
	PartitionId      uid.ID                     `json:"-"`
	RunNumber        uint32                     `json:"runNumber"`
	State            string                     `json:"state"`
	EcsState         sm.State                   `json:"ecsState"`
	DdsSessionId     string                     `json:"ddsSessionId"`
	DdsSessionStatus string                     `json:"ddsSessionStatus"`
	Devices          map[OdcDeviceId]*OdcDevice `json:"devices"`
	Hosts            []string                   `json:"hosts"`
}

type OdcStatus added in v0.38.0 

type OdcStatus struct {
	Partitions map[uid.ID]*OdcPartitionInfo
	Status     odc.ReplyStatus
	Message    string
	Error      *odc.Error
}

type Plugin 

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

func (*Plugin) CallStack added in v0.29.0 

func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{})

func (*Plugin) Destroy 

func (p *Plugin) Destroy() error

func (*Plugin) GetConnectionState added in v0.22.80 

func (p *Plugin) GetConnectionState() string

func (*Plugin) GetData added in v0.22.80 

func (p *Plugin) GetData(_ []any) string

func (*Plugin) GetEndpoint added in v0.22.80 

func (p *Plugin) GetEndpoint() string

func (*Plugin) GetEnvironmentsData added in v0.56.0 

func (p *Plugin) GetEnvironmentsData(envIds []uid.ID) map[uid.ID]string

func (*Plugin) GetEnvironmentsShortData added in v0.79.0 

func (p *Plugin) GetEnvironmentsShortData(envIds []uid.ID) map[uid.ID]string

func (*Plugin) GetName 

func (p *Plugin) GetName() string

func (*Plugin) GetPrettyName added in v0.22.80 

func (p *Plugin) GetPrettyName() string

func (*Plugin) Init 

func (p *Plugin) Init(_ string) error

func (*Plugin) ObjectStack 

func (p *Plugin) ObjectStack(varStack map[string]string, baseConfigStack map[string]string) (stack map[string]interface{})

type RpcClient 

type RpcClient struct {
	odcpb.ODCClient
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(cxt context.Context, cancel context.CancelFunc, endpoint string) *RpcClient

func (*RpcClient) Close 

func (m *RpcClient) Close() error

func (*RpcClient) GetConnState 

func (m *RpcClient) GetConnState() connectivity.State

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.