Documentation ¶
Index ¶
- Variables
- type ConnectRequest
- func (*ConnectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectRequest) GetClientId() uint64
- func (x *ConnectRequest) GetNodeId() int32
- func (x *ConnectRequest) GetProtocolVersion() int32
- func (x *ConnectRequest) GetTimeoutMilliseconds() int32
- func (*ConnectRequest) ProtoMessage()
- func (x *ConnectRequest) ProtoReflect() protoreflect.Message
- func (x *ConnectRequest) Reset()
- func (x *ConnectRequest) String() string
- type ConnectResponse
- type DeviceProto
- func (*DeviceProto) Descriptor() ([]byte, []int)deprecated
- func (x *DeviceProto) GetGlobalDeviceId() int32
- func (x *DeviceProto) GetLocalDeviceOrdinal() int32
- func (x *DeviceProto) GetName() string
- func (x *DeviceProto) GetVendor() string
- func (*DeviceProto) ProtoMessage()
- func (x *DeviceProto) ProtoReflect() protoreflect.Message
- func (x *DeviceProto) Reset()
- func (x *DeviceProto) String() string
- type EnumerateDevicesRequest
- func (*EnumerateDevicesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *EnumerateDevicesRequest) GetLocalTopology() *LocalTopologyProto
- func (x *EnumerateDevicesRequest) GetSessionId() uint64
- func (*EnumerateDevicesRequest) ProtoMessage()
- func (x *EnumerateDevicesRequest) ProtoReflect() protoreflect.Message
- func (x *EnumerateDevicesRequest) Reset()
- func (x *EnumerateDevicesRequest) String() string
- type EnumerateDevicesResponse
- func (*EnumerateDevicesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *EnumerateDevicesResponse) GetGlobalTopology() *GlobalTopologyProto
- func (*EnumerateDevicesResponse) ProtoMessage()
- func (x *EnumerateDevicesResponse) ProtoReflect() protoreflect.Message
- func (x *EnumerateDevicesResponse) Reset()
- func (x *EnumerateDevicesResponse) String() string
- type GlobalTopologyProto
- func (*GlobalTopologyProto) Descriptor() ([]byte, []int)deprecated
- func (x *GlobalTopologyProto) GetNodes() []*LocalTopologyProto
- func (*GlobalTopologyProto) ProtoMessage()
- func (x *GlobalTopologyProto) ProtoReflect() protoreflect.Message
- func (x *GlobalTopologyProto) Reset()
- func (x *GlobalTopologyProto) String() string
- type HeartbeatRequest
- func (*HeartbeatRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HeartbeatRequest) GetNodeId() int32
- func (x *HeartbeatRequest) GetSessionId() uint64
- func (*HeartbeatRequest) ProtoMessage()
- func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message
- func (x *HeartbeatRequest) Reset()
- func (x *HeartbeatRequest) String() string
- type HeartbeatResponse
- type KeyValueGetRequest
- func (*KeyValueGetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KeyValueGetRequest) GetKey() []byte
- func (x *KeyValueGetRequest) GetSessionId() uint64
- func (x *KeyValueGetRequest) GetTimeoutMilliseconds() int32
- func (*KeyValueGetRequest) ProtoMessage()
- func (x *KeyValueGetRequest) ProtoReflect() protoreflect.Message
- func (x *KeyValueGetRequest) Reset()
- func (x *KeyValueGetRequest) String() string
- type KeyValueGetResponse
- func (*KeyValueGetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *KeyValueGetResponse) GetFound() bool
- func (x *KeyValueGetResponse) GetValue() []byte
- func (*KeyValueGetResponse) ProtoMessage()
- func (x *KeyValueGetResponse) ProtoReflect() protoreflect.Message
- func (x *KeyValueGetResponse) Reset()
- func (x *KeyValueGetResponse) String() string
- type KeyValueSetRequest
- func (*KeyValueSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *KeyValueSetRequest) GetKey() []byte
- func (x *KeyValueSetRequest) GetSessionId() uint64
- func (x *KeyValueSetRequest) GetValue() []byte
- func (*KeyValueSetRequest) ProtoMessage()
- func (x *KeyValueSetRequest) ProtoReflect() protoreflect.Message
- func (x *KeyValueSetRequest) Reset()
- func (x *KeyValueSetRequest) String() string
- type KeyValueSetResponse
- type LocalTopologyProto
- func (*LocalTopologyProto) Descriptor() ([]byte, []int)deprecated
- func (x *LocalTopologyProto) GetDevices() []*DeviceProto
- func (x *LocalTopologyProto) GetNodeId() int32
- func (*LocalTopologyProto) ProtoMessage()
- func (x *LocalTopologyProto) ProtoReflect() protoreflect.Message
- func (x *LocalTopologyProto) Reset()
- func (x *LocalTopologyProto) String() string
- type ShutdownRequest
- func (*ShutdownRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ShutdownRequest) GetNodeId() int32
- func (x *ShutdownRequest) GetSessionId() uint64
- func (*ShutdownRequest) ProtoMessage()
- func (x *ShutdownRequest) ProtoReflect() protoreflect.Message
- func (x *ShutdownRequest) Reset()
- func (x *ShutdownRequest) String() string
- type ShutdownResponse
- type WaitAtBarrierRequest
- func (*WaitAtBarrierRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WaitAtBarrierRequest) GetBarrierId() []byte
- func (x *WaitAtBarrierRequest) GetNodeId() int32
- func (x *WaitAtBarrierRequest) GetSessionId() uint64
- func (x *WaitAtBarrierRequest) GetTimeoutMilliseconds() int32
- func (*WaitAtBarrierRequest) ProtoMessage()
- func (x *WaitAtBarrierRequest) ProtoReflect() protoreflect.Message
- func (x *WaitAtBarrierRequest) Reset()
- func (x *WaitAtBarrierRequest) String() string
- type WaitAtBarrierResponse
Constants ¶
This section is empty.
Variables ¶
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