Package allieflowkitgrpc

const (
    // Verify that this generated code is sufficiently up-to-date.
    _ = protoimpl.EnforceVersion(20 - protoimpl.MinVersion)
    // Verify that runtime/protoimpl is sufficiently up-to-date.
    _ = protoimpl.EnforceVersion(protoimpl.MaxVersion - 20)
)

const (
    ExternalFunctions_ListFunctions_FullMethodName  = "/allieflowkitgrpc.ExternalFunctions/ListFunctions"
    ExternalFunctions_RunFunction_FullMethodName    = "/allieflowkitgrpc.ExternalFunctions/RunFunction"
    ExternalFunctions_StreamFunction_FullMethodName = "/allieflowkitgrpc.ExternalFunctions/StreamFunction"
)

This is a compile-time assertion to ensure that this generated file is compatible with the grpc package it is being compiled against. Requires gRPC-Go v1.64.0 or later.

const _ = grpc.SupportPackageIsVersion9

Variables

var (
    file_pkg_allieflowkitgrpc_allie_flowkit_proto_rawDescOnce sync.Once
    file_pkg_allieflowkitgrpc_allie_flowkit_proto_rawDescData = file_pkg_allieflowkitgrpc_allie_flowkit_proto_rawDesc
)

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

var ExternalFunctions_ServiceDesc = grpc.ServiceDesc{
    ServiceName: "allieflowkitgrpc.ExternalFunctions",
    HandlerType: (*ExternalFunctionsServer)(nil),
    Methods: []grpc.MethodDesc{
        {
            MethodName: "ListFunctions",
            Handler:    _ExternalFunctions_ListFunctions_Handler,
        },
        {
            MethodName: "RunFunction",
            Handler:    _ExternalFunctions_RunFunction_Handler,
        },
    },
    Streams: []grpc.StreamDesc{
        {
            StreamName:    "StreamFunction",
            Handler:       _ExternalFunctions_StreamFunction_Handler,
            ServerStreams: true,
        },
    },
    Metadata: "pkg/allieflowkitgrpc/allie-flowkit.proto",
}

var File_pkg_allieflowkitgrpc_allie_flowkit_proto protoreflect.FileDescriptor

var file_pkg_allieflowkitgrpc_allie_flowkit_proto_depIdxs = []int32{
    10,
    3,
    4,
    6,
    8,
    2,
    0,
    5,
    5,
    1,
    7,
    9,
    9,
    6,
    6,
    6,
    0,
}

var file_pkg_allieflowkitgrpc_allie_flowkit_proto_goTypes = []any{
    (*ListFunctionsRequest)(nil),
    (*ListFunctionsResponse)(nil),
    (*FunctionDefinition)(nil),
    (*FunctionInputDefinition)(nil),
    (*FunctionOutputDefinition)(nil),
    (*FunctionInputs)(nil),
    (*FunctionInput)(nil),
    (*FunctionOutputs)(nil),
    (*FunctionOutput)(nil),
    (*StreamOutput)(nil),
    nil,
}

var file_pkg_allieflowkitgrpc_allie_flowkit_proto_msgTypes = make([]protoimpl.MessageInfo, 11)

