dcspb

type ConfiguratorClient interface {
	// Optional call, legal at any time, to subscribe to all future events from
	// the DCS service. The server stops serving the stream when the client closes
	// it. Multiple concurrent stream subscriptions are allowed.
	Subscribe(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (Configurator_SubscribeClient, error)
	// Single PFR request for a data taking session, with per-detector parameters.
	// Returns an event stream which returns subsequent intermediate states within
	// the PFR operation. Upon PFR completion (DetectorState.RUN_OK), the server
	// closes the stream.
	PrepareForRun(ctx context.Context, in *PfrRequest, opts ...grpc.CallOption) (Configurator_PrepareForRunClient, error)
	// Single SOR request for a data taking session, with run number.
	// Returns an event stream which returns subsequent intermediate states within
	// the SOR operation. Upon SOR completion (DetectorState.RUN_OK), the server
	// closes the stream.
	// If the DetectorOperationRequest or run type parameters are the same as the
	// last PrepareForRun request (no matter how far back in time) and the DCS
	// state hasn't changed, the SOR operations should be fast. Otherwise, the SOR
	// also implicitly includes any number of PrepareForRun operations as needed,
	// this can take a while but should not change the overall behavior reported
	// to ECS.
	StartOfRun(ctx context.Context, in *SorRequest, opts ...grpc.CallOption) (Configurator_StartOfRunClient, error)
	// Single EOR request for a data taking session, with per-detector parameters.
	// Returns an event stream which returns subsequent intermediate states within
	// the EOR operation. Upon EOR completion (DetectorState.RUN_OK), the server
	// closes the stream.
	EndOfRun(ctx context.Context, in *EorRequest, opts ...grpc.CallOption) (Configurator_EndOfRunClient, error)
	// Optional call, legal at any time, to query the status of the DCS service
	// and either some or all of its constituent detectors. This call returns a
	// single value (not a stream), reflecting the service state at that
	// specific moment.
	GetStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusReply, error)
}

type ConfiguratorServer interface {
	// Optional call, legal at any time, to subscribe to all future events from
	// the DCS service. The server stops serving the stream when the client closes
	// it. Multiple concurrent stream subscriptions are allowed.
	Subscribe(*SubscriptionRequest, Configurator_SubscribeServer) error
	// Single PFR request for a data taking session, with per-detector parameters.
	// Returns an event stream which returns subsequent intermediate states within
	// the PFR operation. Upon PFR completion (DetectorState.RUN_OK), the server
	// closes the stream.
	PrepareForRun(*PfrRequest, Configurator_PrepareForRunServer) error
	// Single SOR request for a data taking session, with run number.
	// Returns an event stream which returns subsequent intermediate states within
	// the SOR operation. Upon SOR completion (DetectorState.RUN_OK), the server
	// closes the stream.
	// If the DetectorOperationRequest or run type parameters are the same as the
	// last PrepareForRun request (no matter how far back in time) and the DCS
	// state hasn't changed, the SOR operations should be fast. Otherwise, the SOR
	// also implicitly includes any number of PrepareForRun operations as needed,
	// this can take a while but should not change the overall behavior reported
	// to ECS.
	StartOfRun(*SorRequest, Configurator_StartOfRunServer) error
	// Single EOR request for a data taking session, with per-detector parameters.
	// Returns an event stream which returns subsequent intermediate states within
	// the EOR operation. Upon EOR completion (DetectorState.RUN_OK), the server
	// closes the stream.
	EndOfRun(*EorRequest, Configurator_EndOfRunServer) error
	// Optional call, legal at any time, to query the status of the DCS service
	// and either some or all of its constituent detectors. This call returns a
	// single value (not a stream), reflecting the service state at that
	// specific moment.
	GetStatus(context.Context, *StatusRequest) (*StatusReply, error)
}

type Configurator_EndOfRunClient interface {
	Recv() (*RunEvent, error)
	grpc.ClientStream
}

type Configurator_EndOfRunServer interface {
	Send(*RunEvent) error
	grpc.ServerStream
}

type Configurator_PrepareForRunClient interface {
	Recv() (*RunEvent, error)
	grpc.ClientStream
}

type Configurator_PrepareForRunServer interface {
	Send(*RunEvent) error
	grpc.ServerStream
}

type Configurator_StartOfRunClient interface {
	Recv() (*RunEvent, error)
	grpc.ClientStream
}

type Configurator_StartOfRunServer interface {
	Send(*RunEvent) error
	grpc.ServerStream
}

type Configurator_SubscribeClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type Configurator_SubscribeServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type Detector int32

