odc

Documentation

Index

• Constants
• func NewPlugin(endpoint string) integration.Plugin
• type OdcDevice
• type OdcDeviceId
  • func (o OdcDeviceId) MarshalJSON() ([]byte, error)
• type OdcPartitionInfo
• type OdcStatus
• type Plugin
  • func (p *Plugin) CallStack(data interface{}) (stack map[string]interface{})
  • func (p *Plugin) Destroy() error
  • func (p *Plugin) GetConnectionState() string
  • func (p *Plugin) GetData(_ []any) string
  • func (p *Plugin) GetEndpoint() string
  • func (p *Plugin) GetEnvironmentsData(envIds []uid.ID) map[uid.ID]string
  • func (p *Plugin) GetEnvironmentsShortData(envIds []uid.ID) map[uid.ID]string
  • func (p *Plugin) GetName() string
  • func (p *Plugin) GetPrettyName() string
  • func (p *Plugin) Init(_ string) error
  • func (p *Plugin) ObjectStack(varStack map[string]string, baseConfigStack map[string]string) (stack map[string]interface{})
• type RpcClient
  • func NewClient(cxt context.Context, cancel context.CancelFunc, endpoint string) *RpcClient
  • func (m *RpcClient) Close() error
  • func (m *RpcClient) GetConnState() connectivity.State

Constants

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

const ODC_ERROR_MAX_LENGTH = 250

Functions

func NewPlugin

func NewPlugin(endpoint string) integration.Plugin

Types

type OdcDevice

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"`
}

type OdcDeviceId

type OdcDeviceId uint64

func (OdcDeviceId) MarshalJSON

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

type OdcPartitionInfo

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

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

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

func (*Plugin) Destroy

func (p *Plugin) Destroy() error

func (*Plugin) GetConnectionState

func (p *Plugin) GetConnectionState() string

func (*Plugin) GetData

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

func (*Plugin) GetEndpoint

func (p *Plugin) GetEndpoint() string

func (*Plugin) GetEnvironmentsData

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

func (*Plugin) GetEnvironmentsShortData

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

func (*Plugin) GetName

func (p *Plugin) GetName() string

func (*Plugin) GetPrettyName

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