protocol_go_proto

package
v0.0.0-...-8fd67a1 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2022 License: Apache-2.0, BSD-2-Clause Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_tensorflow_compiler_xla_pjrt_distributed_protocol_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ConnectRequest 

type ConnectRequest struct {
	ProtocolVersion     int32 `protobuf:"varint,1,opt,name=protocol_version,json=protocolVersion,proto3" json:"protocol_version,omitempty"`
	TimeoutMilliseconds int32 `protobuf:"varint,2,opt,name=timeout_milliseconds,json=timeoutMilliseconds,proto3" json:"timeout_milliseconds,omitempty"`
	// We assume that each node knows its globally-unique node ID, provided by
	// whatever mechanism launches the tasks. Node IDs should form a dense range
	// of integers [0, num_nodes).
	NodeId int32 `protobuf:"varint,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// A unique ID number for the client.
	ClientId uint64 `protobuf:"varint,4,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectRequest) Descriptor deprecated 

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

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetClientId 

func (x *ConnectRequest) GetClientId() uint64

func (*ConnectRequest) GetNodeId 

func (x *ConnectRequest) GetNodeId() int32

func (*ConnectRequest) GetProtocolVersion 

func (x *ConnectRequest) GetProtocolVersion() int32

func (*ConnectRequest) GetTimeoutMilliseconds 

func (x *ConnectRequest) GetTimeoutMilliseconds() int32

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) ProtoReflect 

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

func (*ConnectRequest) Reset 

func (x *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (x *ConnectRequest) String() string

type ConnectResponse 

type ConnectResponse struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectResponse) Descriptor deprecated 

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

Deprecated: Use ConnectResponse.ProtoReflect.Descriptor instead.

func (*ConnectResponse) GetSessionId 

func (x *ConnectResponse) GetSessionId() uint64

func (*ConnectResponse) ProtoMessage 

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) ProtoReflect 

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

func (*ConnectResponse) Reset 

func (x *ConnectResponse) Reset()

func (*ConnectResponse) String 

func (x *ConnectResponse) String() string

type DeviceProto 

type DeviceProto struct {
	LocalDeviceOrdinal int32  `protobuf:"varint,1,opt,name=local_device_ordinal,json=localDeviceOrdinal,proto3" json:"local_device_ordinal,omitempty"`
	Name               string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Vendor             string `protobuf:"bytes,3,opt,name=vendor,proto3" json:"vendor,omitempty"`
	// The following fields are present in the GlobalTopologyProto message
	// returned by EnumerateDevices() but not in the LocalTopologyProto messages
	// passed to EnumerateDevices(). In other words, the coordinator node
	// determines the global device IDs during EnumerateDevices().
	GlobalDeviceId int32 `protobuf:"varint,4,opt,name=global_device_id,json=globalDeviceId,proto3" json:"global_device_id,omitempty"` // Globally unique ID number.
	// contains filtered or unexported fields
}

Describes a device local to a host.

func (*DeviceProto) Descriptor deprecated 

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

Deprecated: Use DeviceProto.ProtoReflect.Descriptor instead.

func (*DeviceProto) GetGlobalDeviceId 

func (x *DeviceProto) GetGlobalDeviceId() int32

func (*DeviceProto) GetLocalDeviceOrdinal 

func (x *DeviceProto) GetLocalDeviceOrdinal() int32

func (*DeviceProto) GetName 

func (x *DeviceProto) GetName() string

func (*DeviceProto) GetVendor 

func (x *DeviceProto) GetVendor() string

func (*DeviceProto) ProtoMessage 

func (*DeviceProto) ProtoMessage()

func (*DeviceProto) ProtoReflect 

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

func (*DeviceProto) Reset 

func (x *DeviceProto) Reset()

func (*DeviceProto) String 

func (x *DeviceProto) String() string

type EnumerateDevicesRequest 

type EnumerateDevicesRequest struct {
	SessionId     uint64              `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	LocalTopology *LocalTopologyProto `protobuf:"bytes,3,opt,name=local_topology,json=localTopology,proto3" json:"local_topology,omitempty"`
	// contains filtered or unexported fields
}

func (*EnumerateDevicesRequest) Descriptor deprecated 

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

Deprecated: Use EnumerateDevicesRequest.ProtoReflect.Descriptor instead.

func (*EnumerateDevicesRequest) GetLocalTopology 

func (x *EnumerateDevicesRequest) GetLocalTopology() *LocalTopologyProto

func (*EnumerateDevicesRequest) GetSessionId 

func (x *EnumerateDevicesRequest) GetSessionId() uint64

func (*EnumerateDevicesRequest) ProtoMessage 

func (*EnumerateDevicesRequest) ProtoMessage()

func (*EnumerateDevicesRequest) ProtoReflect 

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

func (*EnumerateDevicesRequest) Reset 

func (x *EnumerateDevicesRequest) Reset()

func (*EnumerateDevicesRequest) String 

func (x *EnumerateDevicesRequest) String() string

type EnumerateDevicesResponse 

type EnumerateDevicesResponse struct {
	GlobalTopology *GlobalTopologyProto `protobuf:"bytes,1,opt,name=global_topology,json=globalTopology,proto3" json:"global_topology,omitempty"`
	// contains filtered or unexported fields
}

func (*EnumerateDevicesResponse) Descriptor deprecated 

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

Deprecated: Use EnumerateDevicesResponse.ProtoReflect.Descriptor instead.

func (*EnumerateDevicesResponse) GetGlobalTopology 

func (x *EnumerateDevicesResponse) GetGlobalTopology() *GlobalTopologyProto

func (*EnumerateDevicesResponse) ProtoMessage 

func (*EnumerateDevicesResponse) ProtoMessage()

func (*EnumerateDevicesResponse) ProtoReflect 

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

func (*EnumerateDevicesResponse) Reset 

func (x *EnumerateDevicesResponse) Reset()

func (*EnumerateDevicesResponse) String 

func (x *EnumerateDevicesResponse) String() string

type GlobalTopologyProto 

type GlobalTopologyProto struct {
	Nodes []*LocalTopologyProto `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*GlobalTopologyProto) Descriptor deprecated 

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

