Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterEventListenerServer(s grpc.ServiceRegistrar, srv EventListenerServer)
- type CallTraceback
- func (*CallTraceback) Descriptor() ([]byte, []int)deprecated
- func (x *CallTraceback) GetCallKey() string
- func (x *CallTraceback) GetCallType() CallTraceback_CallType
- func (x *CallTraceback) GetGraphTraceback() *profiler.OpLogProto
- func (x *CallTraceback) GetGraphVersion() int64
- func (x *CallTraceback) GetOriginIdToString() map[int64]string
- func (x *CallTraceback) GetOriginStack() *profiler.CodeDef
- func (*CallTraceback) ProtoMessage()
- func (x *CallTraceback) ProtoReflect() protoreflect.Message
- func (x *CallTraceback) Reset()
- func (x *CallTraceback) String() string
- type CallTraceback_CallType
- func (CallTraceback_CallType) Descriptor() protoreflect.EnumDescriptor
- func (x CallTraceback_CallType) Enum() *CallTraceback_CallType
- func (CallTraceback_CallType) EnumDescriptor() ([]byte, []int)deprecated
- func (x CallTraceback_CallType) Number() protoreflect.EnumNumber
- func (x CallTraceback_CallType) String() string
- func (CallTraceback_CallType) Type() protoreflect.EnumType
- type DebuggerEventMetadata
- func (*DebuggerEventMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *DebuggerEventMetadata) GetChunkIndex() int32
- func (x *DebuggerEventMetadata) GetDevice() string
- func (x *DebuggerEventMetadata) GetNumChunks() int32
- func (x *DebuggerEventMetadata) GetOutputSlot() int32
- func (*DebuggerEventMetadata) ProtoMessage()
- func (x *DebuggerEventMetadata) ProtoReflect() protoreflect.Message
- func (x *DebuggerEventMetadata) Reset()
- func (x *DebuggerEventMetadata) String() string
- type EventListenerClient
- type EventListenerServer
- type EventListener_SendEventsClient
- type EventListener_SendEventsServer
- type EventReply
- func (*EventReply) Descriptor() ([]byte, []int)deprecated
- func (x *EventReply) GetDebugOpStateChanges() []*EventReply_DebugOpStateChange
- func (x *EventReply) GetTensor() *framework.TensorProto
- func (*EventReply) ProtoMessage()
- func (x *EventReply) ProtoReflect() protoreflect.Message
- func (x *EventReply) Reset()
- func (x *EventReply) String() string
- type EventReply_DebugOpStateChange
- func (*EventReply_DebugOpStateChange) Descriptor() ([]byte, []int)deprecated
- func (x *EventReply_DebugOpStateChange) GetDebugOp() string
- func (x *EventReply_DebugOpStateChange) GetNodeName() string
- func (x *EventReply_DebugOpStateChange) GetOutputSlot() int32
- func (x *EventReply_DebugOpStateChange) GetState() EventReply_DebugOpStateChange_State
- func (*EventReply_DebugOpStateChange) ProtoMessage()
- func (x *EventReply_DebugOpStateChange) ProtoReflect() protoreflect.Message
- func (x *EventReply_DebugOpStateChange) Reset()
- func (x *EventReply_DebugOpStateChange) String() string
- type EventReply_DebugOpStateChange_State
- func (EventReply_DebugOpStateChange_State) Descriptor() protoreflect.EnumDescriptor
- func (x EventReply_DebugOpStateChange_State) Enum() *EventReply_DebugOpStateChange_State
- func (EventReply_DebugOpStateChange_State) EnumDescriptor() ([]byte, []int)deprecated
- func (x EventReply_DebugOpStateChange_State) Number() protoreflect.EnumNumber
- func (x EventReply_DebugOpStateChange_State) String() string
- func (EventReply_DebugOpStateChange_State) Type() protoreflect.EnumType
- type UnimplementedEventListenerServer
- func (UnimplementedEventListenerServer) SendEvents(EventListener_SendEventsServer) error
- func (UnimplementedEventListenerServer) SendSourceFiles(context.Context, *protobuf.DebuggedSourceFiles) (*EventReply, error)
- func (UnimplementedEventListenerServer) SendTracebacks(context.Context, *CallTraceback) (*EventReply, error)
- type UnsafeEventListenerServer
Constants ¶
const ( EventListener_SendEvents_FullMethodName = "/tensorflow.EventListener/SendEvents" EventListener_SendTracebacks_FullMethodName = "/tensorflow.EventListener/SendTracebacks" EventListener_SendSourceFiles_FullMethodName = "/tensorflow.EventListener/SendSourceFiles" )
Variables ¶
var ( EventReply_DebugOpStateChange_State_name = map[int32]string{ 0: "STATE_UNSPECIFIED", 1: "DISABLED", 2: "READ_ONLY", 3: "READ_WRITE", } EventReply_DebugOpStateChange_State_value = map[string]int32{ "STATE_UNSPECIFIED": 0, "DISABLED": 1, "READ_ONLY": 2, "READ_WRITE": 3, } )
Enum value maps for EventReply_DebugOpStateChange_State.
var ( CallTraceback_CallType_name = map[int32]string{ 0: "UNSPECIFIED", 1: "GRAPH_EXECUTION", 2: "EAGER_EXECUTION", } CallTraceback_CallType_value = map[string]int32{ "UNSPECIFIED": 0, "GRAPH_EXECUTION": 1, "EAGER_EXECUTION": 2, } )
Enum value maps for CallTraceback_CallType.
var EventListener_ServiceDesc = grpc.ServiceDesc{ ServiceName: "tensorflow.EventListener", HandlerType: (*EventListenerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SendTracebacks", Handler: _EventListener_SendTracebacks_Handler, }, { MethodName: "SendSourceFiles", Handler: _EventListener_SendSourceFiles_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "SendEvents", Handler: _EventListener_SendEvents_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "tensorflow/core/debug/debug_service.proto", }
EventListener_ServiceDesc is the grpc.ServiceDesc for EventListener service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_tensorflow_core_debug_debug_service_proto protoreflect.FileDescriptor
var File_tensorflow_core_debug_debugger_event_metadata_proto protoreflect.FileDescriptor
Functions ¶
func RegisterEventListenerServer ¶
func RegisterEventListenerServer(s grpc.ServiceRegistrar, srv EventListenerServer)
Types ¶
type CallTraceback ¶
type CallTraceback struct { CallType CallTraceback_CallType `protobuf:"varint,1,opt,name=call_type,json=callType,proto3,enum=tensorflow.CallTraceback_CallType" json:"call_type,omitempty"` // A key for the call. For example, for graph execution, this is a key // consisting of the names of the fed and fetched tensors. CallKey string `protobuf:"bytes,2,opt,name=call_key,json=callKey,proto3" json:"call_key,omitempty"` // Traceback stack for the origin of the call event. // For graph execution, this is the stack of the Session.run() call. // For eager execution, this is the stack of the Python line that invokes // the execution of the eager op. OriginStack *profiler.CodeDef `protobuf:"bytes,3,opt,name=origin_stack,json=originStack,proto3" json:"origin_stack,omitempty"` // Keeps track of the mapping from integer IDs in `origin_stack` to actual // string values (e.g., file paths, function names). OriginIdToString map[int64]string `` /* 202-byte string literal not displayed */ // Traceback for the graph (if any) involved in the call. GraphTraceback *profiler.OpLogProto `protobuf:"bytes,5,opt,name=graph_traceback,json=graphTraceback,proto3" json:"graph_traceback,omitempty"` // Version of the graph in `graph_traceback` (if any). GraphVersion int64 `protobuf:"varint,6,opt,name=graph_version,json=graphVersion,proto3" json:"graph_version,omitempty"` // contains filtered or unexported fields }
Data on the traceback of a debugged call, e.g., a Session.run() call, or the execution of an eager operation.
func (*CallTraceback) Descriptor
deprecated
func (*CallTraceback) Descriptor() ([]byte, []int)
Deprecated: Use CallTraceback.ProtoReflect.Descriptor instead.
func (*CallTraceback) GetCallKey ¶
func (x *CallTraceback) GetCallKey() string
func (*CallTraceback) GetCallType ¶
func (x *CallTraceback) GetCallType() CallTraceback_CallType
func (*CallTraceback) GetGraphTraceback ¶
func (x *CallTraceback) GetGraphTraceback() *profiler.OpLogProto
func (*CallTraceback) GetGraphVersion ¶
func (x *CallTraceback) GetGraphVersion() int64
func (*CallTraceback) GetOriginIdToString ¶
func (x *CallTraceback) GetOriginIdToString() map[int64]string
func (*CallTraceback) GetOriginStack ¶
func (x *CallTraceback) GetOriginStack() *profiler.CodeDef
func (*CallTraceback) ProtoMessage ¶
func (*CallTraceback) ProtoMessage()
func (*CallTraceback) ProtoReflect ¶
func (x *CallTraceback) ProtoReflect() protoreflect.Message
func (*CallTraceback) Reset ¶
func (x *CallTraceback) Reset()
func (*CallTraceback) String ¶
func (x *CallTraceback) String() string
type CallTraceback_CallType ¶
type CallTraceback_CallType int32
const ( CallTraceback_UNSPECIFIED CallTraceback_CallType = 0 CallTraceback_GRAPH_EXECUTION CallTraceback_CallType = 1 CallTraceback_EAGER_EXECUTION CallTraceback_CallType = 2 )
func (CallTraceback_CallType) Descriptor ¶
func (CallTraceback_CallType) Descriptor() protoreflect.EnumDescriptor
func (CallTraceback_CallType) Enum ¶
func (x CallTraceback_CallType) Enum() *CallTraceback_CallType
func (CallTraceback_CallType) EnumDescriptor
deprecated
func (CallTraceback_CallType) EnumDescriptor() ([]byte, []int)
Deprecated: Use CallTraceback_CallType.Descriptor instead.
func (CallTraceback_CallType) Number ¶
func (x CallTraceback_CallType) Number() protoreflect.EnumNumber
func (CallTraceback_CallType) String ¶
func (x CallTraceback_CallType) String() string
func (CallTraceback_CallType) Type ¶
func (CallTraceback_CallType) Type() protoreflect.EnumType
type DebuggerEventMetadata ¶
type DebuggerEventMetadata struct { Device string `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"` OutputSlot int32 `protobuf:"varint,2,opt,name=output_slot,json=outputSlot,proto3" json:"output_slot,omitempty"` NumChunks int32 `protobuf:"varint,3,opt,name=num_chunks,json=numChunks,proto3" json:"num_chunks,omitempty"` ChunkIndex int32 `protobuf:"varint,4,opt,name=chunk_index,json=chunkIndex,proto3" json:"chunk_index,omitempty"` // contains filtered or unexported fields }
Encapsulates per-event data related to debugging.
func (*DebuggerEventMetadata) Descriptor
deprecated
func (*DebuggerEventMetadata) Descriptor() ([]byte, []int)
Deprecated: Use DebuggerEventMetadata.ProtoReflect.Descriptor instead.
func (*DebuggerEventMetadata) GetChunkIndex ¶
func (x *DebuggerEventMetadata) GetChunkIndex() int32
func (*DebuggerEventMetadata) GetDevice ¶
func (x *DebuggerEventMetadata) GetDevice() string
func (*DebuggerEventMetadata) GetNumChunks ¶
func (x *DebuggerEventMetadata) GetNumChunks() int32
func (*DebuggerEventMetadata) GetOutputSlot ¶
func (x *DebuggerEventMetadata) GetOutputSlot() int32
func (*DebuggerEventMetadata) ProtoMessage ¶
func (*DebuggerEventMetadata) ProtoMessage()
func (*DebuggerEventMetadata) ProtoReflect ¶
func (x *DebuggerEventMetadata) ProtoReflect() protoreflect.Message
func (*DebuggerEventMetadata) Reset ¶
func (x *DebuggerEventMetadata) Reset()
func (*DebuggerEventMetadata) String ¶
func (x *DebuggerEventMetadata) String() string
type EventListenerClient ¶
type EventListenerClient interface { // Client(s) can use this RPC method to send the EventListener Event protos. // The Event protos can hold information such as: // 1. intermediate tensors from a debugged graph being executed, which can // be sent from DebugIdentity ops configured with grpc URLs. // 2. GraphDefs of partition graphs, which can be sent from special debug // ops that get executed immediately after the beginning of the graph // execution. SendEvents(ctx context.Context, opts ...grpc.CallOption) (EventListener_SendEventsClient, error) // Send the tracebacks of a TensorFlow execution call. SendTracebacks(ctx context.Context, in *CallTraceback, opts ...grpc.CallOption) (*EventReply, error) // Send a collection of source code files being debugged. SendSourceFiles(ctx context.Context, in *protobuf.DebuggedSourceFiles, opts ...grpc.CallOption) (*EventReply, error) }
EventListenerClient is the client API for EventListener 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 NewEventListenerClient ¶
func NewEventListenerClient(cc grpc.ClientConnInterface) EventListenerClient
type EventListenerServer ¶
type EventListenerServer interface { // Client(s) can use this RPC method to send the EventListener Event protos. // The Event protos can hold information such as: // 1. intermediate tensors from a debugged graph being executed, which can // be sent from DebugIdentity ops configured with grpc URLs. // 2. GraphDefs of partition graphs, which can be sent from special debug // ops that get executed immediately after the beginning of the graph // execution. SendEvents(EventListener_SendEventsServer) error // Send the tracebacks of a TensorFlow execution call. SendTracebacks(context.Context, *CallTraceback) (*EventReply, error) // Send a collection of source code files being debugged. SendSourceFiles(context.Context, *protobuf.DebuggedSourceFiles) (*EventReply, error) // contains filtered or unexported methods }
EventListenerServer is the server API for EventListener service. All implementations must embed UnimplementedEventListenerServer for forward compatibility
type EventListener_SendEventsClient ¶
type EventListener_SendEventsClient interface { Send(*util.Event) error Recv() (*EventReply, error) grpc.ClientStream }
type EventListener_SendEventsServer ¶
type EventListener_SendEventsServer interface { Send(*EventReply) error Recv() (*util.Event, error) grpc.ServerStream }
type EventReply ¶
type EventReply struct { DebugOpStateChanges []*EventReply_DebugOpStateChange `protobuf:"bytes,1,rep,name=debug_op_state_changes,json=debugOpStateChanges,proto3" json:"debug_op_state_changes,omitempty"` // New tensor value to override the current tensor value with. Tensor *framework.TensorProto `protobuf:"bytes,2,opt,name=tensor,proto3" json:"tensor,omitempty"` // contains filtered or unexported fields }
Reply message from EventListener to the client, i.e., to the source of the Event protocol buffers, e.g., debug ops inserted by a debugged runtime to a TensorFlow graph being executed.
func (*EventReply) Descriptor
deprecated
func (*EventReply) Descriptor() ([]byte, []int)
Deprecated: Use EventReply.ProtoReflect.Descriptor instead.
func (*EventReply) GetDebugOpStateChanges ¶
func (x *EventReply) GetDebugOpStateChanges() []*EventReply_DebugOpStateChange
func (*EventReply) GetTensor ¶
func (x *EventReply) GetTensor() *framework.TensorProto
func (*EventReply) ProtoMessage ¶
func (*EventReply) ProtoMessage()
func (*EventReply) ProtoReflect ¶
func (x *EventReply) ProtoReflect() protoreflect.Message
func (*EventReply) Reset ¶
func (x *EventReply) Reset()
func (*EventReply) String ¶
func (x *EventReply) String() string
type EventReply_DebugOpStateChange ¶
type EventReply_DebugOpStateChange struct { State EventReply_DebugOpStateChange_State `protobuf:"varint,1,opt,name=state,proto3,enum=tensorflow.EventReply_DebugOpStateChange_State" json:"state,omitempty"` NodeName string `protobuf:"bytes,2,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"` OutputSlot int32 `protobuf:"varint,3,opt,name=output_slot,json=outputSlot,proto3" json:"output_slot,omitempty"` DebugOp string `protobuf:"bytes,4,opt,name=debug_op,json=debugOp,proto3" json:"debug_op,omitempty"` // contains filtered or unexported fields }
func (*EventReply_DebugOpStateChange) Descriptor
deprecated
func (*EventReply_DebugOpStateChange) Descriptor() ([]byte, []int)
Deprecated: Use EventReply_DebugOpStateChange.ProtoReflect.Descriptor instead.
func (*EventReply_DebugOpStateChange) GetDebugOp ¶
func (x *EventReply_DebugOpStateChange) GetDebugOp() string
func (*EventReply_DebugOpStateChange) GetNodeName ¶
func (x *EventReply_DebugOpStateChange) GetNodeName() string
func (*EventReply_DebugOpStateChange) GetOutputSlot ¶
func (x *EventReply_DebugOpStateChange) GetOutputSlot() int32
func (*EventReply_DebugOpStateChange) GetState ¶
func (x *EventReply_DebugOpStateChange) GetState() EventReply_DebugOpStateChange_State
func (*EventReply_DebugOpStateChange) ProtoMessage ¶
func (*EventReply_DebugOpStateChange) ProtoMessage()
func (*EventReply_DebugOpStateChange) ProtoReflect ¶
func (x *EventReply_DebugOpStateChange) ProtoReflect() protoreflect.Message
func (*EventReply_DebugOpStateChange) Reset ¶
func (x *EventReply_DebugOpStateChange) Reset()
func (*EventReply_DebugOpStateChange) String ¶
func (x *EventReply_DebugOpStateChange) String() string
type EventReply_DebugOpStateChange_State ¶
type EventReply_DebugOpStateChange_State int32
const ( EventReply_DebugOpStateChange_STATE_UNSPECIFIED EventReply_DebugOpStateChange_State = 0 EventReply_DebugOpStateChange_DISABLED EventReply_DebugOpStateChange_State = 1 EventReply_DebugOpStateChange_READ_ONLY EventReply_DebugOpStateChange_State = 2 EventReply_DebugOpStateChange_READ_WRITE EventReply_DebugOpStateChange_State = 3 )
func (EventReply_DebugOpStateChange_State) Descriptor ¶
func (EventReply_DebugOpStateChange_State) Descriptor() protoreflect.EnumDescriptor
func (EventReply_DebugOpStateChange_State) Enum ¶
func (x EventReply_DebugOpStateChange_State) Enum() *EventReply_DebugOpStateChange_State
func (EventReply_DebugOpStateChange_State) EnumDescriptor
deprecated
func (EventReply_DebugOpStateChange_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use EventReply_DebugOpStateChange_State.Descriptor instead.
func (EventReply_DebugOpStateChange_State) Number ¶
func (x EventReply_DebugOpStateChange_State) Number() protoreflect.EnumNumber
func (EventReply_DebugOpStateChange_State) String ¶
func (x EventReply_DebugOpStateChange_State) String() string
func (EventReply_DebugOpStateChange_State) Type ¶
func (EventReply_DebugOpStateChange_State) Type() protoreflect.EnumType
type UnimplementedEventListenerServer ¶
type UnimplementedEventListenerServer struct { }
UnimplementedEventListenerServer must be embedded to have forward compatible implementations.
func (UnimplementedEventListenerServer) SendEvents ¶
func (UnimplementedEventListenerServer) SendEvents(EventListener_SendEventsServer) error
func (UnimplementedEventListenerServer) SendSourceFiles ¶
func (UnimplementedEventListenerServer) SendSourceFiles(context.Context, *protobuf.DebuggedSourceFiles) (*EventReply, error)
func (UnimplementedEventListenerServer) SendTracebacks ¶
func (UnimplementedEventListenerServer) SendTracebacks(context.Context, *CallTraceback) (*EventReply, error)
type UnsafeEventListenerServer ¶
type UnsafeEventListenerServer interface {
// contains filtered or unexported methods
}
UnsafeEventListenerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EventListenerServer will result in compilation errors.