in sdks/go/pkg/beam/model/fnexecution_v1/beam_fn_api.pb.go [4911:5611]
func file_beam_fn_api_proto_init() {
if File_beam_fn_api_proto != nil {
return
}
if !protoimpl.UnsafeEnabled {
file_beam_fn_api_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RemoteGrpcPort); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*GetProcessBundleDescriptorRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*InstructionRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*InstructionResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*HarnessMonitoringInfosRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*HarnessMonitoringInfosResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RegisterRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*RegisterResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcessBundleDescriptor); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*BundleApplication); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*DelayedBundleApplication); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcessBundleRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcessBundleResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcessBundleProgressRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MonitoringInfosMetadataRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcessBundleProgressResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*MonitoringInfosMetadataResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcessBundleSplitRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcessBundleSplitResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*FinalizeBundleRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*FinalizeBundleResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Elements); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateKey); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[25].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateGetRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[26].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateGetResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[27].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateAppendRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[28].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateAppendResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[29].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateClearRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[30].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateClearResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[31].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*LogEntry); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[32].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*LogControl); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[33].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StartWorkerRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[34].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StartWorkerResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[35].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StopWorkerRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[36].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StopWorkerResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[37].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerStatusRequest); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[38].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*WorkerStatusResponse); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[46].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcessBundleRequest_CacheToken); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[47].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcessBundleRequest_CacheToken_UserState); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[48].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcessBundleRequest_CacheToken_SideInput); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[52].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcessBundleSplitRequest_DesiredSplit); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[54].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*ProcessBundleSplitResponse_ChannelSplit); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[55].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Elements_Data); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[56].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*Elements_Timers); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[57].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateKey_Runner); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[58].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateKey_IterableSideInput); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[59].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateKey_MultimapSideInput); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[60].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateKey_MultimapKeysSideInput); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[61].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*StateKey_BagUserState); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[62].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*LogEntry_List); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
file_beam_fn_api_proto_msgTypes[63].Exporter = func(v interface{}, i int) interface{} {
switch v := v.(*LogEntry_Severity); i {
case 0:
return &v.state
case 1:
return &v.sizeCache
case 2:
return &v.unknownFields
default:
return nil
}
}
}
file_beam_fn_api_proto_msgTypes[2].OneofWrappers = []interface{}{
(*InstructionRequest_ProcessBundle)(nil),
(*InstructionRequest_ProcessBundleProgress)(nil),
(*InstructionRequest_ProcessBundleSplit)(nil),
(*InstructionRequest_FinalizeBundle)(nil),
(*InstructionRequest_MonitoringInfos)(nil),
(*InstructionRequest_HarnessMonitoringInfos)(nil),
(*InstructionRequest_Register)(nil),
}
file_beam_fn_api_proto_msgTypes[3].OneofWrappers = []interface{}{
(*InstructionResponse_ProcessBundle)(nil),
(*InstructionResponse_ProcessBundleProgress)(nil),
(*InstructionResponse_ProcessBundleSplit)(nil),
(*InstructionResponse_FinalizeBundle)(nil),
(*InstructionResponse_MonitoringInfos)(nil),
(*InstructionResponse_HarnessMonitoringInfos)(nil),
(*InstructionResponse_Register)(nil),
}
file_beam_fn_api_proto_msgTypes[22].OneofWrappers = []interface{}{
(*StateRequest_Get)(nil),
(*StateRequest_Append)(nil),
(*StateRequest_Clear)(nil),
}
file_beam_fn_api_proto_msgTypes[23].OneofWrappers = []interface{}{
(*StateResponse_Get)(nil),
(*StateResponse_Append)(nil),
(*StateResponse_Clear)(nil),
}
file_beam_fn_api_proto_msgTypes[24].OneofWrappers = []interface{}{
(*StateKey_Runner_)(nil),
(*StateKey_MultimapSideInput_)(nil),
(*StateKey_BagUserState_)(nil),
(*StateKey_IterableSideInput_)(nil),
(*StateKey_MultimapKeysSideInput_)(nil),
}
file_beam_fn_api_proto_msgTypes[46].OneofWrappers = []interface{}{
(*ProcessBundleRequest_CacheToken_UserState_)(nil),
(*ProcessBundleRequest_CacheToken_SideInput_)(nil),
}
type x struct{}
out := protoimpl.TypeBuilder{
File: protoimpl.DescBuilder{
GoPackagePath: reflect.TypeOf(x{}).PkgPath(),
RawDescriptor: file_beam_fn_api_proto_rawDesc,
NumEnums: 1,
NumMessages: 65,
NumExtensions: 0,
NumServices: 6,
},
GoTypes: file_beam_fn_api_proto_goTypes,
DependencyIndexes: file_beam_fn_api_proto_depIdxs,
EnumInfos: file_beam_fn_api_proto_enumTypes,
MessageInfos: file_beam_fn_api_proto_msgTypes,
}.Build()
File_beam_fn_api_proto = out.File
file_beam_fn_api_proto_rawDesc = nil
file_beam_fn_api_proto_goTypes = nil
file_beam_fn_api_proto_depIdxs = nil
}