var file_pkg_allieflowkitgrpc_allie_flowkit_proto_rawDesc = []byte{
    0x0a, 0x28, 0x70, 0x6b, 0x67, 0x2f, 0x61, 0x6c, 0x6c, 0x69, 0x65, 0x66, 0x6c, 0x6f, 0x77, 0x6b,
    0x69, 0x74, 0x67, 0x72, 0x70, 0x63, 0x2f, 0x61, 0x6c, 0x6c, 0x69, 0x65, 0x2d, 0x66, 0x6c, 0x6f,
    0x77, 0x6b, 0x69, 0x74, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x12, 0x10, 0x61, 0x6c, 0x6c, 0x69,
    0x65, 0x66, 0x6c, 0x6f, 0x77, 0x6b, 0x69, 0x74, 0x67, 0x72, 0x70, 0x63, 0x22, 0x16, 0x0a, 0x14,
    0x4c, 0x69, 0x73, 0x74, 0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71,
    0x75, 0x65, 0x73, 0x74, 0x22, 0xd1, 0x01, 0x0a, 0x15, 0x4c, 0x69, 0x73, 0x74, 0x46, 0x75, 0x6e,
    0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x12, 0x54,
    0x0a, 0x09, 0x66, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18, 0x01, 0x20, 0x03, 0x28,
    0x0b, 0x32, 0x36, 0x2e, 0x61, 0x6c, 0x6c, 0x69, 0x65, 0x66, 0x6c, 0x6f, 0x77, 0x6b, 0x69, 0x74,
    0x67, 0x72, 0x70, 0x63, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f,
    0x6e, 0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x2e, 0x46, 0x75, 0x6e, 0x63, 0x74,
    0x69, 0x6f, 0x6e, 0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x52, 0x09, 0x66, 0x75, 0x6e, 0x63, 0x74,
    0x69, 0x6f, 0x6e, 0x73, 0x1a, 0x62, 0x0a, 0x0e, 0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e,
    0x73, 0x45, 0x6e, 0x74, 0x72, 0x79, 0x12, 0x10, 0x0a, 0x03, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20,
    0x01, 0x28, 0x09, 0x52, 0x03, 0x6b, 0x65, 0x79, 0x12, 0x3a, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75,
    0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x24, 0x2e, 0x61, 0x6c, 0x6c, 0x69, 0x65, 0x66,
    0x6c, 0x6f, 0x77, 0x6b, 0x69, 0x74, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x46, 0x75, 0x6e, 0x63, 0x74,
    0x69, 0x6f, 0x6e, 0x44, 0x65, 0x66, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x05, 0x76,
    0x61, 0x6c, 0x75, 0x65, 0x3a, 0x02, 0x38, 0x01, 0x22, 0x8d, 0x02, 0x0a, 0x12, 0x46, 0x75, 0x6e,
    0x63, 0x74, 0x69, 0x6f, 0x6e, 0x44, 0x65, 0x66, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x12,
    0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e,
    0x61, 0x6d, 0x65, 0x12, 0x20, 0x0a, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69, 0x70, 0x74, 0x69,
    0x6f, 0x6e, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x64, 0x65, 0x73, 0x63, 0x72, 0x69,
    0x70, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x1a, 0x0a, 0x08, 0x63, 0x61, 0x74, 0x65, 0x67, 0x6f, 0x72,
    0x79, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x08, 0x63, 0x61, 0x74, 0x65, 0x67, 0x6f, 0x72,
    0x79, 0x12, 0x20, 0x0a, 0x0b, 0x64, 0x69, 0x73, 0x70, 0x6c, 0x61, 0x79, 0x4e, 0x61, 0x6d, 0x65,
    0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0b, 0x64, 0x69, 0x73, 0x70, 0x6c, 0x61, 0x79, 0x4e,
    0x61, 0x6d, 0x65, 0x12, 0x3f, 0x0a, 0x05, 0x69, 0x6e, 0x70, 0x75, 0x74, 0x18, 0x05, 0x20, 0x03,
    0x28, 0x0b, 0x32, 0x29, 0x2e, 0x61, 0x6c, 0x6c, 0x69, 0x65, 0x66, 0x6c, 0x6f, 0x77, 0x6b, 0x69,
    0x74, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x6e,
    0x70, 0x75, 0x74, 0x44, 0x65, 0x66, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x52, 0x05, 0x69,
    0x6e, 0x70, 0x75, 0x74, 0x12, 0x42, 0x0a, 0x06, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x18, 0x06,
    0x20, 0x03, 0x28, 0x0b, 0x32, 0x2a, 0x2e, 0x61, 0x6c, 0x6c, 0x69, 0x65, 0x66, 0x6c, 0x6f, 0x77,
    0x6b, 0x69, 0x74, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e,
    0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x44, 0x65, 0x66, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x6f, 0x6e,
    0x52, 0x06, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x22, 0x74, 0x0a, 0x17, 0x46, 0x75, 0x6e, 0x63,
    0x74, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x70, 0x75, 0x74, 0x44, 0x65, 0x66, 0x69, 0x6e, 0x69, 0x74,
    0x69, 0x6f, 0x6e, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
    0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18,
    0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x17, 0x0a, 0x07, 0x67,
    0x6f, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x67, 0x6f,
    0x54, 0x79, 0x70, 0x65, 0x12, 0x18, 0x0a, 0x07, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x18,
    0x04, 0x20, 0x03, 0x28, 0x09, 0x52, 0x07, 0x6f, 0x70, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x22, 0x5b,
    0x0a, 0x18, 0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74,
    0x44, 0x65, 0x66, 0x69, 0x6e, 0x69, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61,
    0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x12,
    0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x74, 0x79,
    0x70, 0x65, 0x12, 0x17, 0x0a, 0x07, 0x67, 0x6f, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x03, 0x20,
    0x01, 0x28, 0x09, 0x52, 0x06, 0x67, 0x6f, 0x54, 0x79, 0x70, 0x65, 0x22, 0x5d, 0x0a, 0x0e, 0x46,
    0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x70, 0x75, 0x74, 0x73, 0x12, 0x12, 0x0a,
    0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d,
    0x65, 0x12, 0x37, 0x0a, 0x06, 0x69, 0x6e, 0x70, 0x75, 0x74, 0x73, 0x18, 0x02, 0x20, 0x03, 0x28,
    0x0b, 0x32, 0x1f, 0x2e, 0x61, 0x6c, 0x6c, 0x69, 0x65, 0x66, 0x6c, 0x6f, 0x77, 0x6b, 0x69, 0x74,
    0x67, 0x72, 0x70, 0x63, 0x2e, 0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x70,
    0x75, 0x74, 0x52, 0x06, 0x69, 0x6e, 0x70, 0x75, 0x74, 0x73, 0x22, 0x52, 0x0a, 0x0d, 0x46, 0x75,
    0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x70, 0x75, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e,
    0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12,
    0x17, 0x0a, 0x07, 0x67, 0x6f, 0x5f, 0x74, 0x79, 0x70, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09,
    0x52, 0x06, 0x67, 0x6f, 0x54, 0x79, 0x70, 0x65, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75,
    0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x22, 0x61,
    0x0a, 0x0f, 0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74,
    0x73, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52,
    0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x3a, 0x0a, 0x07, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73,
    0x18, 0x02, 0x20, 0x03, 0x28, 0x0b, 0x32, 0x20, 0x2e, 0x61, 0x6c, 0x6c, 0x69, 0x65, 0x66, 0x6c,
    0x6f, 0x77, 0x6b, 0x69, 0x74, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x46, 0x75, 0x6e, 0x63, 0x74, 0x69,
    0x6f, 0x6e, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x52, 0x07, 0x6f, 0x75, 0x74, 0x70, 0x75, 0x74,
    0x73, 0x22, 0x7c, 0x0a, 0x0e, 0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x75, 0x74,
    0x70, 0x75, 0x74, 0x12, 0x12, 0x0a, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28,
    0x09, 0x52, 0x04, 0x6e, 0x61, 0x6d, 0x65, 0x12, 0x17, 0x0a, 0x07, 0x67, 0x6f, 0x5f, 0x74, 0x79,
    0x70, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x06, 0x67, 0x6f, 0x54, 0x79, 0x70, 0x65,
    0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52,
    0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x27, 0x0a, 0x0f, 0x63, 0x6f, 0x64, 0x65, 0x5f, 0x76,
    0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28, 0x09, 0x52,
    0x0e, 0x63, 0x6f, 0x64, 0x65, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x22,
    0x8f, 0x01, 0x0a, 0x0c, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74,
    0x12, 0x27, 0x0a, 0x0f, 0x6d, 0x65, 0x73, 0x73, 0x61, 0x67, 0x65, 0x5f, 0x63, 0x6f, 0x75, 0x6e,
    0x74, 0x65, 0x72, 0x18, 0x01, 0x20, 0x01, 0x28, 0x05, 0x52, 0x0e, 0x6d, 0x65, 0x73, 0x73, 0x61,
    0x67, 0x65, 0x43, 0x6f, 0x75, 0x6e, 0x74, 0x65, 0x72, 0x12, 0x17, 0x0a, 0x07, 0x69, 0x73, 0x5f,
    0x6c, 0x61, 0x73, 0x74, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x06, 0x69, 0x73, 0x4c, 0x61,
    0x73, 0x74, 0x12, 0x14, 0x0a, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x18, 0x03, 0x20, 0x01, 0x28,
    0x09, 0x52, 0x05, 0x76, 0x61, 0x6c, 0x75, 0x65, 0x12, 0x27, 0x0a, 0x0f, 0x63, 0x6f, 0x64, 0x65,
    0x5f, 0x76, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f, 0x6e, 0x18, 0x04, 0x20, 0x01, 0x28,
    0x09, 0x52, 0x0e, 0x63, 0x6f, 0x64, 0x65, 0x56, 0x61, 0x6c, 0x69, 0x64, 0x61, 0x74, 0x69, 0x6f,
    0x6e, 0x32, 0xa5, 0x02, 0x0a, 0x11, 0x45, 0x78, 0x74, 0x65, 0x72, 0x6e, 0x61, 0x6c, 0x46, 0x75,
    0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x62, 0x0a, 0x0d, 0x4c, 0x69, 0x73, 0x74, 0x46,
    0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x12, 0x26, 0x2e, 0x61, 0x6c, 0x6c, 0x69, 0x65,
    0x66, 0x6c, 0x6f, 0x77, 0x6b, 0x69, 0x74, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x4c, 0x69, 0x73, 0x74,
    0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x73, 0x52, 0x65, 0x71, 0x75, 0x65, 0x73, 0x74,
    0x1a, 0x27, 0x2e, 0x61, 0x6c, 0x6c, 0x69, 0x65, 0x66, 0x6c, 0x6f, 0x77, 0x6b, 0x69, 0x74, 0x67,
    0x72, 0x70, 0x63, 0x2e, 0x4c, 0x69, 0x73, 0x74, 0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e,
    0x73, 0x52, 0x65, 0x73, 0x70, 0x6f, 0x6e, 0x73, 0x65, 0x22, 0x00, 0x12, 0x54, 0x0a, 0x0b, 0x52,
    0x75, 0x6e, 0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x12, 0x20, 0x2e, 0x61, 0x6c, 0x6c,
    0x69, 0x65, 0x66, 0x6c, 0x6f, 0x77, 0x6b, 0x69, 0x74, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x46, 0x75,
    0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49, 0x6e, 0x70, 0x75, 0x74, 0x73, 0x1a, 0x21, 0x2e, 0x61,
    0x6c, 0x6c, 0x69, 0x65, 0x66, 0x6c, 0x6f, 0x77, 0x6b, 0x69, 0x74, 0x67, 0x72, 0x70, 0x63, 0x2e,
    0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x4f, 0x75, 0x74, 0x70, 0x75, 0x74, 0x73, 0x22,
    0x00, 0x12, 0x56, 0x0a, 0x0e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x46, 0x75, 0x6e, 0x63, 0x74,
    0x69, 0x6f, 0x6e, 0x12, 0x20, 0x2e, 0x61, 0x6c, 0x6c, 0x69, 0x65, 0x66, 0x6c, 0x6f, 0x77, 0x6b,
    0x69, 0x74, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x46, 0x75, 0x6e, 0x63, 0x74, 0x69, 0x6f, 0x6e, 0x49,
    0x6e, 0x70, 0x75, 0x74, 0x73, 0x1a, 0x1e, 0x2e, 0x61, 0x6c, 0x6c, 0x69, 0x65, 0x66, 0x6c, 0x6f,
    0x77, 0x6b, 0x69, 0x74, 0x67, 0x72, 0x70, 0x63, 0x2e, 0x53, 0x74, 0x72, 0x65, 0x61, 0x6d, 0x4f,
    0x75, 0x74, 0x70, 0x75, 0x74, 0x22, 0x00, 0x30, 0x01, 0x42, 0x14, 0x5a, 0x12, 0x2e, 0x2f, 0x61,
    0x6c, 0x6c, 0x69, 0x65, 0x66, 0x6c, 0x6f, 0x77, 0x6b, 0x69, 0x74, 0x67, 0x72, 0x70, 0x63, 0x62,
    0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33,
}

