// Code generated by scripts/generate_beto_payloads.py. DO NOT EDIT. package queryregistration import ( "context" requests "github.com/pharos-ai-factory/pharos-platform/services/beto/adaptors/messaging/requests" codec "github.com/pharos-ai-factory/pharos-platform/services/beto/contexts/project/adaptors/messaging/generated/codec" model "github.com/pharos-ai-factory/pharos-platform/services/beto/contracts/requests/generated/model/project" names "github.com/pharos-ai-factory/pharos-platform/services/beto/contracts/requests/generated/names" ) // RegisterGetProjects binds the schema-defined input, result and encoder. func RegisterGetProjects(registry *requests.RabbitMQRequestRegistry, execute func(context.Context, model.GetProjectsQuery) (model.GetProjectsResponse, error)) error { return requests.Query(registry, names.ProjectQueryGetProjects, names.ProjectReplyProjects, codec.GetProjects, execute, codec.EncodeGetProjectsResponse) } // RegisterResolveProjectProviderBinding binds the schema-defined input, result and encoder. func RegisterResolveProjectProviderBinding(registry *requests.RabbitMQRequestRegistry, execute func(context.Context, model.ResolveProjectProviderBindingQuery) (model.ResolveProjectProviderBindingResponse, error)) error { return requests.Query(registry, names.ProjectQueryResolveProjectProviderBinding, names.ProjectReplyProviderBinding, codec.ResolveProjectProviderBinding, execute, codec.EncodeResolveProjectProviderBindingResponse) } // RegisterGetProjectIntegrationSnapshot binds the schema-defined input, result and encoder. func RegisterGetProjectIntegrationSnapshot(registry *requests.RabbitMQRequestRegistry, execute func(context.Context, model.GetProjectIntegrationSnapshotQuery) (model.GetProjectIntegrationSnapshotResponse, error)) error { return requests.Query(registry, names.ProjectQueryGetProjectIntegrationSnapshot, names.ProjectReplyIntegrationSnapshot, codec.GetProjectIntegrationSnapshot, execute, codec.EncodeGetProjectIntegrationSnapshotResponse) } // RegisterCheckProjectCapability binds the schema-defined input, result and encoder. func RegisterCheckProjectCapability(registry *requests.RabbitMQRequestRegistry, execute func(context.Context, model.CheckProjectCapabilityQuery) (model.CheckProjectCapabilityResponse, error)) error { return requests.Query(registry, names.ProjectQueryCheckProjectCapability, names.ProjectReplyCapabilityDecision, codec.CheckProjectCapability, execute, codec.EncodeCheckProjectCapabilityResponse) } // RegisterListProjectIntegrationSnapshots binds the schema-defined input, result and encoder. func RegisterListProjectIntegrationSnapshots(registry *requests.RabbitMQRequestRegistry, execute func(context.Context, model.ListProjectIntegrationSnapshotsQuery) (model.ListProjectIntegrationSnapshotsResponse, error)) error { return requests.Query(registry, names.ProjectQueryListProjectIntegrationSnapshots, names.ProjectReplyIntegrationSnapshotPage, codec.ListProjectIntegrationSnapshots, execute, codec.EncodeListProjectIntegrationSnapshotsResponse) } // RegisterListMyProjects binds the schema-defined input, result and encoder. func RegisterListMyProjects(registry *requests.RabbitMQRequestRegistry, execute func(context.Context, model.ListMyProjectsQuery) (model.ListMyProjectsResponse, error)) error { return requests.Query(registry, names.ProjectQueryListMyProjects, names.ProjectReplyMyProjectsPage, codec.ListMyProjects, execute, codec.EncodeListMyProjectsResponse) } // RegisterListPartyProjectAudiences binds the schema-defined input, result and encoder. func RegisterListPartyProjectAudiences(registry *requests.RabbitMQRequestRegistry, execute func(context.Context, model.ListPartyProjectAudiencesQuery) (model.ListPartyProjectAudiencesResponse, error)) error { return requests.Query(registry, names.ProjectQueryListPartyProjectAudiences, names.ProjectReplyPartyProjectAudiences, codec.ListPartyProjectAudiences, execute, codec.EncodeListPartyProjectAudiencesResponse) } // RegisterGetProjectMembers binds the schema-defined input, result and encoder. func RegisterGetProjectMembers(registry *requests.RabbitMQRequestRegistry, execute func(context.Context, model.GetProjectMembersQuery) (model.GetProjectMembersResponse, error)) error { return requests.Query(registry, names.ProjectQueryGetProjectMembers, names.ProjectReplyProjectMembers, codec.GetProjectMembers, execute, codec.EncodeGetProjectMembersResponse) } // RegisterListProjectInvitations binds the schema-defined input, result and encoder. func RegisterListProjectInvitations(registry *requests.RabbitMQRequestRegistry, execute func(context.Context, model.ListProjectInvitationsQuery) (model.ListProjectInvitationsResponse, error)) error { return requests.Query(registry, names.ProjectQueryListProjectInvitations, names.ProjectReplyProjectInvitations, codec.ListProjectInvitations, execute, codec.EncodeListProjectInvitationsResponse) } // RegisterGetProjectMemberDetails binds the schema-defined input, result and encoder. func RegisterGetProjectMemberDetails(registry *requests.RabbitMQRequestRegistry, execute func(context.Context, model.GetProjectMemberDetailsQuery) (model.GetProjectMemberDetailsResponse, error)) error { return requests.Query(registry, names.ProjectQueryGetProjectMemberDetails, names.ProjectReplyProjectMemberDetails, codec.GetProjectMemberDetails, execute, codec.EncodeGetProjectMemberDetailsResponse) }