dcspb

package
v0.24.0 Latest Latest
Warning

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

 Go to latest Published: Jun 15, 2021 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
var (
	TriggerMode_name = map[int32]string{
		0: "CONTINUOUS",
		1: "TRIGGERED",
	}
	TriggerMode_value = map[string]int32{
		"CONTINUOUS": 0,
		"TRIGGERED":  1,
	}
)

Enum value maps for TriggerMode.

View Source 
var Configurator_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dcs.Configurator",
	HandlerType: (*ConfiguratorServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _Configurator_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StartOfRun",
			Handler:       _Configurator_StartOfRun_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "EndOfRun",
			Handler:       _Configurator_EndOfRun_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetStatus",
			Handler:       _Configurator_GetStatus_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "protos/dcs.proto",
}

Configurator_ServiceDesc is the grpc.ServiceDesc for Configurator service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
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) Enum 

func (x Detector) Enum() *Detector

func (Detector) EnumDescriptor deprecated 

func (Detector) EnumDescriptor() ([]byte, []int)

Deprecated: Use Detector.Descriptor instead.

func (Detector) Number 

func (x Detector) Number() protoreflect.EnumNumber

func (Detector) String 

func (x Detector) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetDetector 

func (x *Event) GetDetector() Detector

func (*Event) GetEventtype 

func (x *Event) GetEventtype() EventType

func (*Event) GetParameters 

func (x *Event) GetParameters() string

func (*Event) GetTimestamp 

func (x *Event) GetTimestamp() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

func (x *Event) ProtoReflect() protoreflect.Message

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type EventType 

type EventType int32
const (
	EventType_NULL_EVENT         EventType = 0
	EventType_HEARTBEAT          EventType = 1
	EventType_STATE_CHANGE_EVENT EventType = 2
	EventType_ERROR_EVENT        EventType = 3
	EventType_ACK_EVENT          EventType = 4
	EventType_SOR_EVENT          EventType = 20
	EventType_EOR_EVENT          EventType = 30
	EventType_TIMEOUT            EventType = 40
)

func (EventType) Descriptor 

func (EventType) Descriptor() protoreflect.EnumDescriptor

func (EventType) Enum 

func (x EventType) Enum() *EventType

func (EventType) EnumDescriptor deprecated 

func (EventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use EventType.Descriptor instead.

func (EventType) Number 

func (x EventType) Number() protoreflect.EnumNumber

func (EventType) String 

func (x EventType) String() string

func (EventType) Type 

func (EventType) Type() protoreflect.EnumType

type RunType 

type RunType int32
const (
	RunType_NULL_RUNTYPE RunType = 0
	RunType_PHYSICS      RunType = 1
	RunType_TECHNICAL    RunType = 2
	RunType_PEDESTALS    RunType = 3
	RunType_PULSER       RunType = 4
)

func (RunType) Descriptor 

func (RunType) Descriptor() protoreflect.EnumDescriptor

func (RunType) Enum 

func (x RunType) Enum() *RunType

func (RunType) EnumDescriptor deprecated 

func (RunType) EnumDescriptor() ([]byte, []int)

Deprecated: Use RunType.Descriptor instead.

func (RunType) Number 

func (x RunType) Number() protoreflect.EnumNumber

func (RunType) String 

func (x RunType) String() string

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.

Source Files

View all Source files

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.