func RegisterExternalFunctionsServer ¶

func RegisterExternalFunctionsServer(s grpc.ServiceRegistrar, srv ExternalFunctionsServer)

func _ExternalFunctions_ListFunctions_Handler ¶

func _ExternalFunctions_ListFunctions_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error)

func _ExternalFunctions_RunFunction_Handler ¶

func _ExternalFunctions_RunFunction_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error)

func _ExternalFunctions_StreamFunction_Handler ¶

func _ExternalFunctions_StreamFunction_Handler(srv interface{}, stream grpc.ServerStream) error

func file_pkg_allieflowkitgrpc_allie_flowkit_proto_init ¶

func file_pkg_allieflowkitgrpc_allie_flowkit_proto_init()

func file_pkg_allieflowkitgrpc_allie_flowkit_proto_rawDescGZIP ¶

func file_pkg_allieflowkitgrpc_allie_flowkit_proto_rawDescGZIP() []byte

func init ¶

func init()

type ExternalFunctionsClient ¶

ExternalFunctionsClient is the client API for ExternalFunctions 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.

ExternalFunctions is a gRPC service that allows for listing and running the function available in the externalfunctions package.

type ExternalFunctionsClient interface {
    // Lists all available functions with description, inputs and outputs.
    ListFunctions(ctx context.Context, in *ListFunctionsRequest, opts ...grpc.CallOption) (*ListFunctionsResponse, error)
    // Runs a specified function with provided inputs and returns the function outputs.
    RunFunction(ctx context.Context, in *FunctionInputs, opts ...grpc.CallOption) (*FunctionOutputs, error)
    // Runs a specified function with provided inputs and returns the function output as a stream.
    StreamFunction(ctx context.Context, in *FunctionInputs, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamOutput], error)
}

