odc

package
v1.8.2 Latest Latest
Warning

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

 Go to latest Published: Apr 11, 2024 License: GPL-3.0 Imports: 33 Imported by: 0

Documentation

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

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"`
	Path    string `json:"path"`
	Ignored bool   `json:"ignored"`
	Host    string `json:"host"`
}

type OdcPartitionInfo added in v0.38.0 

type OdcPartitionInfo struct {
	PartitionId uid.ID `json:"-"`
	RunNumber   uint32 `json:"runNumber"`
	State       string `json:"state"`

	DdsSessionId     string      `json:"ddsSessionId"`
	DdsSessionStatus string      `json:"ddsSessionStatus"`
	Devices          []OdcDevice `json:"devices"`
	Hosts            []string    `json:"hosts"`
	// contains filtered or unexported fields
}

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.