distributed

package
v0.0.0-...-3233e8b Latest Latest
Warning

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

 Go to latest Published: Dec 8, 2023 License: BSD-3-Clause Imports: 8 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	DistributedRuntimeService_Connect_FullMethodName          = "/xla.DistributedRuntimeService/Connect"
	DistributedRuntimeService_EnumerateDevices_FullMethodName = "/xla.DistributedRuntimeService/EnumerateDevices"
	DistributedRuntimeService_Heartbeat_FullMethodName        = "/xla.DistributedRuntimeService/Heartbeat"
	DistributedRuntimeService_Shutdown_FullMethodName         = "/xla.DistributedRuntimeService/Shutdown"
	DistributedRuntimeService_KeyValueGet_FullMethodName      = "/xla.DistributedRuntimeService/KeyValueGet"
	DistributedRuntimeService_KeyValueSet_FullMethodName      = "/xla.DistributedRuntimeService/KeyValueSet"
	DistributedRuntimeService_WaitAtBarrier_FullMethodName    = "/xla.DistributedRuntimeService/WaitAtBarrier"
)

Variables

View Source 
var DistributedRuntimeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "xla.DistributedRuntimeService",
	HandlerType: (*DistributedRuntimeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Connect",
			Handler:    _DistributedRuntimeService_Connect_Handler,
		},
		{
			MethodName: "EnumerateDevices",
			Handler:    _DistributedRuntimeService_EnumerateDevices_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _DistributedRuntimeService_Heartbeat_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _DistributedRuntimeService_Shutdown_Handler,
		},
		{
			MethodName: "KeyValueGet",
			Handler:    _DistributedRuntimeService_KeyValueGet_Handler,
		},
		{
			MethodName: "KeyValueSet",
			Handler:    _DistributedRuntimeService_KeyValueSet_Handler,
		},
		{
			MethodName: "WaitAtBarrier",
			Handler:    _DistributedRuntimeService_WaitAtBarrier_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "tensorflow/compiler/xla/pjrt/distributed/protocol.proto",
}

DistributedRuntimeService_ServiceDesc is the grpc.ServiceDesc for DistributedRuntimeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_tensorflow_compiler_xla_pjrt_distributed_protocol_proto protoreflect.FileDescriptor

Functions

func RegisterDistributedRuntimeServiceServer 

func RegisterDistributedRuntimeServiceServer(s grpc.ServiceRegistrar, srv DistributedRuntimeServiceServer)

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 DistributedRuntimeServiceClient 

type DistributedRuntimeServiceClient interface {
	// Connects a node to the distributed coordinator node. Blocks until all tasks
	// have connected. The service receives the number of nodes to expect as an
	// option passed to its constructor.
	Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error)
	// Blocking enumeration of devices, used by the GPU backend only.
	// In parallel, all clients call EnumerateDevices() with their local device
	// topology, and receive back a global topology in response.
	EnumerateDevices(ctx context.Context, in *EnumerateDevicesRequest, opts ...grpc.CallOption) (*EnumerateDevicesResponse, error)
	// Health-checking RPC. Workers send heartbeats to the coordinator at regular
	// intervals. If the worker does not hear from the coordinator or the
	// coordinator does not hear from the tasks, the tasks abort.
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	// Shutdown RPC. Workers send this RPC when they are ready to shut down; the
	// RPC blocks until all tasks have indicated they are ready to shut down,
	// or a timeout is reached.
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
	// Looks up a key in the key-value service. Blocks until the key is present
	// or until `timeout` expires.
	KeyValueGet(ctx context.Context, in *KeyValueGetRequest, opts ...grpc.CallOption) (*KeyValueGetResponse, error)
	// Updates the value associated with a key.
	KeyValueSet(ctx context.Context, in *KeyValueSetRequest, opts ...grpc.CallOption) (*KeyValueSetResponse, error)
	// Blocks until all nodes are at the barrier or the barrier times out.
	WaitAtBarrier(ctx context.Context, in *WaitAtBarrierRequest, opts ...grpc.CallOption) (*WaitAtBarrierResponse, error)
}