func NewExternalFunctionsClient ¶

func NewExternalFunctionsClient(cc grpc.ClientConnInterface) ExternalFunctionsClient

type ExternalFunctionsServer ¶

ExternalFunctionsServer is the server API for ExternalFunctions service. All implementations must embed UnimplementedExternalFunctionsServer for forward compatibility.

ExternalFunctions is a gRPC service that allows for listing and running the function available in the externalfunctions package.

type ExternalFunctionsServer interface {
    // Lists all available functions with description, inputs and outputs.
    ListFunctions(context.Context, *ListFunctionsRequest) (*ListFunctionsResponse, error)
    // Runs a specified function with provided inputs and returns the function outputs.
    RunFunction(context.Context, *FunctionInputs) (*FunctionOutputs, error)
    // Runs a specified function with provided inputs and returns the function output as a stream.
    StreamFunction(*FunctionInputs, grpc.ServerStreamingServer[StreamOutput]) error
    mustEmbedUnimplementedExternalFunctionsServer()
}

type ExternalFunctions_StreamFunctionClient ¶

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ExternalFunctions_StreamFunctionClient = grpc.ServerStreamingClient[StreamOutput]

type ExternalFunctions_StreamFunctionServer ¶

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ExternalFunctions_StreamFunctionServer = grpc.ServerStreamingServer[StreamOutput]