Deprecated: Use GlobalTopologyProto.ProtoReflect.Descriptor instead.

func (*GlobalTopologyProto) GetNodes 

func (x *GlobalTopologyProto) GetNodes() []*LocalTopologyProto

func (*GlobalTopologyProto) ProtoMessage 

func (*GlobalTopologyProto) ProtoMessage()

func (*GlobalTopologyProto) ProtoReflect 

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

func (*GlobalTopologyProto) Reset 

func (x *GlobalTopologyProto) Reset()

func (*GlobalTopologyProto) String 

func (x *GlobalTopologyProto) String() string

type HeartbeatRequest 

type HeartbeatRequest struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	NodeId    int32  `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*HeartbeatRequest) Descriptor deprecated 

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

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetNodeId 

func (x *HeartbeatRequest) GetNodeId() int32

func (*HeartbeatRequest) GetSessionId 

func (x *HeartbeatRequest) GetSessionId() uint64

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect 

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

func (*HeartbeatRequest) Reset 

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (x *HeartbeatRequest) String() string

type HeartbeatResponse 

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

func (*HeartbeatResponse) Descriptor deprecated 

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

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect 

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

func (*HeartbeatResponse) Reset 

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (x *HeartbeatResponse) String() string

type KeyValueGetRequest 

type KeyValueGetRequest struct {
	SessionId           uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Key                 []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	TimeoutMilliseconds int32  `protobuf:"varint,3,opt,name=timeout_milliseconds,json=timeoutMilliseconds,proto3" json:"timeout_milliseconds,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValueGetRequest) Descriptor deprecated 

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

Deprecated: Use KeyValueGetRequest.ProtoReflect.Descriptor instead.

func (*KeyValueGetRequest) GetKey 

func (x *KeyValueGetRequest) GetKey() []byte

func (*KeyValueGetRequest) GetSessionId 

func (x *KeyValueGetRequest) GetSessionId() uint64

func (*KeyValueGetRequest) GetTimeoutMilliseconds 

func (x *KeyValueGetRequest) GetTimeoutMilliseconds() int32

func (*KeyValueGetRequest) ProtoMessage 

func (*KeyValueGetRequest) ProtoMessage()

func (*KeyValueGetRequest) ProtoReflect 

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

func (*KeyValueGetRequest) Reset 

func (x *KeyValueGetRequest) Reset()

func (*KeyValueGetRequest) String 

func (x *KeyValueGetRequest) String() string

type KeyValueGetResponse 

type KeyValueGetResponse struct {
	Found bool   `protobuf:"varint,1,opt,name=found,proto3" json:"found,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValueGetResponse) Descriptor deprecated 

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

Deprecated: Use KeyValueGetResponse.ProtoReflect.Descriptor instead.

func (*KeyValueGetResponse) GetFound 

func (x *KeyValueGetResponse) GetFound() bool

func (*KeyValueGetResponse) GetValue 

func (x *KeyValueGetResponse) GetValue() []byte

func (*KeyValueGetResponse) ProtoMessage 

func (*KeyValueGetResponse) ProtoMessage()

func (*KeyValueGetResponse) ProtoReflect 

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

func (*KeyValueGetResponse) Reset 

func (x *KeyValueGetResponse) Reset()

func (*KeyValueGetResponse) String 

func (x *KeyValueGetResponse) String() string

type KeyValueSetRequest 

type KeyValueSetRequest struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Key       []byte `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*KeyValueSetRequest) Descriptor deprecated 

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

Deprecated: Use KeyValueSetRequest.ProtoReflect.Descriptor instead.

func (*KeyValueSetRequest) GetKey 

func (x *KeyValueSetRequest) GetKey() []byte

func (*KeyValueSetRequest) GetSessionId 

func (x *KeyValueSetRequest) GetSessionId() uint64

func (*KeyValueSetRequest) GetValue 

func (x *KeyValueSetRequest) GetValue() []byte

