kafka

Jun 9, 2022

Changes in this version

+ var File_kafka_proto protoreflect.FileDescriptor

type EnvInfo

+ EnterStateTimestamp uint64

+ func (x *EnvInfo) GetEnterStateTimestamp() uint64

Apr 27, 2022

Changes in this version

+ var File_protos_kafka_proto protoreflect.FileDescriptor

+ type ActiveRunsList struct

+ ActiveRuns []*EnvInfo

+ Timestamp uint64

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

+ func (*ActiveRunsList) ProtoMessage()

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

+ func (x *ActiveRunsList) GetTimestamp() uint64

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

+ func (x *ActiveRunsList) Reset()

+ func (x *ActiveRunsList) String() string

+ type EnvInfo struct

+ Detectors []string

+ EnvironmentId string

+ RunNumber *uint32

+ RunType *string

+ State string

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

+ func (*EnvInfo) ProtoMessage()

+ 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 (x *EnvInfo) ProtoReflect() protoreflect.Message

+ func (x *EnvInfo) Reset()

+ func (x *EnvInfo) String() string

+ type NewStateNotification struct

+ EnvInfo *EnvInfo

+ Timestamp uint64

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

+ func (*NewStateNotification) ProtoMessage()

+ func (x *NewStateNotification) GetEnvInfo() *EnvInfo

+ func (x *NewStateNotification) GetTimestamp() uint64

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

+ func (x *NewStateNotification) Reset()

+ func (x *NewStateNotification) String() string