type FunctionDefinition ¶

FunctionDefinition is the definition of an individual function. It contains the name, description, inputs and outputs of the function.

type FunctionDefinition struct {
    state         protoimpl.MessageState
    sizeCache     protoimpl.SizeCache
    unknownFields protoimpl.UnknownFields

    // Name of the function.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Description of the function.
    Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
    // Category of the function.
    Category string `protobuf:"bytes,3,opt,name=category,proto3" json:"category,omitempty"`
    // Display name of the function;
    DisplayName string `protobuf:"bytes,4,opt,name=displayName,proto3" json:"displayName,omitempty"`
    // List of input definitions for the function.
    Input []*FunctionInputDefinition `protobuf:"bytes,5,rep,name=input,proto3" json:"input,omitempty"`
    // List of output definitions for the function.
    Output []*FunctionOutputDefinition `protobuf:"bytes,6,rep,name=output,proto3" json:"output,omitempty"`
}

func (*FunctionDefinition) Descriptor ¶

func (*FunctionDefinition) Descriptor() ([]byte, []int)

Deprecated: Use FunctionDefinition.ProtoReflect.Descriptor instead.

func (*FunctionDefinition) GetCategory ¶

func (x *FunctionDefinition) GetCategory() string

func (*FunctionDefinition) GetDescription ¶

func (x *FunctionDefinition) GetDescription() string

func (*FunctionDefinition) GetDisplayName ¶

func (x *FunctionDefinition) GetDisplayName() string

func (*FunctionDefinition) GetInput ¶

func (x *FunctionDefinition) GetInput() []*FunctionInputDefinition

func (*FunctionDefinition) GetName ¶

func (x *FunctionDefinition) GetName() string

func (*FunctionDefinition) GetOutput ¶

func (x *FunctionDefinition) GetOutput() []*FunctionOutputDefinition

func (*FunctionDefinition) ProtoMessage ¶

func (*FunctionDefinition) ProtoMessage()

func (*FunctionDefinition) ProtoReflect ¶

func (x *FunctionDefinition) ProtoReflect() protoreflect.Message

func (*FunctionDefinition) Reset ¶

func (x *FunctionDefinition) Reset()

func (*FunctionDefinition) String ¶

func (x *FunctionDefinition) String() string

type FunctionInput ¶

Single input for a function.

type FunctionInput struct {
    state         protoimpl.MessageState
    sizeCache     protoimpl.SizeCache
    unknownFields protoimpl.UnknownFields

    // Name of the input.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Go language type of the input.
    GoType string `protobuf:"bytes,2,opt,name=go_type,json=goType,proto3" json:"go_type,omitempty"`
    // Value of the input.
    Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
}

func (*FunctionInput) Descriptor ¶

func (*FunctionInput) Descriptor() ([]byte, []int)

Deprecated: Use FunctionInput.ProtoReflect.Descriptor instead.

func (*FunctionInput) GetGoType ¶

func (x *FunctionInput) GetGoType() string

func (*FunctionInput) GetName ¶

func (x *FunctionInput) GetName() string

func (*FunctionInput) GetValue ¶

func (x *FunctionInput) GetValue() string

func (*FunctionInput) ProtoMessage ¶

func (*FunctionInput) ProtoMessage()

func (*FunctionInput) ProtoReflect ¶

func (x *FunctionInput) ProtoReflect() protoreflect.Message

func (*FunctionInput) Reset ¶

func (x *FunctionInput) Reset()