DistributedRuntimeServiceClient is the client API for DistributedRuntimeService 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 NewDistributedRuntimeServiceClient 

func NewDistributedRuntimeServiceClient(cc grpc.ClientConnInterface) DistributedRuntimeServiceClient

type DistributedRuntimeServiceServer 

type DistributedRuntimeServiceServer interface {
	// Connects a node to the distributed coordinator node. Blocks until all tasks
	// have connected. The service receives the number of nodes to expect as an
	// option passed to its constructor.
	Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)
	// Blocking enumeration of devices, used by the GPU backend only.
	// In parallel, all clients call EnumerateDevices() with their local device
	// topology, and receive back a global topology in response.
	EnumerateDevices(context.Context, *EnumerateDevicesRequest) (*EnumerateDevicesResponse, error)
	// Health-checking RPC. Workers send heartbeats to the coordinator at regular
	// intervals. If the worker does not hear from the coordinator or the
	// coordinator does not hear from the tasks, the tasks abort.
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	// Shutdown RPC. Workers send this RPC when they are ready to shut down; the
	// RPC blocks until all tasks have indicated they are ready to shut down,
	// or a timeout is reached.
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
	// Looks up a key in the key-value service. Blocks until the key is present
	// or until `timeout` expires.
	KeyValueGet(context.Context, *KeyValueGetRequest) (*KeyValueGetResponse, error)
	// Updates the value associated with a key.
	KeyValueSet(context.Context, *KeyValueSetRequest) (*KeyValueSetResponse, error)
	// Blocks until all nodes are at the barrier or the barrier times out.
	WaitAtBarrier(context.Context, *WaitAtBarrierRequest) (*WaitAtBarrierResponse, error)
	// contains filtered or unexported methods
}

DistributedRuntimeServiceServer is the server API for DistributedRuntimeService service. All implementations must embed UnimplementedDistributedRuntimeServiceServer for forward compatibility

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 UnimplementedDistributedRuntimeServiceServer 

type UnimplementedDistributedRuntimeServiceServer struct {
}

UnimplementedDistributedRuntimeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDistributedRuntimeServiceServer) Connect 

func (UnimplementedDistributedRuntimeServiceServer) Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)

func (UnimplementedDistributedRuntimeServiceServer) EnumerateDevices 

func (UnimplementedDistributedRuntimeServiceServer) EnumerateDevices(context.Context, *EnumerateDevicesRequest) (*EnumerateDevicesResponse, error)

func (UnimplementedDistributedRuntimeServiceServer) Heartbeat 

func (UnimplementedDistributedRuntimeServiceServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)

func (UnimplementedDistributedRuntimeServiceServer) KeyValueGet 

func (UnimplementedDistributedRuntimeServiceServer) KeyValueGet(context.Context, *KeyValueGetRequest) (*KeyValueGetResponse, error)

func (UnimplementedDistributedRuntimeServiceServer) KeyValueSet 

func (UnimplementedDistributedRuntimeServiceServer) KeyValueSet(context.Context, *KeyValueSetRequest) (*KeyValueSetResponse, error)

func (UnimplementedDistributedRuntimeServiceServer) Shutdown 

func (UnimplementedDistributedRuntimeServiceServer) Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)

func (UnimplementedDistributedRuntimeServiceServer) WaitAtBarrier 

func (UnimplementedDistributedRuntimeServiceServer) WaitAtBarrier(context.Context, *WaitAtBarrierRequest) (*WaitAtBarrierResponse, error)

type UnsafeDistributedRuntimeServiceServer 

type UnsafeDistributedRuntimeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDistributedRuntimeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DistributedRuntimeServiceServer will result in compilation errors.

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.