Documentation
¶
Index ¶
- Variables
- func RegisterConfiguratorServer(s grpc.ServiceRegistrar, srv ConfiguratorServer)
- type ConfiguratorClient
- type ConfiguratorServer
- type Configurator_EndOfRunClient
- type Configurator_EndOfRunServer
- type Configurator_GetStatusClient
- type Configurator_GetStatusServer
- type Configurator_StartOfRunClient
- type Configurator_StartOfRunServer
- type Configurator_SubscribeClient
- type Configurator_SubscribeServer
- type Detector
- type DetectorInfo
- func (*DetectorInfo) Descriptor() ([]byte, []int)deprecated
- func (x *DetectorInfo) GetDetector() Detector
- func (x *DetectorInfo) GetState() DetectorState
- func (x *DetectorInfo) GetTimestamp() string
- func (*DetectorInfo) ProtoMessage()
- func (x *DetectorInfo) ProtoReflect() protoreflect.Message
- func (x *DetectorInfo) Reset()
- func (x *DetectorInfo) String() string
- type DetectorState
- func (DetectorState) Descriptor() protoreflect.EnumDescriptor
- func (x DetectorState) Enum() *DetectorState
- func (DetectorState) EnumDescriptor() ([]byte, []int)deprecated
- func (x DetectorState) Number() protoreflect.EnumNumber
- func (x DetectorState) String() string
- func (DetectorState) Type() protoreflect.EnumType
- type EorRequest
- func (*EorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EorRequest) GetDetector() []Detector
- func (x *EorRequest) GetParameters() map[string]string
- func (x *EorRequest) GetRunNumber() int32
- func (*EorRequest) ProtoMessage()
- func (x *EorRequest) ProtoReflect() protoreflect.Message
- func (x *EorRequest) Reset()
- func (x *EorRequest) String() string
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetDetector() Detector
- func (x *Event) GetEventtype() EventType
- func (x *Event) GetParameters() string
- func (x *Event) GetTimestamp() string
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type EventType
- type RunType
- type SorRequest
- func (*SorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SorRequest) GetDetector() []Detector
- func (x *SorRequest) GetParameters() map[string]string
- func (x *SorRequest) GetRunNumber() int32
- func (x *SorRequest) GetRunType() RunType
- func (*SorRequest) ProtoMessage()
- func (x *SorRequest) ProtoReflect() protoreflect.Message
- func (x *SorRequest) Reset()
- func (x *SorRequest) String() string
- type StatusReply
- func (*StatusReply) Descriptor() ([]byte, []int)deprecated
- func (x *StatusReply) GetDetector() Detector
- func (x *StatusReply) GetState() DetectorState
- func (x *StatusReply) GetTimestamp() string
- func (*StatusReply) ProtoMessage()
- func (x *StatusReply) ProtoReflect() protoreflect.Message
- func (x *StatusReply) Reset()
- func (x *StatusReply) String() string
- type StatusRequest
- type SubscriptionRequest
- func (*SubscriptionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionRequest) GetInstanceId() string
- func (*SubscriptionRequest) ProtoMessage()
- func (x *SubscriptionRequest) ProtoReflect() protoreflect.Message
- func (x *SubscriptionRequest) Reset()
- func (x *SubscriptionRequest) String() string
- type TriggerMode
- func (TriggerMode) Descriptor() protoreflect.EnumDescriptor
- func (x TriggerMode) Enum() *TriggerMode
- func (TriggerMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x TriggerMode) Number() protoreflect.EnumNumber
- func (x TriggerMode) String() string
- func (TriggerMode) Type() protoreflect.EnumType
- type UnimplementedConfiguratorServer
- func (UnimplementedConfiguratorServer) EndOfRun(*EorRequest, Configurator_EndOfRunServer) error
- func (UnimplementedConfiguratorServer) GetStatus(*StatusRequest, Configurator_GetStatusServer) error
- func (UnimplementedConfiguratorServer) StartOfRun(*SorRequest, Configurator_StartOfRunServer) error
- func (UnimplementedConfiguratorServer) Subscribe(*SubscriptionRequest, Configurator_SubscribeServer) error
- type UnsafeConfiguratorServer
Constants ¶
This section is empty.
Variables ¶
var ( EventType_name = map[int32]string{ 0: "NULL_EVENT", 1: "HEARTBEAT", 2: "STATE_CHANGE_EVENT", 3: "ERROR_EVENT", 4: "ACK_EVENT", 20: "SOR_EVENT", 30: "EOR_EVENT", 40: "TIMEOUT", } EventType_value = map[string]int32{ "NULL_EVENT": 0, "HEARTBEAT": 1, "STATE_CHANGE_EVENT": 2, "ERROR_EVENT": 3, "ACK_EVENT": 4, "SOR_EVENT": 20, "EOR_EVENT": 30, "TIMEOUT": 40, } )
Enum value maps for EventType.
var ( Detector_name = map[int32]string{ 0: "NULL_DETECTOR", 1: "CPV", 2: "EMC", 3: "FDD", 4: "FT0", 5: "FV0", 6: "ITS", 7: "HMP", 8: "MCH", 9: "MFT", 10: "MID", 11: "PHS", 12: "TOF", 13: "TPC", 14: "TRD", 15: "ZDC", 16: "LHC", 17: "DCS", } Detector_value = map[string]int32{ "NULL_DETECTOR": 0, "CPV": 1, "EMC": 2, "FDD": 3, "FT0": 4, "FV0": 5, "ITS": 6, "HMP": 7, "MCH": 8, "MFT": 9, "MID": 10, "PHS": 11, "TOF": 12, "TPC": 13, "TRD": 14, "ZDC": 15, "LHC": 16, "DCS": 17, } )
Enum value maps for Detector.
var ( DetectorState_name = map[int32]string{ 0: "NULL_STATE", 1: "READY", 2: "RUN_OK", 3: "RUN_FAILURE", 4: "RUN_INHIBIT", 5: "SOR_PROGRESSING", 6: "EOR_PROGRESSING", 7: "SOR_FAILURE", 8: "EOR_FAILURE", 9: "ERROR", 10: "DEAD", } DetectorState_value = map[string]int32{ "NULL_STATE": 0, "READY": 1, "RUN_OK": 2, "RUN_FAILURE": 3, "RUN_INHIBIT": 4, "SOR_PROGRESSING": 5, "EOR_PROGRESSING": 6, "SOR_FAILURE": 7, "EOR_FAILURE": 8, "ERROR": 9, "DEAD": 10, } )
Enum value maps for DetectorState.
var ( RunType_name = map[int32]string{ 0: "NULL_RUNTYPE", 1: "PHYSICS", 2: "TECHNICAL", 3: "PEDESTALS", 4: "PULSER", } RunType_value = map[string]int32{ "NULL_RUNTYPE": 0, "PHYSICS": 1, "TECHNICAL": 2, "PEDESTALS": 3, "PULSER": 4, } )
Enum value maps for RunType.
var ( TriggerMode_name = map[int32]string{ 0: "CONTINUOUS", 1: "TRIGGERED", } TriggerMode_value = map[string]int32{ "CONTINUOUS": 0, "TRIGGERED": 1, } )
Enum value maps for TriggerMode.
var File_protos_dcs_proto protoreflect.FileDescriptor
Functions ¶
func RegisterConfiguratorServer ¶
func RegisterConfiguratorServer(s grpc.ServiceRegistrar, srv ConfiguratorServer)
Types ¶
type ConfiguratorClient ¶
type ConfiguratorClient interface { Subscribe(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (Configurator_SubscribeClient, error) StartOfRun(ctx context.Context, in *SorRequest, opts ...grpc.CallOption) (Configurator_StartOfRunClient, error) EndOfRun(ctx context.Context, in *EorRequest, opts ...grpc.CallOption) (Configurator_EndOfRunClient, error) GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (Configurator_GetStatusClient, error) }
ConfiguratorClient is the client API for Configurator service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewConfiguratorClient ¶
func NewConfiguratorClient(cc grpc.ClientConnInterface) ConfiguratorClient
type ConfiguratorServer ¶
type ConfiguratorServer interface { Subscribe(*SubscriptionRequest, Configurator_SubscribeServer) error StartOfRun(*SorRequest, Configurator_StartOfRunServer) error EndOfRun(*EorRequest, Configurator_EndOfRunServer) error GetStatus(*StatusRequest, Configurator_GetStatusServer) error }
ConfiguratorServer is the server API for Configurator service. All implementations should embed UnimplementedConfiguratorServer for forward compatibility
type Configurator_EndOfRunClient ¶ added in v0.22.0
type Configurator_EndOfRunClient interface { Recv() (*Event, error) grpc.ClientStream }
type Configurator_EndOfRunServer ¶ added in v0.22.0
type Configurator_EndOfRunServer interface { Send(*Event) error grpc.ServerStream }
type Configurator_GetStatusClient ¶ added in v0.22.0
type Configurator_GetStatusClient interface { Recv() (*StatusReply, error) grpc.ClientStream }
type Configurator_GetStatusServer ¶ added in v0.22.0
type Configurator_GetStatusServer interface { Send(*StatusReply) error grpc.ServerStream }
type Configurator_StartOfRunClient ¶ added in v0.22.0
type Configurator_StartOfRunClient interface { Recv() (*Event, error) grpc.ClientStream }
type Configurator_StartOfRunServer ¶ added in v0.22.0
type Configurator_StartOfRunServer interface { Send(*Event) error grpc.ServerStream }
type Configurator_SubscribeClient ¶
type Configurator_SubscribeClient interface { Recv() (*Event, error) grpc.ClientStream }
type Configurator_SubscribeServer ¶
type Configurator_SubscribeServer interface { Send(*Event) error grpc.ServerStream }
type Detector ¶
type Detector int32
const ( Detector_NULL_DETECTOR Detector = 0 Detector_CPV Detector = 1 Detector_EMC Detector = 2 Detector_FDD Detector = 3 Detector_FT0 Detector = 4 Detector_FV0 Detector = 5 Detector_ITS Detector = 6 Detector_HMP Detector = 7 Detector_MCH Detector = 8 Detector_MFT Detector = 9 Detector_MID Detector = 10 Detector_PHS Detector = 11 Detector_TOF Detector = 12 Detector_TPC Detector = 13 Detector_TRD Detector = 14 Detector_ZDC Detector = 15 Detector_LHC Detector = 16 Detector_DCS Detector = 17 )
func (Detector) Descriptor ¶
func (Detector) Descriptor() protoreflect.EnumDescriptor
func (Detector) EnumDescriptor
deprecated
func (Detector) Number ¶
func (x Detector) Number() protoreflect.EnumNumber
func (Detector) Type ¶
func (Detector) Type() protoreflect.EnumType
type DetectorInfo ¶
type DetectorInfo struct { Detector Detector `protobuf:"varint,1,opt,name=detector,proto3,enum=dcs.Detector" json:"detector,omitempty"` State DetectorState `protobuf:"varint,2,opt,name=state,proto3,enum=dcs.DetectorState" json:"state,omitempty"` Timestamp string `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` //repeated RunType allowedRunTypes = 3; //?what is this // contains filtered or unexported fields }
func (*DetectorInfo) Descriptor
deprecated
func (*DetectorInfo) Descriptor() ([]byte, []int)
Deprecated: Use DetectorInfo.ProtoReflect.Descriptor instead.
func (*DetectorInfo) GetDetector ¶
func (x *DetectorInfo) GetDetector() Detector
func (*DetectorInfo) GetState ¶
func (x *DetectorInfo) GetState() DetectorState
func (*DetectorInfo) GetTimestamp ¶
func (x *DetectorInfo) GetTimestamp() string
func (*DetectorInfo) ProtoMessage ¶
func (*DetectorInfo) ProtoMessage()
func (*DetectorInfo) ProtoReflect ¶
func (x *DetectorInfo) ProtoReflect() protoreflect.Message
func (*DetectorInfo) Reset ¶
func (x *DetectorInfo) Reset()
func (*DetectorInfo) String ¶
func (x *DetectorInfo) String() string
type DetectorState ¶
type DetectorState int32
const ( DetectorState_NULL_STATE DetectorState = 0 DetectorState_READY DetectorState = 1 DetectorState_RUN_OK DetectorState = 2 DetectorState_RUN_FAILURE DetectorState = 3 DetectorState_RUN_INHIBIT DetectorState = 4 DetectorState_SOR_PROGRESSING DetectorState = 5 DetectorState_EOR_PROGRESSING DetectorState = 6 DetectorState_SOR_FAILURE DetectorState = 7 DetectorState_EOR_FAILURE DetectorState = 8 DetectorState_ERROR DetectorState = 9 DetectorState_DEAD DetectorState = 10 )
func (DetectorState) Descriptor ¶
func (DetectorState) Descriptor() protoreflect.EnumDescriptor
func (DetectorState) Enum ¶
func (x DetectorState) Enum() *DetectorState
func (DetectorState) EnumDescriptor
deprecated
func (DetectorState) EnumDescriptor() ([]byte, []int)
Deprecated: Use DetectorState.Descriptor instead.
func (DetectorState) Number ¶
func (x DetectorState) Number() protoreflect.EnumNumber
func (DetectorState) String ¶
func (x DetectorState) String() string
func (DetectorState) Type ¶
func (DetectorState) Type() protoreflect.EnumType
type EorRequest ¶
type EorRequest struct { Detector []Detector `protobuf:"varint,1,rep,packed,name=detector,proto3,enum=dcs.Detector" json:"detector,omitempty"` // or repeated Detector detectors = 1; if we want to allow multiple detectors per EOR command RunNumber int32 `protobuf:"varint,2,opt,name=runNumber,proto3" json:"runNumber,omitempty"` Parameters map[string]string `` // does EOR need other params? /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
func (*EorRequest) Descriptor
deprecated
func (*EorRequest) Descriptor() ([]byte, []int)
Deprecated: Use EorRequest.ProtoReflect.Descriptor instead.
func (*EorRequest) GetDetector ¶
func (x *EorRequest) GetDetector() []Detector
func (*EorRequest) GetParameters ¶
func (x *EorRequest) GetParameters() map[string]string
func (*EorRequest) GetRunNumber ¶
func (x *EorRequest) GetRunNumber() int32
func (*EorRequest) ProtoMessage ¶
func (*EorRequest) ProtoMessage()
func (*EorRequest) ProtoReflect ¶
func (x *EorRequest) ProtoReflect() protoreflect.Message
func (*EorRequest) Reset ¶
func (x *EorRequest) Reset()
func (*EorRequest) String ¶
func (x *EorRequest) String() string
type Event ¶
type Event struct { Eventtype EventType `protobuf:"varint,1,opt,name=eventtype,proto3,enum=dcs.EventType" json:"eventtype,omitempty"` Detector Detector `protobuf:"varint,2,opt,name=detector,proto3,enum=dcs.Detector" json:"detector,omitempty"` Parameters string `protobuf:"bytes,3,opt,name=parameters,proto3" json:"parameters,omitempty"` Timestamp string `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
func (*Event) GetDetector ¶
func (*Event) GetEventtype ¶
func (*Event) GetParameters ¶
func (*Event) GetTimestamp ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type EventType ¶
type EventType int32
func (EventType) Descriptor ¶
func (EventType) Descriptor() protoreflect.EnumDescriptor
func (EventType) EnumDescriptor
deprecated
func (EventType) Number ¶
func (x EventType) Number() protoreflect.EnumNumber
func (EventType) Type ¶
func (EventType) Type() protoreflect.EnumType
type RunType ¶
type RunType int32
func (RunType) Descriptor ¶
func (RunType) Descriptor() protoreflect.EnumDescriptor
func (RunType) EnumDescriptor
deprecated
func (RunType) Number ¶
func (x RunType) Number() protoreflect.EnumNumber
func (RunType) Type ¶
func (RunType) Type() protoreflect.EnumType
type SorRequest ¶
type SorRequest struct { Detector []Detector `protobuf:"varint,1,rep,packed,name=detector,proto3,enum=dcs.Detector" json:"detector,omitempty"` // or repeated Detector detectors = 1; if we want to allow multiple detectors per SOR command RunType RunType `protobuf:"varint,2,opt,name=runType,proto3,enum=dcs.RunType" json:"runType,omitempty"` RunNumber int32 `protobuf:"varint,3,opt,name=runNumber,proto3" json:"runNumber,omitempty"` //TriggerMode triggerMode = 4 // this is missing, but can be in the parameters Parameters map[string]string `` // this can be a map or something strongly typed as we figure it out /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
func (*SorRequest) Descriptor
deprecated
func (*SorRequest) Descriptor() ([]byte, []int)
Deprecated: Use SorRequest.ProtoReflect.Descriptor instead.
func (*SorRequest) GetDetector ¶
func (x *SorRequest) GetDetector() []Detector
func (*SorRequest) GetParameters ¶
func (x *SorRequest) GetParameters() map[string]string
func (*SorRequest) GetRunNumber ¶
func (x *SorRequest) GetRunNumber() int32
func (*SorRequest) GetRunType ¶
func (x *SorRequest) GetRunType() RunType
func (*SorRequest) ProtoMessage ¶
func (*SorRequest) ProtoMessage()
func (*SorRequest) ProtoReflect ¶
func (x *SorRequest) ProtoReflect() protoreflect.Message
func (*SorRequest) Reset ¶
func (x *SorRequest) Reset()
func (*SorRequest) String ¶
func (x *SorRequest) String() string
type StatusReply ¶
type StatusReply struct { //repeated DetectorInfo detectorMatrix = 1; Detector Detector `protobuf:"varint,1,opt,name=detector,proto3,enum=dcs.Detector" json:"detector,omitempty"` State DetectorState `protobuf:"varint,2,opt,name=state,proto3,enum=dcs.DetectorState" json:"state,omitempty"` Timestamp string `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` //repeated RunType allowedRunTypes = 3; //? // contains filtered or unexported fields }
func (*StatusReply) Descriptor
deprecated
func (*StatusReply) Descriptor() ([]byte, []int)
Deprecated: Use StatusReply.ProtoReflect.Descriptor instead.
func (*StatusReply) GetDetector ¶
func (x *StatusReply) GetDetector() Detector
func (*StatusReply) GetState ¶
func (x *StatusReply) GetState() DetectorState
func (*StatusReply) GetTimestamp ¶
func (x *StatusReply) GetTimestamp() string
func (*StatusReply) ProtoMessage ¶
func (*StatusReply) ProtoMessage()
func (*StatusReply) ProtoReflect ¶
func (x *StatusReply) ProtoReflect() protoreflect.Message
func (*StatusReply) Reset ¶
func (x *StatusReply) Reset()
func (*StatusReply) String ¶
func (x *StatusReply) String() string
type StatusRequest ¶
type StatusRequest struct { Detector []Detector `protobuf:"varint,1,rep,packed,name=detector,proto3,enum=dcs.Detector" json:"detector,omitempty"` // contains filtered or unexported fields }
func (*StatusRequest) Descriptor
deprecated
func (*StatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.
func (*StatusRequest) GetDetector ¶
func (x *StatusRequest) GetDetector() []Detector
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) ProtoReflect ¶
func (x *StatusRequest) ProtoReflect() protoreflect.Message
func (*StatusRequest) Reset ¶
func (x *StatusRequest) Reset()
func (*StatusRequest) String ¶
func (x *StatusRequest) String() string
type SubscriptionRequest ¶
type SubscriptionRequest struct { InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"` // contains filtered or unexported fields }
func (*SubscriptionRequest) Descriptor
deprecated
func (*SubscriptionRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscriptionRequest.ProtoReflect.Descriptor instead.
func (*SubscriptionRequest) GetInstanceId ¶
func (x *SubscriptionRequest) GetInstanceId() string
func (*SubscriptionRequest) ProtoMessage ¶
func (*SubscriptionRequest) ProtoMessage()
func (*SubscriptionRequest) ProtoReflect ¶
func (x *SubscriptionRequest) ProtoReflect() protoreflect.Message
func (*SubscriptionRequest) Reset ¶
func (x *SubscriptionRequest) Reset()
func (*SubscriptionRequest) String ¶
func (x *SubscriptionRequest) String() string
type TriggerMode ¶
type TriggerMode int32
const ( TriggerMode_CONTINUOUS TriggerMode = 0 TriggerMode_TRIGGERED TriggerMode = 1 )
func (TriggerMode) Descriptor ¶
func (TriggerMode) Descriptor() protoreflect.EnumDescriptor
func (TriggerMode) Enum ¶
func (x TriggerMode) Enum() *TriggerMode
func (TriggerMode) EnumDescriptor
deprecated
func (TriggerMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use TriggerMode.Descriptor instead.
func (TriggerMode) Number ¶
func (x TriggerMode) Number() protoreflect.EnumNumber
func (TriggerMode) String ¶
func (x TriggerMode) String() string
func (TriggerMode) Type ¶
func (TriggerMode) Type() protoreflect.EnumType
type UnimplementedConfiguratorServer ¶
type UnimplementedConfiguratorServer struct { }
UnimplementedConfiguratorServer should be embedded to have forward compatible implementations.
func (UnimplementedConfiguratorServer) EndOfRun ¶
func (UnimplementedConfiguratorServer) EndOfRun(*EorRequest, Configurator_EndOfRunServer) error
func (UnimplementedConfiguratorServer) GetStatus ¶
func (UnimplementedConfiguratorServer) GetStatus(*StatusRequest, Configurator_GetStatusServer) error
func (UnimplementedConfiguratorServer) StartOfRun ¶
func (UnimplementedConfiguratorServer) StartOfRun(*SorRequest, Configurator_StartOfRunServer) error
func (UnimplementedConfiguratorServer) Subscribe ¶
func (UnimplementedConfiguratorServer) Subscribe(*SubscriptionRequest, Configurator_SubscribeServer) error
type UnsafeConfiguratorServer ¶
type UnsafeConfiguratorServer interface {
// contains filtered or unexported methods
}
UnsafeConfiguratorServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConfiguratorServer will result in compilation errors.