service

Documentation

Index

• func NewEventStoreService(services *Services, log logger.Logger, ...) *eventStoreService
• func NewInvoiceService(repositories *repository.Repositories, services *Services, log logger.Logger, ...) *invoiceService
• 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 NewRequestHandler(log logger.Logger, es eventstore.AggregateStore, cfg config.Utils) *requestHandler
• func NewServiceLineItemService(log logger.Logger, aggregateStore eventstore.AggregateStore, ...) *serviceLineItemService
• type RequestHandler
• type Services
  • func InitServices(cfg *config.Config, repositories *repository.Repositories, ...) *Services

Functions

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 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 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

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

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

	//GRPC services
	OrganizationService    *organizationService
	LocationService        *locationService
	OpportunityService     *opportunityService
	ServiceLineItemService *serviceLineItemService
	InvoiceService         *invoiceService
	EventStoreService      *eventStoreService
	// 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