service

Documentation

Index

• func NewCommentService(services *Services, log logger.Logger, ...) *commentService
• func NewContactService(log logger.Logger, services *Services) *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 NewEventCompletionService(services *Services, log logger.Logger, ...) *eventCompletionService
• func NewEventStoreService(services *Services, log logger.Logger, ...) *eventStoreService
• func NewInvoiceService(repositories *repository.Repositories, services *Services, log logger.Logger, ...) *invoiceService
• 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 NewOpportunityService(log logger.Logger, commandHandlers *command_handler.CommandHandlers, ...) *opportunityService
• func NewOrganizationService(log logger.Logger, organizationCommands *command_handler.CommandHandlers, ...) *organizationService
• func NewPhoneNumberService(log logger.Logger, neo4jRepositories *neo4jrepository.Repositories, ...) *phoneNumberService
• func NewRequestHandler(log logger.Logger, es eventstore.AggregateStore, cfg config.Utils) *requestHandler
• func NewServiceLineItemService(log logger.Logger, aggregateStore eventstore.AggregateStore, ...) *serviceLineItemService
• func NewUserService(log logger.Logger, aggregateStore eventstore.AggregateStore, ...) *userService
• type Event
• type RequestHandler
• type Services
  • func InitServices(cfg *config.Config, repositories *repository.Repositories, ...) *Services

Functions

func NewCommentService

func NewCommentService(services *Services, log logger.Logger, aggregateStore eventstore.AggregateStore, cfg *config.Config) *commentService

func NewContactService

func NewContactService(log logger.Logger, services *Services) *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, services *Services) *emailService

func NewEventCompletionService

func NewEventCompletionService(services *Services, log logger.Logger, aggregateStore eventstore.AggregateStore, cfg *config.Config) *eventCompletionService

func NewEventStoreService

func NewEventStoreService(services *Services, log logger.Logger, aggregateStore eventstore.AggregateStore) *eventStoreService

func NewInvoiceService

func NewInvoiceService(repositories *repository.Repositories, services *Services, log logger.Logger, aggregateStore eventstore.AggregateStore) *invoiceService

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 NewOpportunityService

func NewOpportunityService(log logger.Logger, commandHandlers *command_handler.CommandHandlers, aggregateStore eventstore.AggregateStore, services *Services) *opportunityService

func NewOrganizationService

func NewOrganizationService(log logger.Logger, organizationCommands *command_handler.CommandHandlers, aggregateStore eventstore.AggregateStore, cfg *config.Config, services *Services) *organizationService

func NewPhoneNumberService

func NewPhoneNumberService(log logger.Logger, neo4jRepositories *neo4jrepository.Repositories, phoneNumberCommands *command_handler.CommandHandlers, services *Services) *phoneNumberService

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 NewUserService

func NewUserService(log logger.Logger, aggregateStore eventstore.AggregateStore, cfg *config.Config, userCommands *command_handler.CommandHandlers, services *Services) *userService

Types

type Event

type Event struct {
	Tenant    string `json:"tenant"`
	EventType string `json:"eventType"`
	Entity    string `json:"entity"`
	EntityID  string `json:"entityId"`
	Create    bool   `json:"create"`
	Update    bool   `json:"update"`
	Delete    bool   `json:"delete"`
}

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

	EventStoreGenericService genericServices.EventStoreGenericService
	RequestHandler           *requestHandler // generic grpc request handler

	//GRPC services
	ContactService         *contactService
	OrganizationService    *organizationService
	PhoneNumberService     *phoneNumberService
	EmailService           *emailService
	UserService            *userService
	LocationService        *locationService
	JobRoleService         *jobRoleService
	IssueService           *issueService
	CommentService         *commentService
	OpportunityService     *opportunityService
	ContractService        *contractService
	ServiceLineItemService *serviceLineItemService
	InvoiceService         *invoiceService
	CountryService         *countryService
	EventStoreService      *eventStoreService
	EventCompletionService *eventCompletionService
	// contains filtered or unexported fields
}

func InitServices

func InitServices(cfg *config.Config, repositories *repository.Repositories, aggregateStore eventstore.AggregateStore, commandHandlers *command.CommandHandlers, log logger.Logger, ebs *eventbuffer.EventBufferStoreService) *Services