Documentation
¶
Index ¶
- func GetParticipantTypeFromPB(participant *interactioneventpb.Participant) commonmodel.ParticipantType
- func NewCommentService(services *Services, log logger.Logger, ...) *commentService
- func NewContactService(log logger.Logger, contactCommandHandlers *command_handler.CommandHandlers, ...) *contactService
- func NewContractService(log logger.Logger, aggregateStore eventstore.AggregateStore, ...) *contractService
- func NewCountryService(services *Services, log logger.Logger, ...) *countryService
- func NewEmailService(log logger.Logger, neo4jRepositories *neo4jrepository.Repositories, ...) *emailService
- func NewEventStoreService(services *Services, log logger.Logger, ...) *eventStoreService
- func NewInteractionEventService(log logger.Logger, commands *cmdhnd.CommandHandlers) *interactionEventService
- func NewInteractionSessionService(log logger.Logger, commands *cmdhnd.CommandHandlers) *interactionSessionService
- func NewInvoiceService(repositories *repository.Repositories, services *Services, log logger.Logger, ...) *invoiceService
- func NewInvoicingCycleService(log logger.Logger, eventHandlers *invoicingcycleEvents.EventHandlers, ...) *invoicingCycleService
- func NewIssueService(log logger.Logger, issueCommandHandlers *cmdhnd.CommandHandlers) *issueService
- func NewJobRoleService(log logger.Logger, jobRoleCommands *commands.CommandHandlers) *jobRoleService
- func NewLocationService(log logger.Logger, locationCommands *command_handler.CommandHandlers) *locationService
- func NewLogEntryService(log logger.Logger, logEntryCommands *logentrycmdhandler.CommandHandlers) *logEntryService
- func NewMasterPlanService(log logger.Logger, commandHandlers *command_handler.CommandHandlers, ...) *masterPlanService
- func NewOfferingService(log logger.Logger, aggregateStore eventstore.AggregateStore, ...) *offeringService
- func NewOpportunityService(log logger.Logger, commandHandlers *command_handler.CommandHandlers, ...) *opportunityService
- func NewOrderService(log logger.Logger, aggregateStore eventstore.AggregateStore, ...) *orderService
- func NewOrganizationPlanService(log logger.Logger, commandHandlers *event_handler.EventHandlers, ...) *organizationPlanService
- func NewOrganizationService(log logger.Logger, organizationCommands *command_handler.CommandHandlers, ...) *organizationService
- func NewPhoneNumberService(log logger.Logger, neo4jRepositories *neo4jrepository.Repositories, ...) *phoneNumberService
- func NewReminderService(log logger.Logger, aggregateStore eventstore.AggregateStore, ...) *reminderService
- func NewRequestHandler(log logger.Logger, es eventstore.AggregateStore, cfg config.Utils) *requestHandler
- func NewServiceLineItemService(log logger.Logger, aggregateStore eventstore.AggregateStore, ...) *serviceLineItemService
- func NewTenantService(services *Services, log logger.Logger, ...) *tenantService
- func NewUserService(log logger.Logger, aggregateStore eventstore.AggregateStore, ...) *userService
- type RequestHandler
- type Services
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetParticipantTypeFromPB ¶
func GetParticipantTypeFromPB(participant *interactioneventpb.Participant) commonmodel.ParticipantType
func NewCommentService ¶
func NewCommentService(services *Services, log logger.Logger, aggregateStore eventstore.AggregateStore, cfg *config.Config) *commentService
func NewContactService ¶
func NewContactService(log logger.Logger, contactCommandHandlers *command_handler.CommandHandlers, aggregateStore eventstore.AggregateStore, cfg *config.Config) *contactService
func NewContractService ¶
func NewContractService(log logger.Logger, aggregateStore eventstore.AggregateStore, services *Services) *contractService
func NewCountryService ¶
func NewCountryService(services *Services, log logger.Logger, aggregateStore eventstore.AggregateStore, cfg *config.Config) *countryService
func NewEmailService ¶
func NewEmailService(log logger.Logger, neo4jRepositories *neo4jrepository.Repositories, emailCommandHandlers *command_handler.CommandHandlers) *emailService
func NewEventStoreService ¶
func NewEventStoreService(services *Services, log logger.Logger, aggregateStore eventstore.AggregateStore) *eventStoreService
func NewInteractionEventService ¶
func NewInteractionEventService(log logger.Logger, commands *cmdhnd.CommandHandlers) *interactionEventService
func NewInteractionSessionService ¶
func NewInteractionSessionService(log logger.Logger, commands *cmdhnd.CommandHandlers) *interactionSessionService
func NewInvoiceService ¶
func NewInvoiceService(repositories *repository.Repositories, services *Services, log logger.Logger, aggregateStore eventstore.AggregateStore) *invoiceService
func NewInvoicingCycleService ¶
func NewInvoicingCycleService(log logger.Logger, eventHandlers *invoicingcycleEvents.EventHandlers, aggregateStore eventstore.AggregateStore) *invoicingCycleService
func NewIssueService ¶
func NewIssueService(log logger.Logger, issueCommandHandlers *cmdhnd.CommandHandlers) *issueService
func NewJobRoleService ¶
func NewJobRoleService(log logger.Logger, jobRoleCommands *commands.CommandHandlers) *jobRoleService
func NewLocationService ¶
func NewLocationService(log logger.Logger, locationCommands *command_handler.CommandHandlers) *locationService
func NewLogEntryService ¶
func NewLogEntryService(log logger.Logger, logEntryCommands *logentrycmdhandler.CommandHandlers) *logEntryService
func NewMasterPlanService ¶
func NewMasterPlanService(log logger.Logger, commandHandlers *command_handler.CommandHandlers, aggregateStore eventstore.AggregateStore) *masterPlanService
func NewOfferingService ¶
func NewOfferingService(log logger.Logger, aggregateStore eventstore.AggregateStore, cfg *config.Config) *offeringService
func NewOpportunityService ¶
func NewOpportunityService(log logger.Logger, commandHandlers *command_handler.CommandHandlers, aggregateStore eventstore.AggregateStore, services *Services) *opportunityService
func NewOrderService ¶
func NewOrderService(log logger.Logger, aggregateStore eventstore.AggregateStore, cfg *config.Config) *orderService
func NewOrganizationPlanService ¶
func NewOrganizationPlanService(log logger.Logger, commandHandlers *event_handler.EventHandlers, aggregateStore eventstore.AggregateStore) *organizationPlanService
func NewOrganizationService ¶
func NewOrganizationService(log logger.Logger, organizationCommands *command_handler.CommandHandlers, aggregateStore eventstore.AggregateStore, cfg *config.Config) *organizationService
func NewPhoneNumberService ¶
func NewPhoneNumberService(log logger.Logger, neo4jRepositories *neo4jrepository.Repositories, phoneNumberCommands *command_handler.CommandHandlers) *phoneNumberService
func NewReminderService ¶
func NewReminderService(log logger.Logger, aggregateStore eventstore.AggregateStore, cfg *config.Config, ebs *eventstore.EventBufferService) *reminderService
func NewRequestHandler ¶
func NewRequestHandler(log logger.Logger, es eventstore.AggregateStore, cfg config.Utils) *requestHandler
func NewServiceLineItemService ¶
func NewServiceLineItemService(log logger.Logger, aggregateStore eventstore.AggregateStore, services *Services) *serviceLineItemService
func NewTenantService ¶
func NewTenantService(services *Services, log logger.Logger, aggregateStore eventstore.AggregateStore, cfg *config.Config) *tenantService
func NewUserService ¶
func NewUserService(log logger.Logger, aggregateStore eventstore.AggregateStore, cfg *config.Config, userCommands *command_handler.CommandHandlers) *userService
Types ¶
type RequestHandler ¶
type RequestHandler interface {
HandleGRPCRequest(ctx context.Context, initAggregate func() eventstore.Aggregate, aggregateOptions eventstore.LoadAggregateOptions, request any, params ...map[string]any) (any, error)
}
type Services ¶
type Services struct {
FileStoreApiService fsc.FileStoreApiService
CommonServices *commonService.Services
RequestHandler *requestHandler // generic grpc request handler
//GRPC services
ContactService *contactService
OrganizationService *organizationService
PhoneNumberService *phoneNumberService
EmailService *emailService
UserService *userService
LocationService *locationService
JobRoleService *jobRoleService
InteractionEventService *interactionEventService
InteractionSessionService *interactionSessionService
LogEntryService *logEntryService
IssueService *issueService
CommentService *commentService
OpportunityService *opportunityService
ContractService *contractService
ServiceLineItemService *serviceLineItemService
MasterPlanService *masterPlanService
OrganizationPlanService *organizationPlanService
InvoicingCycleService *invoicingCycleService
InvoiceService *invoiceService
TenantService *tenantService
CountryService *countryService
ReminderService *reminderService
OrderService *orderService
EventStoreService *eventStoreService
}
func InitServices ¶
func InitServices(cfg *config.Config, repositories *repository.Repositories, aggregateStore eventstore.AggregateStore, commandHandlers *command.CommandHandlers, log logger.Logger, ebs *eventstore.EventBufferService) *Services
Source Files
¶
- comment_service.go
- contact_service.go
- contract_service.go
- country_service.go
- email_service.go
- event_store_service.go
- interaction_event_service.go
- interaction_session_service.go
- invoice_service.go
- invoicing_cycle_service.go
- issue_service.go
- job_role_service.go
- location_service.go
- log_entry_service.go
- master_plan_service.go
- offering_service.go
- opportunity_service.go
- order_service.go
- org_plan_service.go
- organization_service.go
- phone_number_service.go
- reminder_service.go
- request_handler_service.go
- service_line_item_service.go
- services.go
- tenant_service.go
- user_service.go
- utils.go
Click to show internal directories.
Click to hide internal directories.