func (*KeyValueSetRequest) ProtoMessage 

func (*KeyValueSetRequest) ProtoMessage()

func (*KeyValueSetRequest) ProtoReflect 

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

func (*KeyValueSetRequest) Reset 

func (x *KeyValueSetRequest) Reset()

func (*KeyValueSetRequest) String 

func (x *KeyValueSetRequest) String() string

type KeyValueSetResponse 

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

func (*KeyValueSetResponse) Descriptor deprecated 

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

Deprecated: Use KeyValueSetResponse.ProtoReflect.Descriptor instead.

func (*KeyValueSetResponse) ProtoMessage 

func (*KeyValueSetResponse) ProtoMessage()

func (*KeyValueSetResponse) ProtoReflect 

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

func (*KeyValueSetResponse) Reset 

func (x *KeyValueSetResponse) Reset()

func (*KeyValueSetResponse) String 

func (x *KeyValueSetResponse) String() string

type LocalTopologyProto 

type LocalTopologyProto struct {
	NodeId  int32          `protobuf:"varint,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Devices []*DeviceProto `protobuf:"bytes,2,rep,name=devices,proto3" json:"devices,omitempty"`
	// contains filtered or unexported fields
}

func (*LocalTopologyProto) Descriptor deprecated 

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

Deprecated: Use LocalTopologyProto.ProtoReflect.Descriptor instead.

func (*LocalTopologyProto) GetDevices 

func (x *LocalTopologyProto) GetDevices() []*DeviceProto

func (*LocalTopologyProto) GetNodeId 

func (x *LocalTopologyProto) GetNodeId() int32

func (*LocalTopologyProto) ProtoMessage 

func (*LocalTopologyProto) ProtoMessage()

func (*LocalTopologyProto) ProtoReflect 

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

func (*LocalTopologyProto) Reset 

func (x *LocalTopologyProto) Reset()

func (*LocalTopologyProto) String 

func (x *LocalTopologyProto) String() string

type ShutdownRequest 

type ShutdownRequest struct {
	SessionId uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	NodeId    int32  `protobuf:"varint,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ShutdownRequest) Descriptor deprecated 

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) GetNodeId 

func (x *ShutdownRequest) GetNodeId() int32

func (*ShutdownRequest) GetSessionId 

func (x *ShutdownRequest) GetSessionId() uint64

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect 

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

func (*ShutdownRequest) Reset 

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (x *ShutdownRequest) String() string

type ShutdownResponse 

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

func (*ShutdownResponse) Descriptor deprecated 

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

Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.

func (*ShutdownResponse) ProtoMessage 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) ProtoReflect 

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

func (*ShutdownResponse) Reset 

func (x *ShutdownResponse) Reset()

func (*ShutdownResponse) String 

func (x *ShutdownResponse) String() string

type WaitAtBarrierRequest 

type WaitAtBarrierRequest struct {
	SessionId           uint64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	BarrierId           []byte `protobuf:"bytes,2,opt,name=barrier_id,json=barrierId,proto3" json:"barrier_id,omitempty"`
	NodeId              int32  `protobuf:"varint,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	TimeoutMilliseconds int32  `protobuf:"varint,4,opt,name=timeout_milliseconds,json=timeoutMilliseconds,proto3" json:"timeout_milliseconds,omitempty"`
	// contains filtered or unexported fields
}

func (*WaitAtBarrierRequest) Descriptor deprecated 

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

Deprecated: Use WaitAtBarrierRequest.ProtoReflect.Descriptor instead.

func (*WaitAtBarrierRequest) GetBarrierId 

func (x *WaitAtBarrierRequest) GetBarrierId() []byte

func (*WaitAtBarrierRequest) GetNodeId 

func (x *WaitAtBarrierRequest) GetNodeId() int32

func (*WaitAtBarrierRequest) GetSessionId 

func (x *WaitAtBarrierRequest) GetSessionId() uint64

func (*WaitAtBarrierRequest) GetTimeoutMilliseconds 

func (x *WaitAtBarrierRequest) GetTimeoutMilliseconds() int32

func (*WaitAtBarrierRequest) ProtoMessage 

func (*WaitAtBarrierRequest) ProtoMessage()

func (*WaitAtBarrierRequest) ProtoReflect 

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

func (*WaitAtBarrierRequest) Reset 

func (x *WaitAtBarrierRequest) Reset()

func (*WaitAtBarrierRequest) String 

func (x *WaitAtBarrierRequest) String() string

type WaitAtBarrierResponse 

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

func (*WaitAtBarrierResponse) Descriptor deprecated 

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

Deprecated: Use WaitAtBarrierResponse.ProtoReflect.Descriptor instead.

func (*WaitAtBarrierResponse) ProtoMessage 

func (*WaitAtBarrierResponse) ProtoMessage()

func (*WaitAtBarrierResponse) ProtoReflect 

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

func (*WaitAtBarrierResponse) Reset 

func (x *WaitAtBarrierResponse) Reset()

func (*WaitAtBarrierResponse) String 

func (x *WaitAtBarrierResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.