ddpb

package
v1.9.0 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2024 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
var DataDistributionControl_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "o2.DataDistribution.Control.DataDistributionControl",
	HandlerType: (*DataDistributionControlServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PartitionInitialize",
			Handler:    _DataDistributionControl_PartitionInitialize_Handler,
		},
		{
			MethodName: "PartitionTerminate",
			Handler:    _DataDistributionControl_PartitionTerminate_Handler,
		},
		{
			MethodName: "PartitionStatus",
			Handler:    _DataDistributionControl_PartitionStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "protos/ddsched.proto",
}

DataDistributionControl_ServiceDesc is the grpc.ServiceDesc for DataDistributionControl 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_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 */
	// [optional] parameters passed from AliECS to TfScheduler
	PartitionParams map[string]string `` /* 194-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) GetPartitionParams added in v0.27.0 

func (x *PartitionInitRequest) GetPartitionParams() map[string]string

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.

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.