bkpb

package
v0.82.1 Latest Latest
Warning

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

Go to latest
Published: Oct 13, 2023 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Detector_name = map[int32]string{
		0:  "DETECTOR_NULL",
		3:  "DETECTOR_TPC",
		4:  "DETECTOR_TRD",
		5:  "DETECTOR_TOF",
		6:  "DETECTOR_HMP",
		7:  "DETECTOR_PHS",
		8:  "DETECTOR_CPV",
		10: "DETECTOR_MCH",
		15: "DETECTOR_ZDC",
		18: "DETECTOR_EMC",
		19: "DETECTOR_TST",
		32: "DETECTOR_ITS",
		33: "DETECTOR_FDD",
		34: "DETECTOR_FT0",
		35: "DETECTOR_FV0",
		36: "DETECTOR_MFT",
		37: "DETECTOR_MID",
	}
	Detector_value = map[string]int32{
		"DETECTOR_NULL": 0,
		"DETECTOR_TPC":  3,
		"DETECTOR_TRD":  4,
		"DETECTOR_TOF":  5,
		"DETECTOR_HMP":  6,
		"DETECTOR_PHS":  7,
		"DETECTOR_CPV":  8,
		"DETECTOR_MCH":  10,
		"DETECTOR_ZDC":  15,
		"DETECTOR_EMC":  18,
		"DETECTOR_TST":  19,
		"DETECTOR_ITS":  32,
		"DETECTOR_FDD":  33,
		"DETECTOR_FT0":  34,
		"DETECTOR_FV0":  35,
		"DETECTOR_MFT":  36,
		"DETECTOR_MID":  37,
	}
)

Enum value maps for Detector.

View Source
var (
	RunQuality_name = map[int32]string{
		0: "RUN_QUALITY_NULL",
		1: "RUN_QUALITY_BAD",
		2: "RUN_QUALITY_GOOD",
		3: "RUN_QUALITY_TEST",
		4: "RUN_QUALITY_NONE",
	}
	RunQuality_value = map[string]int32{
		"RUN_QUALITY_NULL": 0,
		"RUN_QUALITY_BAD":  1,
		"RUN_QUALITY_GOOD": 2,
		"RUN_QUALITY_TEST": 3,
		"RUN_QUALITY_NONE": 4,
	}
)

Enum value maps for RunQuality.

View Source
var (
	RunType_name = map[int32]string{
		0:  "RUN_TYPE_NULL",
		1:  "RUN_TYPE_PHYSICS",
		2:  "RUN_TYPE_TECHNICAL",
		3:  "RUN_TYPE_PEDESTAL",
		4:  "RUN_TYPE_PULSER",
		5:  "RUN_TYPE_LASER",
		6:  "RUN_TYPE_CALIBRATION_ITHR_TUNING",
		7:  "RUN_TYPE_CALIBRATION_VCASN_TUNING",
		8:  "RUN_TYPE_CALIBRATION_THR_SCAN",
		9:  "RUN_TYPE_CALIBRATION_DIGITAL_SCAN",
		10: "RUN_TYPE_CALIBRATION_ANALOG_SCAN",
		11: "RUN_TYPE_CALIBRATION_FHR",
		12: "RUN_TYPE_CALIBRATION_ALPIDE_SCAN",
		13: "RUN_TYPE_CALIBRATION",
		14: "RUN_TYPE_COSMICS",
		15: "RUN_TYPE_SYNTHETIC",
		16: "RUN_TYPE_NOISE",
		17: "RUN_TYPE_CALIBRATION_PULSE_LENGTH",
		18: "RUN_TYPE_CALIBRATION_VRESETD",
	}
	RunType_value = map[string]int32{
		"RUN_TYPE_NULL":                     0,
		"RUN_TYPE_PHYSICS":                  1,
		"RUN_TYPE_TECHNICAL":                2,
		"RUN_TYPE_PEDESTAL":                 3,
		"RUN_TYPE_PULSER":                   4,
		"RUN_TYPE_LASER":                    5,
		"RUN_TYPE_CALIBRATION_ITHR_TUNING":  6,
		"RUN_TYPE_CALIBRATION_VCASN_TUNING": 7,
		"RUN_TYPE_CALIBRATION_THR_SCAN":     8,
		"RUN_TYPE_CALIBRATION_DIGITAL_SCAN": 9,
		"RUN_TYPE_CALIBRATION_ANALOG_SCAN":  10,
		"RUN_TYPE_CALIBRATION_FHR":          11,
		"RUN_TYPE_CALIBRATION_ALPIDE_SCAN":  12,
		"RUN_TYPE_CALIBRATION":              13,
		"RUN_TYPE_COSMICS":                  14,
		"RUN_TYPE_SYNTHETIC":                15,
		"RUN_TYPE_NOISE":                    16,
		"RUN_TYPE_CALIBRATION_PULSE_LENGTH": 17,
		"RUN_TYPE_CALIBRATION_VRESETD":      18,
	}
)

Enum value maps for RunType.

View Source
var (
	LogOrigin_name = map[int32]string{
		0: "LOG_ORIGIN_NULL",
		1: "LOG_ORIGIN_HUMAN",
		2: "LOG_ORIGIN_PROCESS",
	}
	LogOrigin_value = map[string]int32{
		"LOG_ORIGIN_NULL":    0,
		"LOG_ORIGIN_HUMAN":   1,
		"LOG_ORIGIN_PROCESS": 2,
	}
)

Enum value maps for LogOrigin.

View Source
var (
	LogSubtype_name = map[int32]string{
		0: "LOG_SUBTYPE_NULL",
		1: "LOG_SUBTYPE_RUN",
		2: "LOG_SUBTYPE_SUBSYSTEM",
		3: "LOG_SUBTYPE_ANNOUNCEMENT",
		4: "LOG_SUBTYPE_INTERVENTION",
		5: "LOG_SUBTYPE_COMMENT",
	}
	LogSubtype_value = map[string]int32{
		"LOG_SUBTYPE_NULL":         0,
		"LOG_SUBTYPE_RUN":          1,
		"LOG_SUBTYPE_SUBSYSTEM":    2,
		"LOG_SUBTYPE_ANNOUNCEMENT": 3,
		"LOG_SUBTYPE_INTERVENTION": 4,
		"LOG_SUBTYPE_COMMENT":      5,
	}
)

Enum value maps for LogSubtype.

View Source
var (
	RunRelations_name = map[int32]string{
		0: "RUN_RELATIONS_NULL",
		1: "RUN_RELATIONS_LHC_FILL",
	}
	RunRelations_value = map[string]int32{
		"RUN_RELATIONS_NULL":     0,
		"RUN_RELATIONS_LHC_FILL": 1,
	}
)

Enum value maps for RunRelations.

View Source
var EnvironmentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "o2.bookkeeping.EnvironmentService",
	HandlerType: (*EnvironmentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _EnvironmentService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _EnvironmentService_Update_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/environment.proto",
}

EnvironmentService_ServiceDesc is the grpc.ServiceDesc for EnvironmentService 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_common_proto protoreflect.FileDescriptor
View Source
var File_protos_environment_proto protoreflect.FileDescriptor
View Source
var File_protos_flp_proto protoreflect.FileDescriptor
View Source
var File_protos_lhcFill_proto protoreflect.FileDescriptor
View Source
var File_protos_log_proto protoreflect.FileDescriptor
View Source
var File_protos_run_proto protoreflect.FileDescriptor
View Source
var FlpService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "o2.bookkeeping.FlpService",
	HandlerType: (*FlpServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateMany",
			Handler:    _FlpService_CreateMany_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/flp.proto",
}

FlpService_ServiceDesc is the grpc.ServiceDesc for FlpService 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 LhcFillService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "o2.bookkeeping.LhcFillService",
	HandlerType: (*LhcFillServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetLast",
			Handler:    _LhcFillService_GetLast_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/lhcFill.proto",
}

LhcFillService_ServiceDesc is the grpc.ServiceDesc for LhcFillService 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 LogService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "o2.bookkeeping.LogService",
	HandlerType: (*LogServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _LogService_Create_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/log.proto",
}