func (*FunctionInput) String ¶

func (x *FunctionInput) String() string

type FunctionInputDefinition ¶

FunctionInputDefinition is the definition of an input for a function. It contains the name, type, Go language type and options for the input.

type FunctionInputDefinition struct {
    state         protoimpl.MessageState
    sizeCache     protoimpl.SizeCache
    unknownFields protoimpl.UnknownFields

    // Name of the input.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Type of the input.
    Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
    // Go language type of the input.
    GoType string `protobuf:"bytes,3,opt,name=go_type,json=goType,proto3" json:"go_type,omitempty"`
    // List of options for the input, if applicable.
    Options []string `protobuf:"bytes,4,rep,name=options,proto3" json:"options,omitempty"`
}

func (*FunctionInputDefinition) Descriptor ¶

func (*FunctionInputDefinition) Descriptor() ([]byte, []int)

Deprecated: Use FunctionInputDefinition.ProtoReflect.Descriptor instead.

func (*FunctionInputDefinition) GetGoType ¶

func (x *FunctionInputDefinition) GetGoType() string

func (*FunctionInputDefinition) GetName ¶

func (x *FunctionInputDefinition) GetName() string

func (*FunctionInputDefinition) GetOptions ¶

func (x *FunctionInputDefinition) GetOptions() []string

func (*FunctionInputDefinition) GetType ¶

func (x *FunctionInputDefinition) GetType() string

func (*FunctionInputDefinition) ProtoMessage ¶

func (*FunctionInputDefinition) ProtoMessage()

func (*FunctionInputDefinition) ProtoReflect ¶

func (x *FunctionInputDefinition) ProtoReflect() protoreflect.Message

func (*FunctionInputDefinition) Reset ¶

func (x *FunctionInputDefinition) Reset()

func (*FunctionInputDefinition) String ¶

func (x *FunctionInputDefinition) String() string

type FunctionInputs ¶

FunctionInputs is the input message for the RunFunction method. It contains the name of the function to run and a list of inputs.

type FunctionInputs struct {
    state         protoimpl.MessageState
    sizeCache     protoimpl.SizeCache
    unknownFields protoimpl.UnknownFields

    // Name of the function to run.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // List of inputs for the function.
    Inputs []*FunctionInput `protobuf:"bytes,2,rep,name=inputs,proto3" json:"inputs,omitempty"`
}

func (*FunctionInputs) Descriptor ¶

func (*FunctionInputs) Descriptor() ([]byte, []int)

Deprecated: Use FunctionInputs.ProtoReflect.Descriptor instead.

func (*FunctionInputs) GetInputs ¶

func (x *FunctionInputs) GetInputs() []*FunctionInput

func (*FunctionInputs) GetName ¶

func (x *FunctionInputs) GetName() string

func (*FunctionInputs) ProtoMessage ¶

func (*FunctionInputs) ProtoMessage()

func (*FunctionInputs) ProtoReflect ¶

func (x *FunctionInputs) ProtoReflect() protoreflect.Message

func (*FunctionInputs) Reset ¶

func (x *FunctionInputs) Reset()

func (*FunctionInputs) String ¶

func (x *FunctionInputs) String() string

type FunctionOutput ¶

FunctionOutput is a single output from a function. It contains the name, Go language type and value of the output.

type FunctionOutput struct {
    state         protoimpl.MessageState
    sizeCache     protoimpl.SizeCache
    unknownFields protoimpl.UnknownFields

    // Name of the output.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Go language type of the output.
    GoType string `protobuf:"bytes,2,opt,name=go_type,json=goType,proto3" json:"go_type,omitempty"`
    // Value of the output.
    Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
    // Code validation of the output. Only relevant for code generation.
    CodeValidation string `protobuf:"bytes,4,opt,name=code_validation,json=codeValidation,proto3" json:"code_validation,omitempty"`
}

func (*FunctionOutput) Descriptor ¶

func (*FunctionOutput) Descriptor() ([]byte, []int)

Deprecated: Use FunctionOutput.ProtoReflect.Descriptor instead.

func (*FunctionOutput) GetCodeValidation ¶

func (x *FunctionOutput) GetCodeValidation() string

func (*FunctionOutput) GetGoType ¶

func (x *FunctionOutput) GetGoType() string

func (*FunctionOutput) GetName ¶

func (x *FunctionOutput) GetName() string

func (*FunctionOutput) GetValue ¶

func (x *FunctionOutput) GetValue() string

func (*FunctionOutput) ProtoMessage ¶

func (*FunctionOutput) ProtoMessage()

func (*FunctionOutput) ProtoReflect ¶

func (x *FunctionOutput) ProtoReflect() protoreflect.Message

func (*FunctionOutput) Reset ¶

func (x *FunctionOutput) Reset()

func (*FunctionOutput) String ¶

func (x *FunctionOutput) String() string

type FunctionOutputDefinition ¶

FunctionOutputDefinition is the definition of an output for a function. It contains the name, type and Go language type of the output.

type FunctionOutputDefinition struct {
    state         protoimpl.MessageState
    sizeCache     protoimpl.SizeCache
    unknownFields protoimpl.UnknownFields

    // Name of the output.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // Type of the output.
    Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
    // Go language type of the output.
    GoType string `protobuf:"bytes,3,opt,name=go_type,json=goType,proto3" json:"go_type,omitempty"`
}

func (*FunctionOutputDefinition) Descriptor ¶

func (*FunctionOutputDefinition) Descriptor() ([]byte, []int)

Deprecated: Use FunctionOutputDefinition.ProtoReflect.Descriptor instead.

func (*FunctionOutputDefinition) GetGoType ¶

func (x *FunctionOutputDefinition) GetGoType() string

func (*FunctionOutputDefinition) GetName ¶

func (x *FunctionOutputDefinition) GetName() string

func (*FunctionOutputDefinition) GetType ¶

func (x *FunctionOutputDefinition) GetType() string

func (*FunctionOutputDefinition) ProtoMessage ¶

func (*FunctionOutputDefinition) ProtoMessage()

func (*FunctionOutputDefinition) ProtoReflect ¶

func (x *FunctionOutputDefinition) ProtoReflect() protoreflect.Message

func (*FunctionOutputDefinition) Reset ¶

func (x *FunctionOutputDefinition) Reset()

func (*FunctionOutputDefinition) String ¶

func (x *FunctionOutputDefinition) String() string

type FunctionOutputs ¶

FunctionOutputs is the output message for the RunFunction method. It contains the name of the function that was run and a list of outputs.

type FunctionOutputs struct {
    state         protoimpl.MessageState
    sizeCache     protoimpl.SizeCache
    unknownFields protoimpl.UnknownFields

    // Name of the function that was run.
    Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
    // List of outputs from the function.
    Outputs []*FunctionOutput `protobuf:"bytes,2,rep,name=outputs,proto3" json:"outputs,omitempty"`
}

func (*FunctionOutputs) Descriptor ¶

func (*FunctionOutputs) Descriptor() ([]byte, []int)

Deprecated: Use FunctionOutputs.ProtoReflect.Descriptor instead.

func (*FunctionOutputs) GetName ¶

func (x *FunctionOutputs) GetName() string

func (*FunctionOutputs) GetOutputs ¶

func (x *FunctionOutputs) GetOutputs() []*FunctionOutput

func (*FunctionOutputs) ProtoMessage ¶

func (*FunctionOutputs) ProtoMessage()

func (*FunctionOutputs) ProtoReflect ¶

func (x *FunctionOutputs) ProtoReflect() protoreflect.Message

func (*FunctionOutputs) Reset ¶

func (x *FunctionOutputs) Reset()

func (*FunctionOutputs) String ¶

func (x *FunctionOutputs) String() string

type ListFunctionsRequest ¶

ListFunctionsRequest is the input message for the ListFunctions method. As no input is required, this message is empty.

type ListFunctionsRequest struct {
    state         protoimpl.MessageState
    sizeCache     protoimpl.SizeCache
    unknownFields protoimpl.UnknownFields
}

func (*ListFunctionsRequest) Descriptor ¶

