kafka

Documentation

Index

• Variables
• type ActiveRunsList
  • func (*ActiveRunsList) Descriptor() ([]byte, []int)
  • func (x *ActiveRunsList) GetActiveRuns() []*EnvInfo
  • func (x *ActiveRunsList) GetTimestamp() uint64
  • func (*ActiveRunsList) ProtoMessage()
  • func (x *ActiveRunsList) ProtoReflect() protoreflect.Message
  • func (x *ActiveRunsList) Reset()
  • func (x *ActiveRunsList) String() string
• type EnvInfo
  • func (*EnvInfo) Descriptor() ([]byte, []int)
  • func (x *EnvInfo) GetDetectors() []string
  • func (x *EnvInfo) GetEnvironmentId() string
  • func (x *EnvInfo) GetRunNumber() uint32
  • func (x *EnvInfo) GetRunType() string
  • func (x *EnvInfo) GetState() string
  • func (*EnvInfo) ProtoMessage()
  • func (x *EnvInfo) ProtoReflect() protoreflect.Message
  • func (x *EnvInfo) Reset()
  • func (x *EnvInfo) String() string
• type NewStateNotification
  • func (*NewStateNotification) Descriptor() ([]byte, []int)
  • func (x *NewStateNotification) GetEnvInfo() *EnvInfo
  • func (x *NewStateNotification) GetTimestamp() uint64
  • func (*NewStateNotification) ProtoMessage()
  • func (x *NewStateNotification) ProtoReflect() protoreflect.Message
  • func (x *NewStateNotification) Reset()
  • func (x *NewStateNotification) String() string

Variables

var File_protos_kafka_proto protoreflect.FileDescriptor

Types

type ActiveRunsList

type ActiveRunsList struct {
	ActiveRuns []*EnvInfo `protobuf:"bytes,1,rep,name=activeRuns,proto3" json:"activeRuns,omitempty"`
	Timestamp  uint64     `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // ms since epoch
	// contains filtered or unexported fields
}

func (*ActiveRunsList) Descriptor

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

Deprecated: Use ActiveRunsList.ProtoReflect.Descriptor instead.

func (*ActiveRunsList) GetActiveRuns

func (x *ActiveRunsList) GetActiveRuns() []*EnvInfo

func (*ActiveRunsList) GetTimestamp

func (x *ActiveRunsList) GetTimestamp() uint64

func (*ActiveRunsList) ProtoMessage

func (*ActiveRunsList) ProtoMessage()

func (*ActiveRunsList) ProtoReflect

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

func (*ActiveRunsList) Reset

func (x *ActiveRunsList) Reset()

func (*ActiveRunsList) String

func (x *ActiveRunsList) String() string

type EnvInfo

type EnvInfo struct {
	EnvironmentId string   `protobuf:"bytes,1,opt,name=environmentId,proto3" json:"environmentId,omitempty"`
	RunNumber     *uint32  `protobuf:"varint,2,opt,name=runNumber,proto3,oneof" json:"runNumber,omitempty"`
	RunType       *string  `protobuf:"bytes,3,opt,name=runType,proto3,oneof" json:"runType,omitempty"`
	State         string   `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	Detectors     []string `protobuf:"bytes,5,rep,name=detectors,proto3" json:"detectors,omitempty"`
	// contains filtered or unexported fields
}

func (*EnvInfo) Descriptor

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

Deprecated: Use EnvInfo.ProtoReflect.Descriptor instead.

func (*EnvInfo) GetDetectors

func (x *EnvInfo) GetDetectors() []string

func (*EnvInfo) GetEnvironmentId

func (x *EnvInfo) GetEnvironmentId() string

func (*EnvInfo) GetRunNumber

func (x *EnvInfo) GetRunNumber() uint32

func (*EnvInfo) GetRunType

func (x *EnvInfo) GetRunType() string

func (*EnvInfo) GetState

func (x *EnvInfo) GetState() string

func (*EnvInfo) ProtoMessage

func (*EnvInfo) ProtoMessage()

func (*EnvInfo) ProtoReflect

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

func (*EnvInfo) Reset

func (x *EnvInfo) Reset()

func (*EnvInfo) String

func (x *EnvInfo) String() string

type NewStateNotification

type NewStateNotification struct {
	EnvInfo   *EnvInfo `protobuf:"bytes,1,opt,name=envInfo,proto3" json:"envInfo,omitempty"`
	Timestamp uint64   `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // ms since epoch
	// contains filtered or unexported fields
}

func (*NewStateNotification) Descriptor

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

Deprecated: Use NewStateNotification.ProtoReflect.Descriptor instead.

func (*NewStateNotification) GetEnvInfo

func (x *NewStateNotification) GetEnvInfo() *EnvInfo

func (*NewStateNotification) GetTimestamp

func (x *NewStateNotification) GetTimestamp() uint64

func (*NewStateNotification) ProtoMessage

func (*NewStateNotification) ProtoMessage()

func (*NewStateNotification) ProtoReflect

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

func (*NewStateNotification) Reset

func (x *NewStateNotification) Reset()

func (*NewStateNotification) String

func (x *NewStateNotification) String() string