Documentation ¶
Index ¶
- Variables
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetFileVersion() string
- func (x *Event) GetGraphDef() []byte
- func (x *Event) GetLogMessage() *LogMessagedeprecated
- func (x *Event) GetMetaGraphDef() []byte
- func (x *Event) GetSessionLog() *SessionLog
- func (x *Event) GetSourceMetadata() *SourceMetadata
- func (x *Event) GetStep() int64
- func (x *Event) GetSummary() *summary_go_proto.Summary
- func (x *Event) GetTaggedRunMetadata() *TaggedRunMetadata
- func (x *Event) GetWallTime() float64
- func (m *Event) GetWhat() isEvent_What
- func (*Event) ProtoMessage()
- func (x *Event) ProtoReflect() protoreflect.Message
- func (x *Event) Reset()
- func (x *Event) String() string
- type Event_FileVersion
- type Event_GraphDef
- type Event_LogMessage
- type Event_MetaGraphDef
- type Event_SessionLog
- type Event_Summary
- type Event_TaggedRunMetadata
- type LogMessagedeprecated
- func (*LogMessage) Descriptor() ([]byte, []int)deprecated
- func (x *LogMessage) GetLevel() LogMessage_Level
- func (x *LogMessage) GetMessage() string
- func (*LogMessage) ProtoMessage()
- func (x *LogMessage) ProtoReflect() protoreflect.Message
- func (x *LogMessage) Reset()
- func (x *LogMessage) String() string
- type LogMessage_Leveldeprecated
- func (LogMessage_Level) Descriptor() protoreflect.EnumDescriptor
- func (x LogMessage_Level) Enum() *LogMessage_Level
- func (LogMessage_Level) EnumDescriptor() ([]byte, []int)deprecated
- func (x LogMessage_Level) Number() protoreflect.EnumNumber
- func (x LogMessage_Level) String() string
- func (LogMessage_Level) Type() protoreflect.EnumType
- type RequestedExitCode
- type SessionLog
- func (*SessionLog) Descriptor() ([]byte, []int)deprecated
- func (x *SessionLog) GetCheckpointPath() string
- func (x *SessionLog) GetMsg() string
- func (x *SessionLog) GetStatus() SessionLog_SessionStatus
- func (*SessionLog) ProtoMessage()
- func (x *SessionLog) ProtoReflect() protoreflect.Message
- func (x *SessionLog) Reset()
- func (x *SessionLog) String() string
- type SessionLog_SessionStatus
- func (SessionLog_SessionStatus) Descriptor() protoreflect.EnumDescriptor
- func (x SessionLog_SessionStatus) Enum() *SessionLog_SessionStatus
- func (SessionLog_SessionStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x SessionLog_SessionStatus) Number() protoreflect.EnumNumber
- func (x SessionLog_SessionStatus) String() string
- func (SessionLog_SessionStatus) Type() protoreflect.EnumType
- type SourceMetadata
- type TaggedRunMetadata
- func (*TaggedRunMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *TaggedRunMetadata) GetRunMetadata() []byte
- func (x *TaggedRunMetadata) GetTag() string
- func (*TaggedRunMetadata) ProtoMessage()
- func (x *TaggedRunMetadata) ProtoReflect() protoreflect.Message
- func (x *TaggedRunMetadata) Reset()
- func (x *TaggedRunMetadata) String() string
- type WatchdogConfig
- type WorkerHealth
- func (WorkerHealth) Descriptor() protoreflect.EnumDescriptor
- func (x WorkerHealth) Enum() *WorkerHealth
- func (WorkerHealth) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkerHealth) Number() protoreflect.EnumNumber
- func (x WorkerHealth) String() string
- func (WorkerHealth) Type() protoreflect.EnumType
- type WorkerHeartbeatRequest
- func (*WorkerHeartbeatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerHeartbeatRequest) GetExitCode() *RequestedExitCode
- func (x *WorkerHeartbeatRequest) GetShutdownMode() WorkerShutdownMode
- func (x *WorkerHeartbeatRequest) GetWatchdogConfig() *WatchdogConfig
- func (*WorkerHeartbeatRequest) ProtoMessage()
- func (x *WorkerHeartbeatRequest) ProtoReflect() protoreflect.Message
- func (x *WorkerHeartbeatRequest) Reset()
- func (x *WorkerHeartbeatRequest) String() string
- type WorkerHeartbeatResponse
- func (*WorkerHeartbeatResponse) Descriptor() ([]byte, []int)deprecated
- func (x *WorkerHeartbeatResponse) GetHealthStatus() WorkerHealth
- func (x *WorkerHeartbeatResponse) GetHostname() string
- func (x *WorkerHeartbeatResponse) GetWorkerLog() []*Event
- func (*WorkerHeartbeatResponse) ProtoMessage()
- func (x *WorkerHeartbeatResponse) ProtoReflect() protoreflect.Message
- func (x *WorkerHeartbeatResponse) Reset()
- func (x *WorkerHeartbeatResponse) String() string
- type WorkerShutdownMode
- func (WorkerShutdownMode) Descriptor() protoreflect.EnumDescriptor
- func (x WorkerShutdownMode) Enum() *WorkerShutdownMode
- func (WorkerShutdownMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x WorkerShutdownMode) Number() protoreflect.EnumNumber
- func (x WorkerShutdownMode) String() string
- func (WorkerShutdownMode) Type() protoreflect.EnumType
Constants ¶
This section is empty.
Variables ¶
var ( WorkerHealth_name = map[int32]string{ 0: "OK", 1: "RECEIVED_SHUTDOWN_SIGNAL", 2: "INTERNAL_ERROR", 3: "SHUTTING_DOWN", } WorkerHealth_value = map[string]int32{ "OK": 0, "RECEIVED_SHUTDOWN_SIGNAL": 1, "INTERNAL_ERROR": 2, "SHUTTING_DOWN": 3, } )
Enum value maps for WorkerHealth.
var ( WorkerShutdownMode_name = map[int32]string{ 0: "DEFAULT", 1: "NOT_CONFIGURED", 2: "WAIT_FOR_COORDINATOR", 3: "SHUTDOWN_AFTER_TIMEOUT", } WorkerShutdownMode_value = map[string]int32{ "DEFAULT": 0, "NOT_CONFIGURED": 1, "WAIT_FOR_COORDINATOR": 2, "SHUTDOWN_AFTER_TIMEOUT": 3, } )
Enum value maps for WorkerShutdownMode.
var ( LogMessage_Level_name = map[int32]string{ 0: "UNKNOWN", 10: "DEBUGGING", 20: "INFO", 30: "WARN", 40: "ERROR", 50: "FATAL", } LogMessage_Level_value = map[string]int32{ "UNKNOWN": 0, "DEBUGGING": 10, "INFO": 20, "WARN": 30, "ERROR": 40, "FATAL": 50, } )
Enum value maps for LogMessage_Level.
var ( SessionLog_SessionStatus_name = map[int32]string{ 0: "STATUS_UNSPECIFIED", 1: "START", 2: "STOP", 3: "CHECKPOINT", } SessionLog_SessionStatus_value = map[string]int32{ "STATUS_UNSPECIFIED": 0, "START": 1, "STOP": 2, "CHECKPOINT": 3, } )
Enum value maps for SessionLog_SessionStatus.
var File_tensorflow_core_util_event_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Event ¶
type Event struct { // Timestamp of the event. WallTime float64 `protobuf:"fixed64,1,opt,name=wall_time,json=wallTime,proto3" json:"wall_time,omitempty"` // Global step of the event. Step int64 `protobuf:"varint,2,opt,name=step,proto3" json:"step,omitempty"` // Types that are assignable to What: // // *Event_FileVersion // *Event_GraphDef // *Event_Summary // *Event_LogMessage // *Event_SessionLog // *Event_TaggedRunMetadata // *Event_MetaGraphDef What isEvent_What `protobuf_oneof:"what"` // Information of the source that writes the events, this is only logged in // the very first event along with the `file_version` field. SourceMetadata *SourceMetadata `protobuf:"bytes,10,opt,name=source_metadata,json=sourceMetadata,proto3" json:"source_metadata,omitempty"` // contains filtered or unexported fields }
Protocol buffer representing an event that happened during the execution of a Brain model.
func (*Event) Descriptor
deprecated
func (*Event) GetFileVersion ¶
func (*Event) GetGraphDef ¶
func (*Event) GetLogMessage
deprecated
func (x *Event) GetLogMessage() *LogMessage
Deprecated: Do not use.
func (*Event) GetMetaGraphDef ¶
func (*Event) GetSessionLog ¶
func (x *Event) GetSessionLog() *SessionLog
func (*Event) GetSourceMetadata ¶ added in v0.4.0
func (x *Event) GetSourceMetadata() *SourceMetadata
func (*Event) GetSummary ¶
func (x *Event) GetSummary() *summary_go_proto.Summary
func (*Event) GetTaggedRunMetadata ¶
func (x *Event) GetTaggedRunMetadata() *TaggedRunMetadata
func (*Event) GetWallTime ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
type Event_FileVersion ¶
type Event_FileVersion struct { // An event file was started, with the specified version. // This is use to identify the contents of the record IO files // easily. Current version is "brain.Event:2". All versions // start with "brain.Event:". FileVersion string `protobuf:"bytes,3,opt,name=file_version,json=fileVersion,proto3,oneof"` }
type Event_GraphDef ¶
type Event_GraphDef struct { // An encoded version of a GraphDef. GraphDef []byte `protobuf:"bytes,4,opt,name=graph_def,json=graphDef,proto3,oneof"` }
type Event_LogMessage ¶
type Event_LogMessage struct { // The user output a log message. This was theoretically used by the defunct // tensorboard_logging module, which has since been removed; this field is // now deprecated and should not be used. // // Deprecated: Do not use. LogMessage *LogMessage `protobuf:"bytes,6,opt,name=log_message,json=logMessage,proto3,oneof"` }
type Event_MetaGraphDef ¶
type Event_MetaGraphDef struct { // An encoded version of a MetaGraphDef. MetaGraphDef []byte `protobuf:"bytes,9,opt,name=meta_graph_def,json=metaGraphDef,proto3,oneof"` }
type Event_SessionLog ¶
type Event_SessionLog struct { // The state of the session which can be used for restarting after crashes. SessionLog *SessionLog `protobuf:"bytes,7,opt,name=session_log,json=sessionLog,proto3,oneof"` }
type Event_Summary ¶
type Event_Summary struct { // A summary was generated. Summary *summary_go_proto.Summary `protobuf:"bytes,5,opt,name=summary,proto3,oneof"` }
type Event_TaggedRunMetadata ¶
type Event_TaggedRunMetadata struct { // The metadata returned by running a session.run() call. TaggedRunMetadata *TaggedRunMetadata `protobuf:"bytes,8,opt,name=tagged_run_metadata,json=taggedRunMetadata,proto3,oneof"` }
type LogMessage
deprecated
type LogMessage struct { Level LogMessage_Level `protobuf:"varint,1,opt,name=level,proto3,enum=tensorflow.LogMessage_Level" json:"level,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
Protocol buffer used for logging messages to the events file.
This was theoretically used by the defunct tensorboard_logging module, which has been removed; this message is now deprecated and should not be used.
Deprecated: Do not use.
func (*LogMessage) Descriptor
deprecated
func (*LogMessage) Descriptor() ([]byte, []int)
Deprecated: Use LogMessage.ProtoReflect.Descriptor instead.
func (*LogMessage) GetLevel ¶
func (x *LogMessage) GetLevel() LogMessage_Level
func (*LogMessage) GetMessage ¶
func (x *LogMessage) GetMessage() string
func (*LogMessage) ProtoMessage ¶
func (*LogMessage) ProtoMessage()
func (*LogMessage) ProtoReflect ¶
func (x *LogMessage) ProtoReflect() protoreflect.Message
func (*LogMessage) Reset ¶
func (x *LogMessage) Reset()
func (*LogMessage) String ¶
func (x *LogMessage) String() string
type LogMessage_Level
deprecated
type LogMessage_Level int32
Deprecated: Do not use.
const ( LogMessage_UNKNOWN LogMessage_Level = 0 // Note: The logging level 10 cannot be named DEBUG. Some software // projects compile their C/C++ code with -DDEBUG in debug builds. So the // C++ code generated from this file should not have an identifier named // DEBUG. LogMessage_DEBUGGING LogMessage_Level = 10 LogMessage_INFO LogMessage_Level = 20 LogMessage_WARN LogMessage_Level = 30 LogMessage_ERROR LogMessage_Level = 40 LogMessage_FATAL LogMessage_Level = 50 )
func (LogMessage_Level) Descriptor ¶
func (LogMessage_Level) Descriptor() protoreflect.EnumDescriptor
func (LogMessage_Level) Enum ¶
func (x LogMessage_Level) Enum() *LogMessage_Level
func (LogMessage_Level) EnumDescriptor
deprecated
func (LogMessage_Level) EnumDescriptor() ([]byte, []int)
Deprecated: Use LogMessage_Level.Descriptor instead.
func (LogMessage_Level) Number ¶
func (x LogMessage_Level) Number() protoreflect.EnumNumber
func (LogMessage_Level) String ¶
func (x LogMessage_Level) String() string
func (LogMessage_Level) Type ¶
func (LogMessage_Level) Type() protoreflect.EnumType
type RequestedExitCode ¶
type RequestedExitCode struct { ExitCode int32 `protobuf:"varint,1,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"` // contains filtered or unexported fields }
func (*RequestedExitCode) Descriptor
deprecated
func (*RequestedExitCode) Descriptor() ([]byte, []int)
Deprecated: Use RequestedExitCode.ProtoReflect.Descriptor instead.
func (*RequestedExitCode) GetExitCode ¶
func (x *RequestedExitCode) GetExitCode() int32
func (*RequestedExitCode) ProtoMessage ¶
func (*RequestedExitCode) ProtoMessage()
func (*RequestedExitCode) ProtoReflect ¶
func (x *RequestedExitCode) ProtoReflect() protoreflect.Message
func (*RequestedExitCode) Reset ¶
func (x *RequestedExitCode) Reset()
func (*RequestedExitCode) String ¶
func (x *RequestedExitCode) String() string
type SessionLog ¶
type SessionLog struct { Status SessionLog_SessionStatus `protobuf:"varint,1,opt,name=status,proto3,enum=tensorflow.SessionLog_SessionStatus" json:"status,omitempty"` // This checkpoint_path contains both the path and filename. CheckpointPath string `protobuf:"bytes,2,opt,name=checkpoint_path,json=checkpointPath,proto3" json:"checkpoint_path,omitempty"` Msg string `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"` // contains filtered or unexported fields }
Protocol buffer used for logging session state.
func (*SessionLog) Descriptor
deprecated
func (*SessionLog) Descriptor() ([]byte, []int)
Deprecated: Use SessionLog.ProtoReflect.Descriptor instead.
func (*SessionLog) GetCheckpointPath ¶
func (x *SessionLog) GetCheckpointPath() string
func (*SessionLog) GetMsg ¶
func (x *SessionLog) GetMsg() string
func (*SessionLog) GetStatus ¶
func (x *SessionLog) GetStatus() SessionLog_SessionStatus
func (*SessionLog) ProtoMessage ¶
func (*SessionLog) ProtoMessage()
func (*SessionLog) ProtoReflect ¶
func (x *SessionLog) ProtoReflect() protoreflect.Message
func (*SessionLog) Reset ¶
func (x *SessionLog) Reset()
func (*SessionLog) String ¶
func (x *SessionLog) String() string
type SessionLog_SessionStatus ¶
type SessionLog_SessionStatus int32
const ( SessionLog_STATUS_UNSPECIFIED SessionLog_SessionStatus = 0 SessionLog_START SessionLog_SessionStatus = 1 SessionLog_STOP SessionLog_SessionStatus = 2 SessionLog_CHECKPOINT SessionLog_SessionStatus = 3 )
func (SessionLog_SessionStatus) Descriptor ¶
func (SessionLog_SessionStatus) Descriptor() protoreflect.EnumDescriptor
func (SessionLog_SessionStatus) Enum ¶
func (x SessionLog_SessionStatus) Enum() *SessionLog_SessionStatus
func (SessionLog_SessionStatus) EnumDescriptor
deprecated
func (SessionLog_SessionStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use SessionLog_SessionStatus.Descriptor instead.
func (SessionLog_SessionStatus) Number ¶
func (x SessionLog_SessionStatus) Number() protoreflect.EnumNumber
func (SessionLog_SessionStatus) String ¶
func (x SessionLog_SessionStatus) String() string
func (SessionLog_SessionStatus) Type ¶
func (SessionLog_SessionStatus) Type() protoreflect.EnumType
type SourceMetadata ¶ added in v0.4.0
type SourceMetadata struct { // Low level name of the summary writer, such as // `tensorflow.core.util.events_writer`. Writer string `protobuf:"bytes,1,opt,name=writer,proto3" json:"writer,omitempty"` // contains filtered or unexported fields }
Holds the information of the source that writes the events.
func (*SourceMetadata) Descriptor
deprecated
added in
v0.4.0
func (*SourceMetadata) Descriptor() ([]byte, []int)
Deprecated: Use SourceMetadata.ProtoReflect.Descriptor instead.
func (*SourceMetadata) GetWriter ¶ added in v0.4.0
func (x *SourceMetadata) GetWriter() string
func (*SourceMetadata) ProtoMessage ¶ added in v0.4.0
func (*SourceMetadata) ProtoMessage()
func (*SourceMetadata) ProtoReflect ¶ added in v0.4.0
func (x *SourceMetadata) ProtoReflect() protoreflect.Message
func (*SourceMetadata) Reset ¶ added in v0.4.0
func (x *SourceMetadata) Reset()
func (*SourceMetadata) String ¶ added in v0.4.0
func (x *SourceMetadata) String() string
type TaggedRunMetadata ¶
type TaggedRunMetadata struct { // Tag name associated with this metadata. Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"` // Byte-encoded version of the `RunMetadata` proto in order to allow lazy // deserialization. RunMetadata []byte `protobuf:"bytes,2,opt,name=run_metadata,json=runMetadata,proto3" json:"run_metadata,omitempty"` // contains filtered or unexported fields }
For logging the metadata output for a single session.run() call.
func (*TaggedRunMetadata) Descriptor
deprecated
func (*TaggedRunMetadata) Descriptor() ([]byte, []int)
Deprecated: Use TaggedRunMetadata.ProtoReflect.Descriptor instead.
func (*TaggedRunMetadata) GetRunMetadata ¶
func (x *TaggedRunMetadata) GetRunMetadata() []byte
func (*TaggedRunMetadata) GetTag ¶
func (x *TaggedRunMetadata) GetTag() string
func (*TaggedRunMetadata) ProtoMessage ¶
func (*TaggedRunMetadata) ProtoMessage()
func (*TaggedRunMetadata) ProtoReflect ¶
func (x *TaggedRunMetadata) ProtoReflect() protoreflect.Message
func (*TaggedRunMetadata) Reset ¶
func (x *TaggedRunMetadata) Reset()
func (*TaggedRunMetadata) String ¶
func (x *TaggedRunMetadata) String() string
type WatchdogConfig ¶
type WatchdogConfig struct { TimeoutMs int64 `protobuf:"varint,1,opt,name=timeout_ms,json=timeoutMs,proto3" json:"timeout_ms,omitempty"` // contains filtered or unexported fields }
func (*WatchdogConfig) Descriptor
deprecated
func (*WatchdogConfig) Descriptor() ([]byte, []int)
Deprecated: Use WatchdogConfig.ProtoReflect.Descriptor instead.
func (*WatchdogConfig) GetTimeoutMs ¶
func (x *WatchdogConfig) GetTimeoutMs() int64
func (*WatchdogConfig) ProtoMessage ¶
func (*WatchdogConfig) ProtoMessage()
func (*WatchdogConfig) ProtoReflect ¶
func (x *WatchdogConfig) ProtoReflect() protoreflect.Message
func (*WatchdogConfig) Reset ¶
func (x *WatchdogConfig) Reset()
func (*WatchdogConfig) String ¶
func (x *WatchdogConfig) String() string
type WorkerHealth ¶
type WorkerHealth int32
Current health status of a worker.
const ( WorkerHealth_OK WorkerHealth = 0 // By default a worker is healthy. WorkerHealth_RECEIVED_SHUTDOWN_SIGNAL WorkerHealth = 1 WorkerHealth_INTERNAL_ERROR WorkerHealth = 2 WorkerHealth_SHUTTING_DOWN WorkerHealth = 3 // Worker has been instructed to shutdown after a timeout. )
func (WorkerHealth) Descriptor ¶
func (WorkerHealth) Descriptor() protoreflect.EnumDescriptor
func (WorkerHealth) Enum ¶
func (x WorkerHealth) Enum() *WorkerHealth
func (WorkerHealth) EnumDescriptor
deprecated
func (WorkerHealth) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkerHealth.Descriptor instead.
func (WorkerHealth) Number ¶
func (x WorkerHealth) Number() protoreflect.EnumNumber
func (WorkerHealth) String ¶
func (x WorkerHealth) String() string
func (WorkerHealth) Type ¶
func (WorkerHealth) Type() protoreflect.EnumType
type WorkerHeartbeatRequest ¶
type WorkerHeartbeatRequest struct { ShutdownMode WorkerShutdownMode `` /* 133-byte string literal not displayed */ WatchdogConfig *WatchdogConfig `protobuf:"bytes,2,opt,name=watchdog_config,json=watchdogConfig,proto3" json:"watchdog_config,omitempty"` ExitCode *RequestedExitCode `protobuf:"bytes,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"` // contains filtered or unexported fields }
func (*WorkerHeartbeatRequest) Descriptor
deprecated
func (*WorkerHeartbeatRequest) Descriptor() ([]byte, []int)
Deprecated: Use WorkerHeartbeatRequest.ProtoReflect.Descriptor instead.
func (*WorkerHeartbeatRequest) GetExitCode ¶
func (x *WorkerHeartbeatRequest) GetExitCode() *RequestedExitCode
func (*WorkerHeartbeatRequest) GetShutdownMode ¶
func (x *WorkerHeartbeatRequest) GetShutdownMode() WorkerShutdownMode
func (*WorkerHeartbeatRequest) GetWatchdogConfig ¶
func (x *WorkerHeartbeatRequest) GetWatchdogConfig() *WatchdogConfig
func (*WorkerHeartbeatRequest) ProtoMessage ¶
func (*WorkerHeartbeatRequest) ProtoMessage()
func (*WorkerHeartbeatRequest) ProtoReflect ¶
func (x *WorkerHeartbeatRequest) ProtoReflect() protoreflect.Message
func (*WorkerHeartbeatRequest) Reset ¶
func (x *WorkerHeartbeatRequest) Reset()
func (*WorkerHeartbeatRequest) String ¶
func (x *WorkerHeartbeatRequest) String() string
type WorkerHeartbeatResponse ¶
type WorkerHeartbeatResponse struct { HealthStatus WorkerHealth `` /* 127-byte string literal not displayed */ WorkerLog []*Event `protobuf:"bytes,2,rep,name=worker_log,json=workerLog,proto3" json:"worker_log,omitempty"` Hostname string `protobuf:"bytes,3,opt,name=hostname,proto3" json:"hostname,omitempty"` // contains filtered or unexported fields }
func (*WorkerHeartbeatResponse) Descriptor
deprecated
func (*WorkerHeartbeatResponse) Descriptor() ([]byte, []int)
Deprecated: Use WorkerHeartbeatResponse.ProtoReflect.Descriptor instead.
func (*WorkerHeartbeatResponse) GetHealthStatus ¶
func (x *WorkerHeartbeatResponse) GetHealthStatus() WorkerHealth
func (*WorkerHeartbeatResponse) GetHostname ¶
func (x *WorkerHeartbeatResponse) GetHostname() string
func (*WorkerHeartbeatResponse) GetWorkerLog ¶
func (x *WorkerHeartbeatResponse) GetWorkerLog() []*Event
func (*WorkerHeartbeatResponse) ProtoMessage ¶
func (*WorkerHeartbeatResponse) ProtoMessage()
func (*WorkerHeartbeatResponse) ProtoReflect ¶
func (x *WorkerHeartbeatResponse) ProtoReflect() protoreflect.Message
func (*WorkerHeartbeatResponse) Reset ¶
func (x *WorkerHeartbeatResponse) Reset()
func (*WorkerHeartbeatResponse) String ¶
func (x *WorkerHeartbeatResponse) String() string
type WorkerShutdownMode ¶
type WorkerShutdownMode int32
Indicates the behavior of the worker when an internal error or shutdown signal is received.
const ( WorkerShutdownMode_DEFAULT WorkerShutdownMode = 0 WorkerShutdownMode_NOT_CONFIGURED WorkerShutdownMode = 1 WorkerShutdownMode_WAIT_FOR_COORDINATOR WorkerShutdownMode = 2 WorkerShutdownMode_SHUTDOWN_AFTER_TIMEOUT WorkerShutdownMode = 3 )
func (WorkerShutdownMode) Descriptor ¶
func (WorkerShutdownMode) Descriptor() protoreflect.EnumDescriptor
func (WorkerShutdownMode) Enum ¶
func (x WorkerShutdownMode) Enum() *WorkerShutdownMode
func (WorkerShutdownMode) EnumDescriptor
deprecated
func (WorkerShutdownMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use WorkerShutdownMode.Descriptor instead.
func (WorkerShutdownMode) Number ¶
func (x WorkerShutdownMode) Number() protoreflect.EnumNumber
func (WorkerShutdownMode) String ¶
func (x WorkerShutdownMode) String() string
func (WorkerShutdownMode) Type ¶
func (WorkerShutdownMode) Type() protoreflect.EnumType