func (*ListFunctionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListFunctionsRequest.ProtoReflect.Descriptor instead.

func (*ListFunctionsRequest) ProtoMessage ¶

func (*ListFunctionsRequest) ProtoMessage()

func (*ListFunctionsRequest) ProtoReflect ¶

func (x *ListFunctionsRequest) ProtoReflect() protoreflect.Message

func (*ListFunctionsRequest) Reset ¶

func (x *ListFunctionsRequest) Reset()

func (*ListFunctionsRequest) String ¶

func (x *ListFunctionsRequest) String() string

type ListFunctionsResponse ¶

ListFunctionsResponse is the output message for the ListFunctions method. It contains a map of function names to their definitions.

type ListFunctionsResponse struct {
    state         protoimpl.MessageState
    sizeCache     protoimpl.SizeCache
    unknownFields protoimpl.UnknownFields

    // Map of function names to their definitions.
    Functions map[string]*FunctionDefinition `protobuf:"bytes,1,rep,name=functions,proto3" json:"functions,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
}

func (*ListFunctionsResponse) Descriptor ¶

func (*ListFunctionsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListFunctionsResponse.ProtoReflect.Descriptor instead.

func (*ListFunctionsResponse) GetFunctions ¶

func (x *ListFunctionsResponse) GetFunctions() map[string]*FunctionDefinition

func (*ListFunctionsResponse) ProtoMessage ¶

func (*ListFunctionsResponse) ProtoMessage()

func (*ListFunctionsResponse) ProtoReflect ¶

func (x *ListFunctionsResponse) ProtoReflect() protoreflect.Message

func (*ListFunctionsResponse) Reset ¶

func (x *ListFunctionsResponse) Reset()

func (*ListFunctionsResponse) String ¶

func (x *ListFunctionsResponse) String() string

type StreamOutput ¶

StreamOutput is the output message for the StreamFunction method. It contains the message counter, a flag indicating if this is the last message

type StreamOutput struct {
    state         protoimpl.MessageState
    sizeCache     protoimpl.SizeCache
    unknownFields protoimpl.UnknownFields

    // Counter for the message in the stream.
    MessageCounter int32 `protobuf:"varint,1,opt,name=message_counter,json=messageCounter,proto3" json:"message_counter,omitempty"`
    // Indicates if this is the last message in the stream.
    IsLast bool `protobuf:"varint,2,opt,name=is_last,json=isLast,proto3" json:"is_last,omitempty"`
    // Value of the output.
    Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
    // Code validation of the output. Only relevant for code generation.
    CodeValidation string `protobuf:"bytes,4,opt,name=code_validation,json=codeValidation,proto3" json:"code_validation,omitempty"`
}

func (*StreamOutput) Descriptor ¶

func (*StreamOutput) Descriptor() ([]byte, []int)

Deprecated: Use StreamOutput.ProtoReflect.Descriptor instead.

func (*StreamOutput) GetCodeValidation ¶

func (x *StreamOutput) GetCodeValidation() string

func (*StreamOutput) GetIsLast ¶

func (x *StreamOutput) GetIsLast() bool

func (*StreamOutput) GetMessageCounter ¶

func (x *StreamOutput) GetMessageCounter() int32

func (*StreamOutput) GetValue ¶

func (x *StreamOutput) GetValue() string

func (*StreamOutput) ProtoMessage ¶

func (*StreamOutput) ProtoMessage()

func (*StreamOutput) ProtoReflect ¶

func (x *StreamOutput) ProtoReflect() protoreflect.Message

func (*StreamOutput) Reset ¶

func (x *StreamOutput) Reset()

func (*StreamOutput) String ¶

func (x *StreamOutput) String() string

type UnimplementedExternalFunctionsServer ¶

UnimplementedExternalFunctionsServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

type UnimplementedExternalFunctionsServer struct{}

func (UnimplementedExternalFunctionsServer) ListFunctions ¶

func (UnimplementedExternalFunctionsServer) ListFunctions(context.Context, *ListFunctionsRequest) (*ListFunctionsResponse, error)

func (UnimplementedExternalFunctionsServer) RunFunction ¶

func (UnimplementedExternalFunctionsServer) RunFunction(context.Context, *FunctionInputs) (*FunctionOutputs, error)

func (UnimplementedExternalFunctionsServer) StreamFunction ¶

func (UnimplementedExternalFunctionsServer) StreamFunction(*FunctionInputs, grpc.ServerStreamingServer[StreamOutput]) error

func (UnimplementedExternalFunctionsServer) mustEmbedUnimplementedExternalFunctionsServer ¶

func (UnimplementedExternalFunctionsServer) mustEmbedUnimplementedExternalFunctionsServer()

func (UnimplementedExternalFunctionsServer) testEmbeddedByValue ¶

func (UnimplementedExternalFunctionsServer) testEmbeddedByValue()

type UnsafeExternalFunctionsServer ¶

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

type UnsafeExternalFunctionsServer interface {
    mustEmbedUnimplementedExternalFunctionsServer()
}

type externalFunctionsClient ¶

type externalFunctionsClient struct {
    cc grpc.ClientConnInterface
}

func (*externalFunctionsClient) ListFunctions ¶

func (c *externalFunctionsClient) ListFunctions(ctx context.Context, in *ListFunctionsRequest, opts ...grpc.CallOption) (*ListFunctionsResponse, error)

func (*externalFunctionsClient) RunFunction ¶

func (c *externalFunctionsClient) RunFunction(ctx context.Context, in *FunctionInputs, opts ...grpc.CallOption) (*FunctionOutputs, error)

func (*externalFunctionsClient) StreamFunction ¶

func (c *externalFunctionsClient) StreamFunction(ctx context.Context, in *FunctionInputs, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamOutput], error)