Documentation ¶
Index ¶
- Variables
- func RegisterDataDistributionControlServer(s grpc.ServiceRegistrar, srv DataDistributionControlServer)
- type DataDistributionControlClient
- type DataDistributionControlServer
- type PartitionInfo
- func (*PartitionInfo) Descriptor() ([]byte, []int)deprecated
- func (x *PartitionInfo) GetEnvironmentId() string
- func (x *PartitionInfo) GetPartitionId() string
- func (*PartitionInfo) ProtoMessage()
- func (x *PartitionInfo) ProtoReflect() protoreflect.Message
- func (x *PartitionInfo) Reset()
- func (x *PartitionInfo) String() string
- type PartitionInitRequest
- func (*PartitionInitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PartitionInitRequest) GetPartitionInfo() *PartitionInfo
- func (x *PartitionInitRequest) GetStfbHostIdMap() map[string]string
- func (x *PartitionInitRequest) GetStfsHostIdMap() map[string]string
- func (*PartitionInitRequest) ProtoMessage()
- func (x *PartitionInitRequest) ProtoReflect() protoreflect.Message
- func (x *PartitionInitRequest) Reset()
- func (x *PartitionInitRequest) String() string
- type PartitionResponse
- func (*PartitionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PartitionResponse) GetInfoMessage() string
- func (x *PartitionResponse) GetPartitionState() PartitionState
- func (*PartitionResponse) ProtoMessage()
- func (x *PartitionResponse) ProtoReflect() protoreflect.Message
- func (x *PartitionResponse) Reset()
- func (x *PartitionResponse) String() string
- type PartitionState
- func (PartitionState) Descriptor() protoreflect.EnumDescriptor
- func (x PartitionState) Enum() *PartitionState
- func (PartitionState) EnumDescriptor() ([]byte, []int)deprecated
- func (x PartitionState) Number() protoreflect.EnumNumber
- func (x PartitionState) String() string
- func (PartitionState) Type() protoreflect.EnumType
- type PartitionTermRequest
- func (*PartitionTermRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PartitionTermRequest) GetPartitionInfo() *PartitionInfo
- func (*PartitionTermRequest) ProtoMessage()
- func (x *PartitionTermRequest) ProtoReflect() protoreflect.Message
- func (x *PartitionTermRequest) Reset()
- func (x *PartitionTermRequest) String() string
- type UnimplementedDataDistributionControlServer
- func (UnimplementedDataDistributionControlServer) PartitionInitialize(context.Context, *PartitionInitRequest) (*PartitionResponse, error)
- func (UnimplementedDataDistributionControlServer) PartitionStatus(context.Context, *PartitionInfo) (*PartitionResponse, error)
- func (UnimplementedDataDistributionControlServer) PartitionTerminate(context.Context, *PartitionTermRequest) (*PartitionResponse, error)
- type UnsafeDataDistributionControlServer
Constants ¶
This section is empty.
Variables ¶
var ( PartitionState_name = map[int32]string{ 0: "IGNORE__", 1: "PARTITION_UNKNOWN", 2: "PARTITION_ERROR", 3: "PARTITION_REQUEST_INVALID", 4: "PARTITION_CONFIGURING", 5: "PARTITION_CONFIGURED", 6: "PARTITION_TERMINATING", 7: "PARTITION_TERMINATED", } PartitionState_value = map[string]int32{ "IGNORE__": 0, "PARTITION_UNKNOWN": 1, "PARTITION_ERROR": 2, "PARTITION_REQUEST_INVALID": 3, "PARTITION_CONFIGURING": 4, "PARTITION_CONFIGURED": 5, "PARTITION_TERMINATING": 6, "PARTITION_TERMINATED": 7, } )
Enum value maps for PartitionState.
var File_protos_ddsched_proto protoreflect.FileDescriptor
Functions ¶
func RegisterDataDistributionControlServer ¶
func RegisterDataDistributionControlServer(s grpc.ServiceRegistrar, srv DataDistributionControlServer)
Types ¶
type DataDistributionControlClient ¶
type DataDistributionControlClient interface { // Partition management requests PartitionInitialize(ctx context.Context, in *PartitionInitRequest, opts ...grpc.CallOption) (*PartitionResponse, error) PartitionTerminate(ctx context.Context, in *PartitionTermRequest, opts ...grpc.CallOption) (*PartitionResponse, error) PartitionStatus(ctx context.Context, in *PartitionInfo, opts ...grpc.CallOption) (*PartitionResponse, error) }
DataDistributionControlClient is the client API for DataDistributionControl 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 NewDataDistributionControlClient ¶
func NewDataDistributionControlClient(cc grpc.ClientConnInterface) DataDistributionControlClient
type DataDistributionControlServer ¶
type DataDistributionControlServer interface { // Partition management requests PartitionInitialize(context.Context, *PartitionInitRequest) (*PartitionResponse, error) PartitionTerminate(context.Context, *PartitionTermRequest) (*PartitionResponse, error) PartitionStatus(context.Context, *PartitionInfo) (*PartitionResponse, error) }
DataDistributionControlServer is the server API for DataDistributionControl service. All implementations should embed UnimplementedDataDistributionControlServer for forward compatibility
type PartitionInfo ¶
type PartitionInfo struct { EnvironmentId string `protobuf:"bytes,1,opt,name=environment_id,json=environmentId,proto3" json:"environment_id,omitempty"` // AliECS environment ID (required) PartitionId string `protobuf:"bytes,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"` // Partition ID. (required) // contains filtered or unexported fields }
func (*PartitionInfo) Descriptor
deprecated
func (*PartitionInfo) Descriptor() ([]byte, []int)
Deprecated: Use PartitionInfo.ProtoReflect.Descriptor instead.
func (*PartitionInfo) GetEnvironmentId ¶
func (x *PartitionInfo) GetEnvironmentId() string
func (*PartitionInfo) GetPartitionId ¶
func (x *PartitionInfo) GetPartitionId() string
func (*PartitionInfo) ProtoMessage ¶
func (*PartitionInfo) ProtoMessage()
func (*PartitionInfo) ProtoReflect ¶
func (x *PartitionInfo) ProtoReflect() protoreflect.Message
func (*PartitionInfo) Reset ¶
func (x *PartitionInfo) Reset()
func (*PartitionInfo) String ¶
func (x *PartitionInfo) String() string
type PartitionInitRequest ¶
type PartitionInitRequest struct { PartitionInfo *PartitionInfo `protobuf:"bytes,1,opt,name=partition_info,json=partitionInfo,proto3" json:"partition_info,omitempty"` StfbHostIdMap map[string]string `` /* 192-byte string literal not displayed */ // Mapping between StfBuilder::discovery-id parameter and its FLP host name (must resolve to IB IP), for all // StfBuilder processes in the partition. StfsHostIdMap map[string]string `` /* 192-byte string literal not displayed */ // contains filtered or unexported fields }
Request for a new partition. AliECS provides the information about processes of DD in order for partition to be configured by TfScheduler. Partition request must include all processes. Adding additional processes to existing partition is not supported.
func (*PartitionInitRequest) Descriptor
deprecated
func (*PartitionInitRequest) Descriptor() ([]byte, []int)
Deprecated: Use PartitionInitRequest.ProtoReflect.Descriptor instead.
func (*PartitionInitRequest) GetPartitionInfo ¶
func (x *PartitionInitRequest) GetPartitionInfo() *PartitionInfo
func (*PartitionInitRequest) GetStfbHostIdMap ¶
func (x *PartitionInitRequest) GetStfbHostIdMap() map[string]string
func (*PartitionInitRequest) GetStfsHostIdMap ¶
func (x *PartitionInitRequest) GetStfsHostIdMap() map[string]string
func (*PartitionInitRequest) ProtoMessage ¶
func (*PartitionInitRequest) ProtoMessage()
func (*PartitionInitRequest) ProtoReflect ¶
func (x *PartitionInitRequest) ProtoReflect() protoreflect.Message
func (*PartitionInitRequest) Reset ¶
func (x *PartitionInitRequest) Reset()
func (*PartitionInitRequest) String ¶
func (x *PartitionInitRequest) String() string
type PartitionResponse ¶
type PartitionResponse struct { PartitionState PartitionState `` // Current or new state of the partition following reception of the request. /* 152-byte string literal not displayed */ InfoMessage string `protobuf:"bytes,2,opt,name=info_message,json=infoMessage,proto3" json:"info_message,omitempty"` // Optional information message. // contains filtered or unexported fields }
func (*PartitionResponse) Descriptor
deprecated
func (*PartitionResponse) Descriptor() ([]byte, []int)
Deprecated: Use PartitionResponse.ProtoReflect.Descriptor instead.
func (*PartitionResponse) GetInfoMessage ¶
func (x *PartitionResponse) GetInfoMessage() string
func (*PartitionResponse) GetPartitionState ¶
func (x *PartitionResponse) GetPartitionState() PartitionState
func (*PartitionResponse) ProtoMessage ¶
func (*PartitionResponse) ProtoMessage()
func (*PartitionResponse) ProtoReflect ¶
func (x *PartitionResponse) ProtoReflect() protoreflect.Message
func (*PartitionResponse) Reset ¶
func (x *PartitionResponse) Reset()
func (*PartitionResponse) String ¶
func (x *PartitionResponse) String() string
type PartitionState ¶
type PartitionState int32
const ( PartitionState_IGNORE__ PartitionState = 0 PartitionState_PARTITION_UNKNOWN PartitionState = 1 // Partition not known to DataDistControl. Initialize by calling PartitionInitialize() PartitionState_PARTITION_ERROR PartitionState = 2 PartitionState_PARTITION_REQUEST_INVALID PartitionState = 3 // Provided configuration does not meet requirements or the request is not accepted at the current state. PartitionState_PARTITION_CONFIGURING PartitionState = 4 // Configuration accepted, waiting on FLP and EPN DD components to respond and connect. PartitionState_PARTITION_CONFIGURED PartitionState = 5 // All components configured, ready for dataflow commands PartitionState_PARTITION_TERMINATING PartitionState = 6 // Partition is terminating. EPN-FLP connections will be cleanly closed. PartitionState_PARTITION_TERMINATED PartitionState = 7 // Partition is terminated. TfScheduler does not accept further requests )
func (PartitionState) Descriptor ¶
func (PartitionState) Descriptor() protoreflect.EnumDescriptor
func (PartitionState) Enum ¶
func (x PartitionState) Enum() *PartitionState
func (PartitionState) EnumDescriptor
deprecated
func (PartitionState) EnumDescriptor() ([]byte, []int)
Deprecated: Use PartitionState.Descriptor instead.
func (PartitionState) Number ¶
func (x PartitionState) Number() protoreflect.EnumNumber
func (PartitionState) String ¶
func (x PartitionState) String() string
func (PartitionState) Type ¶
func (PartitionState) Type() protoreflect.EnumType
type PartitionTermRequest ¶
type PartitionTermRequest struct { PartitionInfo *PartitionInfo `protobuf:"bytes,1,opt,name=partition_info,json=partitionInfo,proto3" json:"partition_info,omitempty"` // contains filtered or unexported fields }
Request for partition to be terminated. This operation will terminate all connections between EPN and FLP, and remove the partition from DD control-plane. Lifetime of individual DD components is managed by the respective FairMQ controller.
func (*PartitionTermRequest) Descriptor
deprecated
func (*PartitionTermRequest) Descriptor() ([]byte, []int)
Deprecated: Use PartitionTermRequest.ProtoReflect.Descriptor instead.
func (*PartitionTermRequest) GetPartitionInfo ¶
func (x *PartitionTermRequest) GetPartitionInfo() *PartitionInfo
func (*PartitionTermRequest) ProtoMessage ¶
func (*PartitionTermRequest) ProtoMessage()
func (*PartitionTermRequest) ProtoReflect ¶
func (x *PartitionTermRequest) ProtoReflect() protoreflect.Message
func (*PartitionTermRequest) Reset ¶
func (x *PartitionTermRequest) Reset()
func (*PartitionTermRequest) String ¶
func (x *PartitionTermRequest) String() string
type UnimplementedDataDistributionControlServer ¶
type UnimplementedDataDistributionControlServer struct { }
UnimplementedDataDistributionControlServer should be embedded to have forward compatible implementations.
func (UnimplementedDataDistributionControlServer) PartitionInitialize ¶
func (UnimplementedDataDistributionControlServer) PartitionInitialize(context.Context, *PartitionInitRequest) (*PartitionResponse, error)
func (UnimplementedDataDistributionControlServer) PartitionStatus ¶
func (UnimplementedDataDistributionControlServer) PartitionStatus(context.Context, *PartitionInfo) (*PartitionResponse, error)
func (UnimplementedDataDistributionControlServer) PartitionTerminate ¶
func (UnimplementedDataDistributionControlServer) PartitionTerminate(context.Context, *PartitionTermRequest) (*PartitionResponse, error)
type UnsafeDataDistributionControlServer ¶
type UnsafeDataDistributionControlServer interface {
// contains filtered or unexported methods
}
UnsafeDataDistributionControlServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DataDistributionControlServer will result in compilation errors.