LogService_ServiceDesc is the grpc.ServiceDesc for LogService 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 RunService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "o2.bookkeeping.RunService",
	HandlerType: (*RunServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _RunService_Get_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _RunService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _RunService_Update_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/run.proto",
}

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

Functions

func RegisterEnvironmentServiceServer

func RegisterEnvironmentServiceServer(s grpc.ServiceRegistrar, srv EnvironmentServiceServer)

func RegisterFlpServiceServer

func RegisterFlpServiceServer(s grpc.ServiceRegistrar, srv FlpServiceServer)

func RegisterLhcFillServiceServer added in v0.70.0

func RegisterLhcFillServiceServer(s grpc.ServiceRegistrar, srv LhcFillServiceServer)

func RegisterLogServiceServer

func RegisterLogServiceServer(s grpc.ServiceRegistrar, srv LogServiceServer)

func RegisterRunServiceServer

func RegisterRunServiceServer(s grpc.ServiceRegistrar, srv RunServiceServer)

Types

type Attachment

type Attachment struct {

	// Unix timestamp when this entity was created.
	CreatedAt    int64  `protobuf:"varint,1,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	Encoding     string `protobuf:"bytes,2,opt,name=encoding,proto3" json:"encoding,omitempty"`
	FileName     string `protobuf:"bytes,3,opt,name=fileName,proto3" json:"fileName,omitempty"`
	Id           int32  `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"`
	LogId        int32  `protobuf:"varint,5,opt,name=logId,proto3" json:"logId,omitempty"`
	MimeType     string `protobuf:"bytes,6,opt,name=mimeType,proto3" json:"mimeType,omitempty"`
	OriginalName string `protobuf:"bytes,7,opt,name=originalName,proto3" json:"originalName,omitempty"`
	Path         string `protobuf:"bytes,8,opt,name=path,proto3" json:"path,omitempty"`
	Size         int32  `protobuf:"varint,9,opt,name=size,proto3" json:"size,omitempty"`
	// Unix timestamp when this entity was created.
	UpdatedAt int64 `protobuf:"varint,10,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	// contains filtered or unexported fields
}

func (*Attachment) Descriptor deprecated

func (*Attachment) Descriptor() ([]byte, []int)

Deprecated: Use Attachment.ProtoReflect.Descriptor instead.

func (*Attachment) GetCreatedAt

func (x *Attachment) GetCreatedAt() int64

func (*Attachment) GetEncoding

func (x *Attachment) GetEncoding() string

func (*Attachment) GetFileName

func (x *Attachment) GetFileName() string

func (*Attachment) GetId

func (x *Attachment) GetId() int32

func (*Attachment) GetLogId

func (x *Attachment) GetLogId() int32

func (*Attachment) GetMimeType

func (x *Attachment) GetMimeType() string

func (*Attachment) GetOriginalName

func (x *Attachment) GetOriginalName() string

func (*Attachment) GetPath

func (x *Attachment) GetPath() string

func (*Attachment) GetSize

func (x *Attachment) GetSize() int32

func (*Attachment) GetUpdatedAt

func (x *Attachment) GetUpdatedAt() int64

func (*Attachment) ProtoMessage

func (*Attachment) ProtoMessage()

func (*Attachment) ProtoReflect

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

func (*Attachment) Reset

func (x *Attachment) Reset()

func (*Attachment) String

func (x *Attachment) String() string

type Detector

type Detector int32
const (
	Detector_DETECTOR_NULL Detector = 0
	Detector_DETECTOR_TPC  Detector = 3
	Detector_DETECTOR_TRD  Detector = 4
	Detector_DETECTOR_TOF  Detector = 5
	Detector_DETECTOR_HMP  Detector = 6
	Detector_DETECTOR_PHS  Detector = 7
	Detector_DETECTOR_CPV  Detector = 8
	Detector_DETECTOR_MCH  Detector = 10
	Detector_DETECTOR_ZDC  Detector = 15
	Detector_DETECTOR_EMC  Detector = 18
	Detector_DETECTOR_TST  Detector = 19
	Detector_DETECTOR_ITS  Detector = 32
	Detector_DETECTOR_FDD  Detector = 33
	Detector_DETECTOR_FT0  Detector = 34
	Detector_DETECTOR_FV0  Detector = 35
	Detector_DETECTOR_MFT  Detector = 36
	Detector_DETECTOR_MID  Detector = 37
)

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

type Environment

type Environment struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Unix timestamp when this entity was created.
	CreatedAt int64 `protobuf:"varint,2,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	// Unix timestamp when this entity was last updated.
	UpdatedAt int64 `protobuf:"varint,3,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	// Unix timestamp when this entity was tore down.
	ToredownAt int64 `protobuf:"varint,4,opt,name=toredownAt,proto3" json:"toredownAt,omitempty"`
	// The status of the environment.
	Status string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	// A message explaining the status or the current state of the environment.
	StatusMessage string `protobuf:"bytes,6,opt,name=statusMessage,proto3" json:"statusMessage,omitempty"`
	// Array of minified Run objects.
	Runs []*Run `protobuf:"bytes,7,rep,name=runs,proto3" json:"runs,omitempty"`
	// contains filtered or unexported fields
}

func (*Environment) Descriptor deprecated

func (*Environment) Descriptor() ([]byte, []int)

Deprecated: Use Environment.ProtoReflect.Descriptor instead.

func (*Environment) GetCreatedAt

func (x *Environment) GetCreatedAt() int64

func (*Environment) GetId

func (x *Environment) GetId() string

func (*Environment) GetRuns

func (x *Environment) GetRuns() []*Run

func (*Environment) GetStatus

func (x *Environment) GetStatus() string

func (*Environment) GetStatusMessage

func (x *Environment) GetStatusMessage() string

func (*Environment) GetToredownAt

func (x *Environment) GetToredownAt() int64

func (*Environment) GetUpdatedAt

func (x *Environment) GetUpdatedAt() int64

func (*Environment) ProtoMessage

func (*Environment) ProtoMessage()

func (*Environment) ProtoReflect

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

func (*Environment) Reset

func (x *Environment) Reset()

func (*Environment) String

func (x *Environment) String() string

type EnvironmentCreationRequest

type EnvironmentCreationRequest struct {
	Id            string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt     *int64  `protobuf:"varint,2,opt,name=createdAt,proto3,oneof" json:"createdAt,omitempty"`
	Status        *string `protobuf:"bytes,3,opt,name=status,proto3,oneof" json:"status,omitempty"`
	StatusMessage *string `protobuf:"bytes,4,opt,name=statusMessage,proto3,oneof" json:"statusMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvironmentCreationRequest) Descriptor deprecated

func (*EnvironmentCreationRequest) Descriptor() ([]byte, []int)

Deprecated: Use EnvironmentCreationRequest.ProtoReflect.Descriptor instead.

func (*EnvironmentCreationRequest) GetCreatedAt

func (x *EnvironmentCreationRequest) GetCreatedAt() int64

func (*EnvironmentCreationRequest) GetId

func (*EnvironmentCreationRequest) GetStatus

func (x *EnvironmentCreationRequest) GetStatus() string

func (*EnvironmentCreationRequest) GetStatusMessage

func (x *EnvironmentCreationRequest) GetStatusMessage() string

func (*EnvironmentCreationRequest) ProtoMessage

func (*EnvironmentCreationRequest) ProtoMessage()

func (*EnvironmentCreationRequest) ProtoReflect

func (*EnvironmentCreationRequest) Reset

func (x *EnvironmentCreationRequest) Reset()

func (*EnvironmentCreationRequest) String

func (x *EnvironmentCreationRequest) String() string

type EnvironmentServiceClient

type EnvironmentServiceClient interface {
	Create(ctx context.Context, in *EnvironmentCreationRequest, opts ...grpc.CallOption) (*Environment, error)
	Update(ctx context.Context, in *EnvironmentUpdateRequest, opts ...grpc.CallOption) (*Environment, error)
}

EnvironmentServiceClient is the client API for EnvironmentService 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.

type EnvironmentServiceServer

type EnvironmentServiceServer interface {
	Create(context.Context, *EnvironmentCreationRequest) (*Environment, error)
	Update(context.Context, *EnvironmentUpdateRequest) (*Environment, error)
}

EnvironmentServiceServer is the server API for EnvironmentService service. All implementations should embed UnimplementedEnvironmentServiceServer for forward compatibility

type EnvironmentUpdateRequest

type EnvironmentUpdateRequest struct {
	Id            string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	ToredownAt    *int64  `protobuf:"varint,2,opt,name=toredownAt,proto3,oneof" json:"toredownAt,omitempty"`
	Status        *string `protobuf:"bytes,3,opt,name=status,proto3,oneof" json:"status,omitempty"`
	StatusMessage *string `protobuf:"bytes,4,opt,name=statusMessage,proto3,oneof" json:"statusMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvironmentUpdateRequest) Descriptor deprecated

func (*EnvironmentUpdateRequest) Descriptor() ([]byte, []int)

Deprecated: Use EnvironmentUpdateRequest.ProtoReflect.Descriptor instead.

func (*EnvironmentUpdateRequest) GetId

func (x *EnvironmentUpdateRequest) GetId() string

func (*EnvironmentUpdateRequest) GetStatus

func (x *EnvironmentUpdateRequest) GetStatus() string

func (*EnvironmentUpdateRequest) GetStatusMessage

func (x *EnvironmentUpdateRequest) GetStatusMessage() string

func (*EnvironmentUpdateRequest) GetToredownAt

func (x *EnvironmentUpdateRequest) GetToredownAt() int64

func (*EnvironmentUpdateRequest) ProtoMessage

func (*EnvironmentUpdateRequest) ProtoMessage()

func (*EnvironmentUpdateRequest) ProtoReflect

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

func (*EnvironmentUpdateRequest) Reset

func (x *EnvironmentUpdateRequest) Reset()

func (*EnvironmentUpdateRequest) String

func (x *EnvironmentUpdateRequest) String() string

type Flp

type Flp struct {
	Id       int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name     string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Unix timestamp when this entity was created.
	CreatedAt int64 `protobuf:"varint,4,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	// Unix timestamp when this entity was last updated.
	UpdatedAt             int64 `protobuf:"varint,5,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	BytesEquipmentReadOut int32 `protobuf:"varint,6,opt,name=bytesEquipmentReadOut,proto3" json:"bytesEquipmentReadOut,omitempty"`
	BytesFairMQReadOut    int32 `protobuf:"varint,7,opt,name=bytesFairMQReadOut,proto3" json:"bytesFairMQReadOut,omitempty"`
	BytesProcessed        int32 `protobuf:"varint,8,opt,name=bytesProcessed,proto3" json:"bytesProcessed,omitempty"`
	BytesRecordingReadOut int32 `protobuf:"varint,9,opt,name=bytesRecordingReadOut,proto3" json:"bytesRecordingReadOut,omitempty"`
	NTimeframes           int32 `protobuf:"varint,10,opt,name=nTimeframes,proto3" json:"nTimeframes,omitempty"`
	// contains filtered or unexported fields
}

func (*Flp) Descriptor deprecated

func (*Flp) Descriptor() ([]byte, []int)

Deprecated: Use Flp.ProtoReflect.Descriptor instead.

func (*Flp) GetBytesEquipmentReadOut

func (x *Flp) GetBytesEquipmentReadOut() int32

func (*Flp) GetBytesFairMQReadOut

func (x *Flp) GetBytesFairMQReadOut() int32

func (*Flp) GetBytesProcessed

func (x *Flp) GetBytesProcessed() int32

func (*Flp) GetBytesRecordingReadOut

func (x *Flp) GetBytesRecordingReadOut() int32

func (*Flp) GetCreatedAt

func (x *Flp) GetCreatedAt() int64

func (*Flp) GetHostname

func (x *Flp) GetHostname() string

func (*Flp) GetId

func (x *Flp) GetId() int32

func (*Flp) GetNTimeframes

func (x *Flp) GetNTimeframes() int32

func (*Flp) GetName

func (x *Flp) GetName() string

func (*Flp) GetUpdatedAt

func (x *Flp) GetUpdatedAt() int64

func (*Flp) ProtoMessage

func (*Flp) ProtoMessage()

func (*Flp) ProtoReflect

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

func (*Flp) Reset

func (x *Flp) Reset()

func (*Flp) String

func (x *Flp) String() string

type FlpCreationRequest

type FlpCreationRequest struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Hostname  string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
	RunNumber *int32 `protobuf:"varint,3,opt,name=runNumber,proto3,oneof" json:"runNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*FlpCreationRequest) Descriptor deprecated

func (*FlpCreationRequest) Descriptor() ([]byte, []int)

Deprecated: Use FlpCreationRequest.ProtoReflect.Descriptor instead.

func (*FlpCreationRequest) GetHostname added in v0.60.0

func (x *FlpCreationRequest) GetHostname() string

func (*FlpCreationRequest) GetName

func (x *FlpCreationRequest) GetName() string

func (*FlpCreationRequest) GetRunNumber

func (x *FlpCreationRequest) GetRunNumber() int32

func (*FlpCreationRequest) ProtoMessage

func (*FlpCreationRequest) ProtoMessage()

func (*FlpCreationRequest) ProtoReflect

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

func (*FlpCreationRequest) Reset

func (x *FlpCreationRequest) Reset()

func (*FlpCreationRequest) String

func (x *FlpCreationRequest) String() string

type FlpList

type FlpList struct {
	Flps []*Flp `protobuf:"bytes,1,rep,name=flps,proto3" json:"flps,omitempty"`
	// contains filtered or unexported fields
}

func (*FlpList) Descriptor deprecated

func (*FlpList) Descriptor() ([]byte, []int)

Deprecated: Use FlpList.ProtoReflect.Descriptor instead.

func (*FlpList) GetFlps

func (x *FlpList) GetFlps() []*Flp

func (*FlpList) ProtoMessage

func (*FlpList) ProtoMessage()

func (*FlpList) ProtoReflect

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

func (*FlpList) Reset

func (x *FlpList) Reset()

func (*FlpList) String

func (x *FlpList) String() string

type FlpServiceClient

type FlpServiceClient interface {
	CreateMany(ctx context.Context, in *ManyFlpsCreationRequest, opts ...grpc.CallOption) (*FlpList, error)
}

FlpServiceClient is the client API for FlpService 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 NewFlpServiceClient

func NewFlpServiceClient(cc grpc.ClientConnInterface) FlpServiceClient

type FlpServiceServer

type FlpServiceServer interface {
	CreateMany(context.Context, *ManyFlpsCreationRequest) (*FlpList, error)
}

FlpServiceServer is the server API for FlpService service. All implementations should embed UnimplementedFlpServiceServer for forward compatibility

type LHCFill added in v0.70.0

type LHCFill struct {
	FillNumber int32 `protobuf:"varint,1,opt,name=fillNumber,proto3" json:"fillNumber,omitempty"`
	// Timestamp of the start of the stable beam (if it applies)
	StableBeamStart *int64 `protobuf:"varint,2,opt,name=stableBeamStart,proto3,oneof" json:"stableBeamStart,omitempty"`
	// Timestamp of the end of the stable beam (if it applies)
	StableBeamEnd *int64 `protobuf:"varint,3,opt,name=stableBeamEnd,proto3,oneof" json:"stableBeamEnd,omitempty"`
	// Duration of the stable beam (if it applies)
	StableBeamDuration *int64 `protobuf:"varint,4,opt,name=stableBeamDuration,proto3,oneof" json:"stableBeamDuration,omitempty"`
	BeamType           string `protobuf:"bytes,5,opt,name=beamType,proto3" json:"beamType,omitempty"`
	FillingSchemeName  string `protobuf:"bytes,6,opt,name=fillingSchemeName,proto3" json:"fillingSchemeName,omitempty"`
	// contains filtered or unexported fields
}

func (*LHCFill) Descriptor deprecated added in v0.70.0

func (*LHCFill) Descriptor() ([]byte, []int)

Deprecated: Use LHCFill.ProtoReflect.Descriptor instead.

func (*LHCFill) GetBeamType added in v0.70.0

func (x *LHCFill) GetBeamType() string

func (*LHCFill) GetFillNumber added in v0.70.0

func (x *LHCFill) GetFillNumber() int32

func (*LHCFill) GetFillingSchemeName added in v0.70.0

func (x *LHCFill) GetFillingSchemeName() string

func (*LHCFill) GetStableBeamDuration added in v0.70.0

func (x *LHCFill) GetStableBeamDuration() int64

func (*LHCFill) GetStableBeamEnd added in v0.70.0

func (x *LHCFill) GetStableBeamEnd() int64

func (*LHCFill) GetStableBeamStart added in v0.70.0

func (x *LHCFill) GetStableBeamStart() int64

func (*LHCFill) ProtoMessage added in v0.70.0

func (*LHCFill) ProtoMessage()

func (*LHCFill) ProtoReflect added in v0.70.0

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

func (*LHCFill) Reset added in v0.70.0

func (x *LHCFill) Reset()

func (*LHCFill) String added in v0.70.0

func (x *LHCFill) String() string

type LastLhcFillFetchRequest added in v0.70.0

type LastLhcFillFetchRequest struct {
	// contains filtered or unexported fields
}

func (*LastLhcFillFetchRequest) Descriptor deprecated added in v0.70.0

func (*LastLhcFillFetchRequest) Descriptor() ([]byte, []int)

Deprecated: Use LastLhcFillFetchRequest.ProtoReflect.Descriptor instead.

func (*LastLhcFillFetchRequest) ProtoMessage added in v0.70.0

func (*LastLhcFillFetchRequest) ProtoMessage()

func (*LastLhcFillFetchRequest) ProtoReflect added in v0.70.0

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

func (*LastLhcFillFetchRequest) Reset added in v0.70.0

func (x *LastLhcFillFetchRequest) Reset()

func (*LastLhcFillFetchRequest) String added in v0.70.0

func (x *LastLhcFillFetchRequest) String() string

type LhcFillServiceClient added in v0.70.0

type LhcFillServiceClient interface {
	GetLast(ctx context.Context, in *LastLhcFillFetchRequest, opts ...grpc.CallOption) (*LhcFillWithRelations, error)
}

LhcFillServiceClient is the client API for LhcFillService 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 NewLhcFillServiceClient added in v0.70.0

func NewLhcFillServiceClient(cc grpc.ClientConnInterface) LhcFillServiceClient

type LhcFillServiceServer added in v0.70.0

type LhcFillServiceServer interface {
	GetLast(context.Context, *LastLhcFillFetchRequest) (*LhcFillWithRelations, error)
}

LhcFillServiceServer is the server API for LhcFillService service. All implementations should embed UnimplementedLhcFillServiceServer for forward compatibility

type LhcFillWithRelations added in v0.70.0

type LhcFillWithRelations struct {
	LhcFill *LHCFill `protobuf:"bytes,1,opt,name=lhcFill,proto3" json:"lhcFill,omitempty"` // For now we do not include relations to LHC fill
	// contains filtered or unexported fields
}

func (*LhcFillWithRelations) Descriptor deprecated added in v0.70.0

func (*LhcFillWithRelations) Descriptor() ([]byte, []int)

Deprecated: Use LhcFillWithRelations.ProtoReflect.Descriptor instead.

func (*LhcFillWithRelations) GetLhcFill added in v0.70.0

func (x *LhcFillWithRelations) GetLhcFill() *LHCFill

func (*LhcFillWithRelations) ProtoMessage added in v0.70.0

func (*LhcFillWithRelations) ProtoMessage()

func (*LhcFillWithRelations) ProtoReflect added in v0.70.0

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

func (*LhcFillWithRelations) Reset added in v0.70.0

func (x *LhcFillWithRelations) Reset()

func (*LhcFillWithRelations) String added in v0.70.0

func (x *LhcFillWithRelations) String() string

type Log

type Log struct {
	Attachments []*Attachment `protobuf:"bytes,1,rep,name=attachments,proto3" json:"attachments,omitempty"`
	Author      *User         `protobuf:"bytes,2,opt,name=author,proto3" json:"author,omitempty"`
	// Unix timestamp when this entity was created.
	CreatedAt   int64      `protobuf:"varint,3,opt,name=CreatedAt,proto3" json:"CreatedAt,omitempty"`
	Id          int32      `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"`
	Origin      *LogOrigin `protobuf:"varint,5,opt,name=origin,proto3,enum=o2.bookkeeping.LogOrigin,oneof" json:"origin,omitempty"`
	ParentLogId int32      `protobuf:"varint,6,opt,name=parentLogId,proto3" json:"parentLogId,omitempty"`
	Replies     int32      `protobuf:"varint,7,opt,name=Replies,proto3" json:"Replies,omitempty"`
	RootLogId   int32      `protobuf:"varint,8,opt,name=rootLogId,proto3" json:"rootLogId,omitempty"`
	// Array of minified Run objects.
	Runs       []*MinimalRun `protobuf:"bytes,9,rep,name=runs,proto3" json:"runs,omitempty"`
	Subsystems []*Subsystem  `protobuf:"bytes,10,rep,name=subsystems,proto3" json:"subsystems,omitempty"`
	Subtype    LogSubtype    `protobuf:"varint,11,opt,name=subtype,proto3,enum=o2.bookkeeping.LogSubtype" json:"subtype,omitempty"`
	Tags       []*Tag        `protobuf:"bytes,12,rep,name=tags,proto3" json:"tags,omitempty"`
	Text       string        `protobuf:"bytes,14,opt,name=text,proto3" json:"text,omitempty"`
	Title      string        `protobuf:"bytes,15,opt,name=title,proto3" json:"title,omitempty"`
	// Unix timestamp when this entity was last updated.
	UpdatedAt int64 `protobuf:"varint,16,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated

func (*Log) Descriptor() ([]byte, []int)

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetAttachments

func (x *Log) GetAttachments() []*Attachment

func (*Log) GetAuthor

func (x *Log) GetAuthor() *User

func (*Log) GetCreatedAt

func (x *Log) GetCreatedAt() int64

func (*Log) GetId

func (x *Log) GetId() int32

func (*Log) GetOrigin

func (x *Log) GetOrigin() LogOrigin

func (*Log) GetParentLogId

func (x *Log) GetParentLogId() int32

func (*Log) GetReplies

func (x *Log) GetReplies() int32

func (*Log) GetRootLogId

func (x *Log) GetRootLogId() int32

func (*Log) GetRuns

func (x *Log) GetRuns() []*MinimalRun

func (*Log) GetSubsystems

func (x *Log) GetSubsystems() []*Subsystem

func (*Log) GetSubtype

func (x *Log) GetSubtype() LogSubtype

func (*Log) GetTags

func (x *Log) GetTags() []*Tag

func (*Log) GetText

func (x *Log) GetText() string

func (*Log) GetTitle

func (x *Log) GetTitle() string

func (*Log) GetUpdatedAt

func (x *Log) GetUpdatedAt() int64

func (*Log) ProtoMessage

func (*Log) ProtoMessage()

func (*Log) ProtoReflect

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

func (*Log) Reset

func (x *Log) Reset()

func (*Log) String

func (x *Log) String() string

type LogCreationRequest

type LogCreationRequest struct {
	Title       string  `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Text        string  `protobuf:"bytes,2,opt,name=text,proto3" json:"text,omitempty"`
	RunNumbers  []int32 `protobuf:"varint,3,rep,packed,name=runNumbers,proto3" json:"runNumbers,omitempty"`
	ParentLogId *int32  `protobuf:"varint,4,opt,name=parentLogId,proto3,oneof" json:"parentLogId,omitempty"`
	// contains filtered or unexported fields
}

func (*LogCreationRequest) Descriptor deprecated

func (*LogCreationRequest) Descriptor() ([]byte, []int)

Deprecated: Use LogCreationRequest.ProtoReflect.Descriptor instead.

func (*LogCreationRequest) GetParentLogId

func (x *LogCreationRequest) GetParentLogId() int32

func (*LogCreationRequest) GetRunNumbers

func (x *LogCreationRequest) GetRunNumbers() []int32

func (*LogCreationRequest) GetText

func (x *LogCreationRequest) GetText() string

func (*LogCreationRequest) GetTitle

func (x *LogCreationRequest) GetTitle() string

func (*LogCreationRequest) ProtoMessage

func (*LogCreationRequest) ProtoMessage()

func (*LogCreationRequest) ProtoReflect

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

func (*LogCreationRequest) Reset

func (x *LogCreationRequest) Reset()

func (*LogCreationRequest) String

func (x *LogCreationRequest) String() string

type LogOrigin

type LogOrigin int32
const (
	LogOrigin_LOG_ORIGIN_NULL    LogOrigin = 0
	LogOrigin_LOG_ORIGIN_HUMAN   LogOrigin = 1
	LogOrigin_LOG_ORIGIN_PROCESS LogOrigin = 2
)

func (LogOrigin) Descriptor

func (LogOrigin) Descriptor() protoreflect.EnumDescriptor

func (LogOrigin) Enum

func (x LogOrigin) Enum() *LogOrigin

func (LogOrigin) EnumDescriptor deprecated

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

Deprecated: Use LogOrigin.Descriptor instead.

func (LogOrigin) Number

func (x LogOrigin) Number() protoreflect.EnumNumber

func (LogOrigin) String

func (x LogOrigin) String() string

func (LogOrigin) Type

type LogServiceClient

type LogServiceClient interface {
	Create(ctx context.Context, in *LogCreationRequest, opts ...grpc.CallOption) (*Log, error)
}

LogServiceClient is the client API for LogService 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 NewLogServiceClient

func NewLogServiceClient(cc grpc.ClientConnInterface) LogServiceClient

type LogServiceServer

type LogServiceServer interface {
	Create(context.Context, *LogCreationRequest) (*Log, error)
}

LogServiceServer is the server API for LogService service. All implementations should embed UnimplementedLogServiceServer for forward compatibility

type LogSubtype

type LogSubtype int32
const (
	LogSubtype_LOG_SUBTYPE_NULL         LogSubtype = 0
	LogSubtype_LOG_SUBTYPE_RUN          LogSubtype = 1
	LogSubtype_LOG_SUBTYPE_SUBSYSTEM    LogSubtype = 2
	LogSubtype_LOG_SUBTYPE_ANNOUNCEMENT LogSubtype = 3
	LogSubtype_LOG_SUBTYPE_INTERVENTION LogSubtype = 4
	LogSubtype_LOG_SUBTYPE_COMMENT      LogSubtype = 5
)

func (LogSubtype) Descriptor

func (LogSubtype) Descriptor() protoreflect.EnumDescriptor

func (LogSubtype) Enum

func (x LogSubtype) Enum() *LogSubtype

func (LogSubtype) EnumDescriptor deprecated

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

Deprecated: Use LogSubtype.Descriptor instead.

func (LogSubtype) Number

func (x LogSubtype) Number() protoreflect.EnumNumber

func (LogSubtype) String

func (x LogSubtype) String() string

func (LogSubtype) Type

type ManyFlpsCreationRequest

type ManyFlpsCreationRequest struct {
	Flps []*FlpCreationRequest `protobuf:"bytes,1,rep,name=flps,proto3" json:"flps,omitempty"`
	// contains filtered or unexported fields
}

func (*ManyFlpsCreationRequest) Descriptor deprecated

func (*ManyFlpsCreationRequest) Descriptor() ([]byte, []int)

Deprecated: Use ManyFlpsCreationRequest.ProtoReflect.Descriptor instead.

func (*ManyFlpsCreationRequest) GetFlps

func (*ManyFlpsCreationRequest) ProtoMessage

func (*ManyFlpsCreationRequest) ProtoMessage()

func (*ManyFlpsCreationRequest) ProtoReflect

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

func (*ManyFlpsCreationRequest) Reset

func (x *ManyFlpsCreationRequest) Reset()

func (*ManyFlpsCreationRequest) String

func (x *ManyFlpsCreationRequest) String() string

type MinimalRun

type MinimalRun struct {
	RunNumber int32 `protobuf:"varint,1,opt,name=runNumber,proto3" json:"runNumber,omitempty"`
	Id        int32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*MinimalRun) Descriptor deprecated

func (*MinimalRun) Descriptor() ([]byte, []int)

Deprecated: Use MinimalRun.ProtoReflect.Descriptor instead.

func (*MinimalRun) GetId

func (x *MinimalRun) GetId() int32

func (*MinimalRun) GetRunNumber

func (x *MinimalRun) GetRunNumber() int32

func (*MinimalRun) ProtoMessage

func (*MinimalRun) ProtoMessage()

func (*MinimalRun) ProtoReflect

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

func (*MinimalRun) Reset

func (x *MinimalRun) Reset()

func (*MinimalRun) String

func (x *MinimalRun) String() string

type Run

type Run struct {
	RunNumber     int32  `protobuf:"varint,1,opt,name=runNumber,proto3" json:"runNumber,omitempty"`
	EnvironmentId string `protobuf:"bytes,2,opt,name=environmentId,proto3" json:"environmentId,omitempty"`
	BytesReadOut  int32  `protobuf:"varint,3,opt,name=bytesReadOut,proto3" json:"bytesReadOut,omitempty"`
	// Unix timestamp when this entity was created
	CreatedAt      int64 `protobuf:"varint,4,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	Id             int32 `protobuf:"varint,5,opt,name=Id,proto3" json:"Id,omitempty"`
	NDetectors     int32 `protobuf:"varint,6,opt,name=nDetectors,proto3" json:"nDetectors,omitempty"`
	NEpns          int32 `protobuf:"varint,7,opt,name=nEpns,proto3" json:"nEpns,omitempty"`
	NFlps          int32 `protobuf:"varint,8,opt,name=nFlps,proto3" json:"nFlps,omitempty"`
	NSubtimeframes int32 `protobuf:"varint,9,opt,name=nSubtimeframes,proto3" json:"nSubtimeframes,omitempty"`
	// Repository hash
	PdpConfigOption string `protobuf:"bytes,10,opt,name=pdpConfigOption,proto3" json:"pdpConfigOption,omitempty"`
	// Library file location of the pdp topology description
	PdpTopologyDescriptionLibraryFile string `protobuf:"bytes,11,opt,name=pdpTopologyDescriptionLibraryFile,proto3" json:"pdpTopologyDescriptionLibraryFile,omitempty"`
	// Parameters given to the pdp workflow
	PdpWorkflowParameters string `protobuf:"bytes,12,opt,name=pdpWorkflowParameters,proto3" json:"pdpWorkflowParameters,omitempty"`
	// Beam type of the pdp
	PdpBeamType string `protobuf:"bytes,13,opt,name=pdpBeamType,proto3" json:"pdpBeamType,omitempty"`
	// Config uri of readout.
	ReadoutCfgUri string     `protobuf:"bytes,14,opt,name=readoutCfgUri,proto3" json:"readoutCfgUri,omitempty"`
	RunQuality    RunQuality `protobuf:"varint,15,opt,name=runQuality,proto3,enum=o2.bookkeeping.RunQuality" json:"runQuality,omitempty"`
	RunType       RunType    `protobuf:"varint,16,opt,name=runType,proto3,enum=o2.bookkeeping.RunType" json:"runType,omitempty"`
	TfbDdMode     string     `protobuf:"bytes,17,opt,name=tfbDdMode,proto3" json:"tfbDdMode,omitempty"`
	TimeO2End     int64      `protobuf:"varint,18,opt,name=timeO2End,proto3" json:"timeO2End,omitempty"`
	TimeO2Start   int64      `protobuf:"varint,19,opt,name=timeO2Start,proto3" json:"timeO2Start,omitempty"`
	TimeTrgEnd    int64      `protobuf:"varint,20,opt,name=timeTrgEnd,proto3" json:"timeTrgEnd,omitempty"`
	TimeTrgStart  int64      `protobuf:"varint,21,opt,name=timeTrgStart,proto3" json:"timeTrgStart,omitempty"`
	// Trigger value
	TriggerValue string `protobuf:"bytes,22,opt,name=triggerValue,proto3" json:"triggerValue,omitempty"`
	// The full name or file location of the odcTopology
	OdcTopologyFullName string     `protobuf:"bytes,23,opt,name=odcTopologyFullName,proto3" json:"odcTopologyFullName,omitempty"`
	DdFlp               bool       `protobuf:"varint,24,opt,name=ddFlp,proto3" json:"ddFlp,omitempty"`
	Dcs                 bool       `protobuf:"varint,25,opt,name=dcs,proto3" json:"dcs,omitempty"`
	Epn                 bool       `protobuf:"varint,26,opt,name=epn,proto3" json:"epn,omitempty"`
	EpnTopology         string     `protobuf:"bytes,27,opt,name=epnTopology,proto3" json:"epnTopology,omitempty"`
	Detectors           []Detector `protobuf:"varint,28,rep,packed,name=detectors,proto3,enum=o2.bookkeeping.Detector" json:"detectors,omitempty"`
	// Unix timestamp when this entity was last updated
	UpdatedAt int64 `protobuf:"varint,30,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	// A string that marks the period of the lhc
	LhcPeriod string `protobuf:"bytes,31,opt,name=lhcPeriod,proto3" json:"lhcPeriod,omitempty"`
	// contains filtered or unexported fields
}

func (*Run) Descriptor deprecated

func (*Run) Descriptor() ([]byte, []int)

Deprecated: Use Run.ProtoReflect.Descriptor instead.

func (*Run) GetBytesReadOut

func (x *Run) GetBytesReadOut() int32

func (*Run) GetCreatedAt

func (x *Run) GetCreatedAt() int64

func (*Run) GetDcs

func (x *Run) GetDcs() bool

func (*Run) GetDdFlp

func (x *Run) GetDdFlp() bool

func (*Run) GetDetectors

func (x *Run) GetDetectors() []Detector

func (*Run) GetEnvironmentId

func (x *Run) GetEnvironmentId() string

func (*Run) GetEpn

func (x *Run) GetEpn() bool

func (*Run) GetEpnTopology

func (x *Run) GetEpnTopology() string

func (*Run) GetId

func (x *Run) GetId() int32

func (*Run) GetLhcPeriod

func (x *Run) GetLhcPeriod() string

func (*Run) GetNDetectors

func (x *Run) GetNDetectors() int32

func (*Run) GetNEpns

func (x *Run) GetNEpns() int32

func (*Run) GetNFlps

func (x *Run) GetNFlps() int32

func (*Run) GetNSubtimeframes

func (x *Run) GetNSubtimeframes() int32

func (*Run) GetOdcTopologyFullName

func (x *Run) GetOdcTopologyFullName() string

func (*Run) GetPdpBeamType

func (x *Run) GetPdpBeamType() string

func (*Run) GetPdpConfigOption

func (x *Run) GetPdpConfigOption() string

func (*Run) GetPdpTopologyDescriptionLibraryFile

func (x *Run) GetPdpTopologyDescriptionLibraryFile() string

func (*Run) GetPdpWorkflowParameters

func (x *Run) GetPdpWorkflowParameters() string

func (*Run) GetReadoutCfgUri

func (x *Run) GetReadoutCfgUri() string

func (*Run) GetRunNumber

func (x *Run) GetRunNumber() int32

func (*Run) GetRunQuality

func (x *Run) GetRunQuality() RunQuality

func (*Run) GetRunType

func (x *Run) GetRunType() RunType

func (*Run) GetTfbDdMode

func (x *Run) GetTfbDdMode() string

func (*Run) GetTimeO2End

func (x *Run) GetTimeO2End() int64

func (*Run) GetTimeO2Start

func (x *Run) GetTimeO2Start() int64

func (*Run) GetTimeTrgEnd

func (x *Run) GetTimeTrgEnd() int64

func (*Run) GetTimeTrgStart

func (x *Run) GetTimeTrgStart() int64

func (*Run) GetTriggerValue

func (x *Run) GetTriggerValue() string

func (*Run) GetUpdatedAt

func (x *Run) GetUpdatedAt() int64

func (*Run) ProtoMessage

func (*Run) ProtoMessage()

func (*Run) ProtoReflect

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

func (*Run) Reset

func (x *Run) Reset()

func (*Run) String

func (x *Run) String() string

type RunCreationRequest

type RunCreationRequest struct {
	EnvironmentId       string     `protobuf:"bytes,1,opt,name=environmentId,proto3" json:"environmentId,omitempty"`
	NDetectors          int32      `protobuf:"varint,2,opt,name=nDetectors,proto3" json:"nDetectors,omitempty"`
	NEpns               int32      `protobuf:"varint,3,opt,name=nEpns,proto3" json:"nEpns,omitempty"`
	NFlps               int32      `protobuf:"varint,4,opt,name=nFlps,proto3" json:"nFlps,omitempty"`
	RunNumber           int32      `protobuf:"varint,5,opt,name=runNumber,proto3" json:"runNumber,omitempty"`
	RunType             RunType    `protobuf:"varint,6,opt,name=runType,proto3,enum=o2.bookkeeping.RunType" json:"runType,omitempty"`
	DdFlp               bool       `protobuf:"varint,7,opt,name=dd_flp,json=ddFlp,proto3" json:"dd_flp,omitempty"`
	Dcs                 bool       `protobuf:"varint,8,opt,name=dcs,proto3" json:"dcs,omitempty"`
	Epn                 bool       `protobuf:"varint,9,opt,name=epn,proto3" json:"epn,omitempty"`
	EpnTopology         string     `protobuf:"bytes,10,opt,name=epnTopology,proto3" json:"epnTopology,omitempty"`
	OdcTopologyFullName *string    `protobuf:"bytes,11,opt,name=odcTopologyFullName,proto3,oneof" json:"odcTopologyFullName,omitempty"`
	Detectors           []Detector `protobuf:"varint,12,rep,packed,name=detectors,proto3,enum=o2.bookkeeping.Detector" json:"detectors,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCreationRequest) Descriptor deprecated

func (*RunCreationRequest) Descriptor() ([]byte, []int)

Deprecated: Use RunCreationRequest.ProtoReflect.Descriptor instead.

func (*RunCreationRequest) GetDcs

func (x *RunCreationRequest) GetDcs() bool

func (*RunCreationRequest) GetDdFlp

func (x *RunCreationRequest) GetDdFlp() bool

func (*RunCreationRequest) GetDetectors

func (x *RunCreationRequest) GetDetectors() []Detector

func (*RunCreationRequest) GetEnvironmentId

func (x *RunCreationRequest) GetEnvironmentId() string

func (*RunCreationRequest) GetEpn

func (x *RunCreationRequest) GetEpn() bool

func (*RunCreationRequest) GetEpnTopology

func (x *RunCreationRequest) GetEpnTopology() string

func (*RunCreationRequest) GetNDetectors

func (x *RunCreationRequest) GetNDetectors() int32

func (*RunCreationRequest) GetNEpns

func (x *RunCreationRequest) GetNEpns() int32

func (*RunCreationRequest) GetNFlps

func (x *RunCreationRequest) GetNFlps() int32

func (*RunCreationRequest) GetOdcTopologyFullName

func (x *RunCreationRequest) GetOdcTopologyFullName() string

func (*RunCreationRequest) GetRunNumber

func (x *RunCreationRequest) GetRunNumber() int32

func (*RunCreationRequest) GetRunType

func (x *RunCreationRequest) GetRunType() RunType

func (*RunCreationRequest) ProtoMessage

func (*RunCreationRequest) ProtoMessage()

func (*RunCreationRequest) ProtoReflect

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

func (*RunCreationRequest) Reset

func (x *RunCreationRequest) Reset()

func (*RunCreationRequest) String

func (x *RunCreationRequest) String() string

type RunFetchRequest added in v0.70.0

type RunFetchRequest struct {
	RunNumber int32 `protobuf:"varint,1,opt,name=runNumber,proto3" json:"runNumber,omitempty"`
	// Specify the list of relations to fetch alongside the run
	// For example if this contains RUN_RELATIONS_LHC_FILL then the returned RunWithRelation will have a populated
	// lhcFill, else it will not be defined
	Relations []RunRelations `protobuf:"varint,2,rep,packed,name=relations,proto3,enum=o2.bookkeeping.RunRelations" json:"relations,omitempty"`
	// contains filtered or unexported fields
}

func (*RunFetchRequest) Descriptor deprecated added in v0.70.0

func (*RunFetchRequest) Descriptor() ([]byte, []int)

Deprecated: Use RunFetchRequest.ProtoReflect.Descriptor instead.

func (*RunFetchRequest) GetRelations added in v0.70.0

func (x *RunFetchRequest) GetRelations() []RunRelations

func (*RunFetchRequest) GetRunNumber added in v0.70.0

func (x *RunFetchRequest) GetRunNumber() int32

func (*RunFetchRequest) ProtoMessage added in v0.70.0

func (*RunFetchRequest) ProtoMessage()

func (*RunFetchRequest) ProtoReflect added in v0.70.0

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

func (*RunFetchRequest) Reset added in v0.70.0

func (x *RunFetchRequest) Reset()

func (*RunFetchRequest) String added in v0.70.0

func (x *RunFetchRequest) String() string

type RunQuality

type RunQuality int32
const (
	RunQuality_RUN_QUALITY_NULL RunQuality = 0
	RunQuality_RUN_QUALITY_BAD  RunQuality = 1
	RunQuality_RUN_QUALITY_GOOD RunQuality = 2
	RunQuality_RUN_QUALITY_TEST RunQuality = 3
	RunQuality_RUN_QUALITY_NONE RunQuality = 4
)

func (RunQuality) Descriptor

func (RunQuality) Descriptor() protoreflect.EnumDescriptor

func (RunQuality) Enum

func (x RunQuality) Enum() *RunQuality

func (RunQuality) EnumDescriptor deprecated

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

Deprecated: Use RunQuality.Descriptor instead.

func (RunQuality) Number

func (x RunQuality) Number() protoreflect.EnumNumber

func (RunQuality) String

func (x RunQuality) String() string

func (RunQuality) Type

type RunRelations added in v0.70.0

type RunRelations int32
const (
	// IGNORED - Here to comply with proto specification
	RunRelations_RUN_RELATIONS_NULL RunRelations = 0
	// Include the LHC fill related to the run
	RunRelations_RUN_RELATIONS_LHC_FILL RunRelations = 1
)

func (RunRelations) Descriptor added in v0.70.0

func (RunRelations) Enum added in v0.70.0

func (x RunRelations) Enum() *RunRelations

func (RunRelations) EnumDescriptor deprecated added in v0.70.0

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

Deprecated: Use RunRelations.Descriptor instead.

func (RunRelations) Number added in v0.70.0

func (RunRelations) String added in v0.70.0

func (x RunRelations) String() string

func (RunRelations) Type added in v0.70.0

type RunServiceClient

type RunServiceClient interface {
	Get(ctx context.Context, in *RunFetchRequest, opts ...grpc.CallOption) (*RunWithRelations, error)
	Create(ctx context.Context, in *RunCreationRequest, opts ...grpc.CallOption) (*Run, error)
	Update(ctx context.Context, in *RunUpdateRequest, opts ...grpc.CallOption) (*Run, error)
}

RunServiceClient is the client API for RunService 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 NewRunServiceClient

func NewRunServiceClient(cc grpc.ClientConnInterface) RunServiceClient

type RunServiceServer

type RunServiceServer interface {
	Get(context.Context, *RunFetchRequest) (*RunWithRelations, error)
	Create(context.Context, *RunCreationRequest) (*Run, error)
	Update(context.Context, *RunUpdateRequest) (*Run, error)
}

RunServiceServer is the server API for RunService service. All implementations should embed UnimplementedRunServiceServer for forward compatibility

type RunType

type RunType int32
const (
	RunType_RUN_TYPE_NULL                     RunType = 0
	RunType_RUN_TYPE_PHYSICS                  RunType = 1
	RunType_RUN_TYPE_TECHNICAL                RunType = 2
	RunType_RUN_TYPE_PEDESTAL                 RunType = 3
	RunType_RUN_TYPE_PULSER                   RunType = 4
	RunType_RUN_TYPE_LASER                    RunType = 5
	RunType_RUN_TYPE_CALIBRATION_ITHR_TUNING  RunType = 6
	RunType_RUN_TYPE_CALIBRATION_VCASN_TUNING RunType = 7
	RunType_RUN_TYPE_CALIBRATION_THR_SCAN     RunType = 8
	RunType_RUN_TYPE_CALIBRATION_DIGITAL_SCAN RunType = 9
	RunType_RUN_TYPE_CALIBRATION_ANALOG_SCAN  RunType = 10
	RunType_RUN_TYPE_CALIBRATION_FHR          RunType = 11
	RunType_RUN_TYPE_CALIBRATION_ALPIDE_SCAN  RunType = 12
	RunType_RUN_TYPE_CALIBRATION              RunType = 13
	RunType_RUN_TYPE_COSMICS                  RunType = 14
	RunType_RUN_TYPE_SYNTHETIC                RunType = 15
	RunType_RUN_TYPE_NOISE                    RunType = 16
	RunType_RUN_TYPE_CALIBRATION_PULSE_LENGTH RunType = 17
	RunType_RUN_TYPE_CALIBRATION_VRESETD      RunType = 18
)

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 RunUpdateRequest

type RunUpdateRequest struct {
	RunNumber                         int32   `protobuf:"varint,1,opt,name=runNumber,proto3" json:"runNumber,omitempty"`
	TimeO2Start                       *int64  `protobuf:"varint,3,opt,name=timeO2Start,proto3,oneof" json:"timeO2Start,omitempty"`
	TimeO2End                         *int64  `protobuf:"varint,4,opt,name=timeO2End,proto3,oneof" json:"timeO2End,omitempty"`
	TimeTrgStart                      *int64  `protobuf:"varint,5,opt,name=timeTrgStart,proto3,oneof" json:"timeTrgStart,omitempty"`
	TimeTrgEnd                        *int64  `protobuf:"varint,6,opt,name=timeTrgEnd,proto3,oneof" json:"timeTrgEnd,omitempty"`
	TriggerValue                      *string `protobuf:"bytes,7,opt,name=triggerValue,proto3,oneof" json:"triggerValue,omitempty"`
	PdpConfigOption                   *string `protobuf:"bytes,8,opt,name=pdpConfigOption,proto3,oneof" json:"pdpConfigOption,omitempty"`
	PdpTopologyDescriptionLibraryFile *string `protobuf:"bytes,9,opt,name=pdpTopologyDescriptionLibraryFile,proto3,oneof" json:"pdpTopologyDescriptionLibraryFile,omitempty"`
	TfbDdMode                         *string `protobuf:"bytes,10,opt,name=tfbDdMode,proto3,oneof" json:"tfbDdMode,omitempty"`
	LhcPeriod                         *string `protobuf:"bytes,11,opt,name=lhcPeriod,proto3,oneof" json:"lhcPeriod,omitempty"`
	OdcTopologyFullName               *string `protobuf:"bytes,12,opt,name=odcTopologyFullName,proto3,oneof" json:"odcTopologyFullName,omitempty"`
	PdpWorkflowParameters             *string `protobuf:"bytes,13,opt,name=pdpWorkflowParameters,proto3,oneof" json:"pdpWorkflowParameters,omitempty"`
	PdpBeamType                       *string `protobuf:"bytes,14,opt,name=pdpBeamType,proto3,oneof" json:"pdpBeamType,omitempty"`
	ReadoutCfgUri                     *string `protobuf:"bytes,15,opt,name=readoutCfgUri,proto3,oneof" json:"readoutCfgUri,omitempty"`
	// contains filtered or unexported fields
}

func (*RunUpdateRequest) Descriptor deprecated

func (*RunUpdateRequest) Descriptor() ([]byte, []int)

Deprecated: Use RunUpdateRequest.ProtoReflect.Descriptor instead.

func (*RunUpdateRequest) GetLhcPeriod

func (x *RunUpdateRequest) GetLhcPeriod() string

func (*RunUpdateRequest) GetOdcTopologyFullName

func (x *RunUpdateRequest) GetOdcTopologyFullName() string

func (*RunUpdateRequest) GetPdpBeamType

func (x *RunUpdateRequest) GetPdpBeamType() string

func (*RunUpdateRequest) GetPdpConfigOption

func (x *RunUpdateRequest) GetPdpConfigOption() string

func (*RunUpdateRequest) GetPdpTopologyDescriptionLibraryFile

func (x *RunUpdateRequest) GetPdpTopologyDescriptionLibraryFile() string

func (*RunUpdateRequest) GetPdpWorkflowParameters

func (x *RunUpdateRequest) GetPdpWorkflowParameters() string

func (*RunUpdateRequest) GetReadoutCfgUri

func (x *RunUpdateRequest) GetReadoutCfgUri() string

func (*RunUpdateRequest) GetRunNumber

func (x *RunUpdateRequest) GetRunNumber() int32

func (*RunUpdateRequest) GetTfbDdMode

func (x *RunUpdateRequest) GetTfbDdMode() string

func (*RunUpdateRequest) GetTimeO2End

func (x *RunUpdateRequest) GetTimeO2End() int64

func (*RunUpdateRequest) GetTimeO2Start

func (x *RunUpdateRequest) GetTimeO2Start() int64

func (*RunUpdateRequest) GetTimeTrgEnd

func (x *RunUpdateRequest) GetTimeTrgEnd() int64

func (*RunUpdateRequest) GetTimeTrgStart

func (x *RunUpdateRequest) GetTimeTrgStart() int64

func (*RunUpdateRequest) GetTriggerValue

func (x *RunUpdateRequest) GetTriggerValue() string

func (*RunUpdateRequest) ProtoMessage

func (*RunUpdateRequest) ProtoMessage()

func (*RunUpdateRequest) ProtoReflect

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

func (*RunUpdateRequest) Reset

func (x *RunUpdateRequest) Reset()

func (*RunUpdateRequest) String

func (x *RunUpdateRequest) String() string

type RunWithRelations added in v0.70.0

type RunWithRelations struct {
	Run     *Run     `protobuf:"bytes,1,opt,name=run,proto3" json:"run,omitempty"`
	LhcFill *LHCFill `protobuf:"bytes,2,opt,name=lhcFill,proto3,oneof" json:"lhcFill,omitempty"`
	// contains filtered or unexported fields
}

func (*RunWithRelations) Descriptor deprecated added in v0.70.0

func (*RunWithRelations) Descriptor() ([]byte, []int)

Deprecated: Use RunWithRelations.ProtoReflect.Descriptor instead.

func (*RunWithRelations) GetLhcFill added in v0.70.0

func (x *RunWithRelations) GetLhcFill() *LHCFill

func (*RunWithRelations) GetRun added in v0.70.0

func (x *RunWithRelations) GetRun() *Run

func (*RunWithRelations) ProtoMessage added in v0.70.0

func (*RunWithRelations) ProtoMessage()

func (*RunWithRelations) ProtoReflect added in v0.70.0

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

func (*RunWithRelations) Reset added in v0.70.0

func (x *RunWithRelations) Reset()

func (*RunWithRelations) String added in v0.70.0

func (x *RunWithRelations) String() string

type Subsystem

type Subsystem struct {

	// Unix timestamp when this entity was created.
	CreatedAt int64 `protobuf:"varint,1,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	Id        int32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// The label value of the subsystem.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Unix timestamp when this entity was last updated.
	UpdatedAt int64 `protobuf:"varint,5,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	// contains filtered or unexported fields
}

func (*Subsystem) Descriptor deprecated

func (*Subsystem) Descriptor() ([]byte, []int)

Deprecated: Use Subsystem.ProtoReflect.Descriptor instead.

func (*Subsystem) GetCreatedAt

func (x *Subsystem) GetCreatedAt() int64

func (*Subsystem) GetId

func (x *Subsystem) GetId() int32

func (*Subsystem) GetName

func (x *Subsystem) GetName() string

func (*Subsystem) GetUpdatedAt

func (x *Subsystem) GetUpdatedAt() int64

func (*Subsystem) ProtoMessage

func (*Subsystem) ProtoMessage()

func (*Subsystem) ProtoReflect

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

func (*Subsystem) Reset

func (x *Subsystem) Reset()

func (*Subsystem) String

func (x *Subsystem) String() string

type Tag

type Tag struct {

	// Unix timestamp when this entity was created.
	CreatedAt int64 `protobuf:"varint,1,opt,name=createdAt,proto3" json:"createdAt,omitempty"`
	Id        int32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// The label value of the tag.
	Text string `protobuf:"bytes,3,opt,name=text,proto3" json:"text,omitempty"`
	// The email for the tag.
	Email string `protobuf:"bytes,4,opt,name=email,proto3" json:"email,omitempty"`
	// All the mattermost tags for updates
	Mattermost string `protobuf:"bytes,5,opt,name=mattermost,proto3" json:"mattermost,omitempty"`
	// Unix timestamp when this entity was last updated.
	UpdatedAt int64 `protobuf:"varint,6,opt,name=updatedAt,proto3" json:"updatedAt,omitempty"`
	// The last person that edited the email/mattermost fields
	LastEditedName string `protobuf:"bytes,7,opt,name=lastEditedName,proto3" json:"lastEditedName,omitempty"`
	// contains filtered or unexported fields
}

func (*Tag) Descriptor deprecated

func (*Tag) Descriptor() ([]byte, []int)

Deprecated: Use Tag.ProtoReflect.Descriptor instead.

func (*Tag) GetCreatedAt

func (x *Tag) GetCreatedAt() int64

func (*Tag) GetEmail

func (x *Tag) GetEmail() string

func (*Tag) GetId

func (x *Tag) GetId() int32

func (*Tag) GetLastEditedName

func (x *Tag) GetLastEditedName() string

func (*Tag) GetMattermost

func (x *Tag) GetMattermost() string

func (*Tag) GetText

func (x *Tag) GetText() string

func (*Tag) GetUpdatedAt

func (x *Tag) GetUpdatedAt() int64

func (*Tag) ProtoMessage

func (*Tag) ProtoMessage()

func (*Tag) ProtoReflect

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

func (*Tag) Reset

func (x *Tag) Reset()

func (*Tag) String

func (x *Tag) String() string

type UnimplementedEnvironmentServiceServer

type UnimplementedEnvironmentServiceServer struct {
}

UnimplementedEnvironmentServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedEnvironmentServiceServer) Create

func (UnimplementedEnvironmentServiceServer) Update

type UnimplementedFlpServiceServer

type UnimplementedFlpServiceServer struct {
}

UnimplementedFlpServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedFlpServiceServer) CreateMany

type UnimplementedLhcFillServiceServer added in v0.70.0

type UnimplementedLhcFillServiceServer struct {
}

UnimplementedLhcFillServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedLhcFillServiceServer) GetLast added in v0.70.0

type UnimplementedLogServiceServer

type UnimplementedLogServiceServer struct {
}

UnimplementedLogServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedLogServiceServer) Create

type UnimplementedRunServiceServer

type UnimplementedRunServiceServer struct {
}

UnimplementedRunServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedRunServiceServer) Create

func (UnimplementedRunServiceServer) Get added in v0.70.0

func (UnimplementedRunServiceServer) Update

type UnsafeEnvironmentServiceServer

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

UnsafeEnvironmentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EnvironmentServiceServer will result in compilation errors.

type UnsafeFlpServiceServer

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

UnsafeFlpServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FlpServiceServer will result in compilation errors.

type UnsafeLhcFillServiceServer added in v0.70.0

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

UnsafeLhcFillServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LhcFillServiceServer will result in compilation errors.

type UnsafeLogServiceServer

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

UnsafeLogServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogServiceServer will result in compilation errors.

type UnsafeRunServiceServer

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

UnsafeRunServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RunServiceServer will result in compilation errors.

type User

type User struct {

	// The unique CERN identifier of this user.
	ExternalId int32 `protobuf:"varint,1,opt,name=externalId,proto3" json:"externalId,omitempty"`
	// The unique identifier of this entity.
	Id int32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// Name of the user.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*User) Descriptor deprecated

func (*User) Descriptor() ([]byte, []int)

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetExternalId

func (x *User) GetExternalId() int32

func (*User) GetId

func (x *User) GetId() int32

func (*User) GetName

func (x *User) GetName() string

func (*User) ProtoMessage

func (*User) ProtoMessage()

func (*User) ProtoReflect

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

func (*User) Reset

func (x *User) Reset()

func (*User) String

func (x *User) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL