eventwrap

package
v0.19.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 21, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewEventAssessmentService 

func NewEventAssessmentService(inner service.AssessmentServicer, s store.Store, accountsSvc service.AccountsServicer) service.AssessmentServicer

func NewEventEstimationService 

func NewEventEstimationService(inner service.EstimationServicer, s store.Store) service.EstimationServicer

func NewEventPartnerService 

func NewEventPartnerService(inner service.PartnerServicer, s store.Store) service.PartnerServicer

func NewEventSizerService 

func NewEventSizerService(inner service.SizerServicer, s store.Store) service.SizerServicer

Types

type EventAssessmentService 

type EventAssessmentService struct {
	// contains filtered or unexported fields
}

func (*EventAssessmentService) CreateAssessment 

func (e *EventAssessmentService) CreateAssessment(ctx context.Context, createForm mappers.AssessmentCreateForm) (*model.Assessment, error)

func (*EventAssessmentService) DeleteAssessment 

func (e *EventAssessmentService) DeleteAssessment(ctx context.Context, id uuid.UUID) error

func (*EventAssessmentService) GetAssessment 

func (e *EventAssessmentService) GetAssessment(ctx context.Context, id uuid.UUID) (*model.Assessment, error)

func (*EventAssessmentService) ListAssessments 

func (e *EventAssessmentService) ListAssessments(ctx context.Context, filter *service.AssessmentFilter) ([]model.Assessment, error)

func (*EventAssessmentService) ShareAssessment 

func (e *EventAssessmentService) ShareAssessment(ctx context.Context, id uuid.UUID) error

func (*EventAssessmentService) UnshareAssessment 

func (e *EventAssessmentService) UnshareAssessment(ctx context.Context, id uuid.UUID) error

func (*EventAssessmentService) UpdateAssessment 

func (e *EventAssessmentService) UpdateAssessment(ctx context.Context, id uuid.UUID, name *string) (*model.Assessment, error)

type EventEstimationService 

type EventEstimationService struct {
	// contains filtered or unexported fields
}

func (*EventEstimationService) BuildBaseParams 

func (e *EventEstimationService) BuildBaseParams(userParams []estimation.Param) []estimation.Param

func (*EventEstimationService) BuildBucketParams 

func (e *EventEstimationService) BuildBucketParams(baseParams []estimation.Param, vmCount int, diskGB float64) []estimation.Param

func (*EventEstimationService) CalculateMigrationComplexity 

func (e *EventEstimationService) CalculateMigrationComplexity(
	ctx context.Context,
	assessmentID uuid.UUID,
	clusterID string,
) (*service.MigrationComplexityResult, error)

func (*EventEstimationService) CalculateMigrationEstimation 

func (e *EventEstimationService) CalculateMigrationEstimation(
	ctx context.Context,
	assessmentID uuid.UUID,
	clusterID string,
	schemas []engines.Schema,
	userParams []estimation.Param,
) (map[engines.Schema]*service.MigrationAssessmentResult, error)

func (*EventEstimationService) CalculateOsDiskComplexity 

func (e *EventEstimationService) CalculateOsDiskComplexity(ctx context.Context, assessmentID uuid.UUID, clusterID string) (*service.OsDiskComplexityResult, error)

func (*EventEstimationService) RunEstimation 

func (e *EventEstimationService) RunEstimation(schemas []engines.Schema, params []estimation.Param) (map[engines.Schema]*service.MigrationAssessmentResult, error)

func (*EventEstimationService) ValidateParams 

func (e *EventEstimationService) ValidateParams(userParams []estimation.Param) error

type EventPartnerService 

type EventPartnerService struct {
	// contains filtered or unexported fields
}

func (*EventPartnerService) CancelRequest 

func (e *EventPartnerService) CancelRequest(ctx context.Context, user auth.User, requestID uuid.UUID) error

func (*EventPartnerService) CreateRequest 

func (e *EventPartnerService) CreateRequest(ctx context.Context, user auth.User, partnerID string, pc model.PartnerCustomer) (*model.PartnerCustomer, error)

func (*EventPartnerService) GetPartner 

func (e *EventPartnerService) GetPartner(ctx context.Context, user auth.User, partnerID string) (model.Group, error)

func (*EventPartnerService) LeavePartner 

func (e *EventPartnerService) LeavePartner(ctx context.Context, user auth.User, partnerID string) error

func (*EventPartnerService) ListCustomers 

func (e *EventPartnerService) ListCustomers(ctx context.Context, user auth.User) (model.PartnerCustomerList, error)

func (*EventPartnerService) ListPartners 

func (e *EventPartnerService) ListPartners(ctx context.Context) (model.GroupList, error)

func (*EventPartnerService) ListRequests 

func (e *EventPartnerService) ListRequests(ctx context.Context, user auth.User) (model.PartnerCustomerList, error)

func (*EventPartnerService) RemoveCustomer 

func (e *EventPartnerService) RemoveCustomer(ctx context.Context, user auth.User, username string) error

func (*EventPartnerService) UpdateRequest 

func (e *EventPartnerService) UpdateRequest(ctx context.Context, user auth.User, requestID uuid.UUID, req model.Request) (*model.PartnerCustomer, error)

type EventSizerService 

type EventSizerService struct {
	// contains filtered or unexported fields
}

func (*EventSizerService) CalculateClusterRequirements 

func (e *EventSizerService) CalculateClusterRequirements(
	ctx context.Context,
	assessmentID uuid.UUID,
	req *mappers.ClusterRequirementsRequestForm,
) (*api.ClusterRequirementsResponse, error)

func (*EventSizerService) CalculateStandaloneClusterRequirements 

func (e *EventSizerService) CalculateStandaloneClusterRequirements(
	ctx context.Context,
	req *mappers.StandaloneClusterRequirementsRequestForm,
) (*mappers.StandaloneClusterRequirementsResponseForm, error)

func (*EventSizerService) GetClusterRequirementsInput 

func (e *EventSizerService) GetClusterRequirementsInput(ctx context.Context, assessmentID uuid.UUID, clusterID string) (*mappers.ClusterRequirementsInputForm, error)

func (*EventSizerService) Health 

func (e *EventSizerService) Health(ctx context.Context) error

type OutboxDispatcher 

type OutboxDispatcher struct {
	// contains filtered or unexported fields
}

func NewOutboxDispatcher 

func NewOutboxDispatcher(s store.Store, writer events.Writer, interval time.Duration) *OutboxDispatcher

func (*OutboxDispatcher) Run 

func (d *OutboxDispatcher) Run(ctx context.Context)

type OutboxService 

type OutboxService struct {
	// contains filtered or unexported fields
}

func NewOutboxService 

func NewOutboxService(s store.Store) *OutboxService

func (*OutboxService) Insert 

func (o *OutboxService) Insert(ctx context.Context, eventType string, payload []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.