type DetectorInfo struct {
	Detector        Detector      `protobuf:"varint,1,opt,name=detector,proto3,enum=dcs.Detector" json:"detector,omitempty"`                     // 1 detector per DetectorInfo
	State           DetectorState `protobuf:"varint,2,opt,name=state,proto3,enum=dcs.DetectorState" json:"state,omitempty"`                      // state of this detector at the time of response generation
	Timestamp       string        `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`                                      // time when the detector state is as declared
	AllowedRunTypes []RunType     `protobuf:"varint,4,rep,packed,name=allowedRunTypes,proto3,enum=dcs.RunType" json:"allowedRunTypes,omitempty"` // a list of run types that are currently
	// possible with the given detector, taking into
	// account all low-level information;
	// for example, at a given moment TECHNICAL
	// runs might be possible but not PHYSICS
	PfrAvailability DetectorState `protobuf:"varint,5,opt,name=pfrAvailability,proto3,enum=dcs.DetectorState" json:"pfrAvailability,omitempty"` // availability of this detector for PFR at the time of response generation
	SorAvailability DetectorState `protobuf:"varint,6,opt,name=sorAvailability,proto3,enum=dcs.DetectorState" json:"sorAvailability,omitempty"` // availability of this detector for SOR at the time of response generation
	// contains filtered or unexported fields
}

type DetectorOperationRequest struct {
	Detector        Detector          `protobuf:"varint,1,opt,name=detector,proto3,enum=dcs.Detector" json:"detector,omitempty"`
	ExtraParameters map[string]string `` // detector-specific parameters
	/* 171-byte string literal not displayed */
	// contains filtered or unexported fields
}

type DetectorState int32

type EorRequest struct {
	Detectors []*DetectorOperationRequest `protobuf:"bytes,1,rep,name=detectors,proto3" json:"detectors,omitempty"`
	RunNumber int32                       `protobuf:"varint,2,opt,name=runNumber,proto3" json:"runNumber,omitempty"`
	// contains filtered or unexported fields
}

type Event struct {
	Eventtype      EventType       `protobuf:"varint,1,opt,name=eventtype,proto3,enum=dcs.EventType" json:"eventtype,omitempty"` // type of event being published by the DCS service
	DetectorMatrix []*DetectorInfo `protobuf:"bytes,2,rep,name=detectorMatrix,proto3" json:"detectorMatrix,omitempty"`           // detector-specific status payloads (optional depending
	// on event type)
	ExtraParameters map[string]string `` // general key-value map just in case
	/* 171-byte string literal not displayed */
	Timestamp string `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // this corresponds to the moment where this Event-answer
	// was valid from the source
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"` // optional user-facing error message, if the DCS wants to
	// contains filtered or unexported fields
}

type EventType int32

type PfrRequest struct {
	Detectors   []*DetectorOperationRequest `protobuf:"bytes,1,rep,name=detectors,proto3" json:"detectors,omitempty"`
	RunType     RunType                     `protobuf:"varint,2,opt,name=runType,proto3,enum=dcs.RunType" json:"runType,omitempty"` // default: NULL_RUNTYPE, should probably never be sent
	PartitionId string                      `protobuf:"bytes,3,opt,name=partitionId,proto3" json:"partitionId,omitempty"`           // unique id for a pfr request
	// contains filtered or unexported fields
}

type RunEvent struct {
	Eventtype EventType `protobuf:"varint,1,opt,name=eventtype,proto3,enum=dcs.EventType" json:"eventtype,omitempty"` // type of event being published by the DCS service
	Detector  Detector  `protobuf:"varint,2,opt,name=detector,proto3,enum=dcs.Detector" json:"detector,omitempty"`    // if detector==DCS, the update is a pre-closure summary
	// of the current operation
	State DetectorState `protobuf:"varint,3,opt,name=state,proto3,enum=dcs.DetectorState" json:"state,omitempty"` // aggregate state for all detectors involved in current
	// SOR/EOR operation
	ExtraParameters map[string]string `` /* 171-byte string literal not displayed */
	Timestamp       string            `protobuf:"bytes,5,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Message         string            `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"` // optional user-facing error message, if the DCS wants to
	// contains filtered or unexported fields
}

type RunType int32

type SorMode int32

type SorRequest struct {
	Detectors []*DetectorOperationRequest `protobuf:"bytes,1,rep,name=detectors,proto3" json:"detectors,omitempty"`
	RunType   RunType                     `protobuf:"varint,2,opt,name=runType,proto3,enum=dcs.RunType" json:"runType,omitempty"` // default: NULL_RUNTYPE, should probably never be sent
	RunNumber int32                       `protobuf:"varint,3,opt,name=runNumber,proto3" json:"runNumber,omitempty"`
	// contains filtered or unexported fields
}

type StatusReply struct {
	DetectorMatrix []*DetectorInfo `protobuf:"bytes,1,rep,name=detectorMatrix,proto3" json:"detectorMatrix,omitempty"` // an exhaustive list of DetectorInfos
	// contains filtered or unexported fields
}

type StatusRequest struct {
	Detector []Detector `protobuf:"varint,1,rep,packed,name=detector,proto3,enum=dcs.Detector" json:"detector,omitempty"`
	// contains filtered or unexported fields
}

type SubscriptionRequest struct {
	InstanceId string `protobuf:"bytes,1,opt,name=instanceId,proto3" json:"instanceId,omitempty"`
	// contains filtered or unexported fields
}

type TriggerMode int32

type UnimplementedConfiguratorServer struct {
}

type UnsafeConfiguratorServer interface {
	// contains filtered or unexported methods
}