eventing

Documentation

Index

• Constants
• func ApplicationEventingConfigurationToGraphQL(in *model.ApplicationEventingConfiguration) *graphql.ApplicationEventingConfiguration
• func NewService(appNameNormalizer normalizer.Normalizator, runtimeRepo RuntimeRepository, ...) *service
• func RuntimeEventingConfigurationToGraphQL(in *model.RuntimeEventingConfiguration) *graphql.RuntimeEventingConfiguration
• type ApplicationService
• type EventingService
• type FormationService
• type LabelRepository
• type Resolver
  • func NewResolver(transact persistence.Transactioner, eventingSvc EventingService, ...) *Resolver
  • func (r *Resolver) SetEventingForApplication(ctx context.Context, appID string, runtime string) (*graphql.ApplicationEventingConfiguration, error)
  • func (r *Resolver) UnsetEventingForApplication(ctx context.Context, appID string) (*graphql.ApplicationEventingConfiguration, error)
• type RuntimeRepository

Constants

const (

	// RuntimeEventingURLLabel missing godoc
	RuntimeEventingURLLabel = "runtime_eventServiceUrl"
	// EmptyEventingURL missing godoc
	EmptyEventingURL = ""
	// RuntimeDefaultEventingLabelf missing godoc
	RuntimeDefaultEventingLabelf = "%s_defaultEventing"
)

Functions

func ApplicationEventingConfigurationToGraphQL

func ApplicationEventingConfigurationToGraphQL(in *model.ApplicationEventingConfiguration) *graphql.ApplicationEventingConfiguration

ApplicationEventingConfigurationToGraphQL missing godoc

func NewService

func NewService(appNameNormalizer normalizer.Normalizator, runtimeRepo RuntimeRepository, labelRepo LabelRepository, formationService FormationService) *service

NewService missing godoc

func RuntimeEventingConfigurationToGraphQL

func RuntimeEventingConfigurationToGraphQL(in *model.RuntimeEventingConfiguration) *graphql.RuntimeEventingConfiguration

RuntimeEventingConfigurationToGraphQL missing godoc

Types

type ApplicationService

type ApplicationService interface {
	Get(ctx context.Context, id string) (*model.Application, error)
}

ApplicationService missing godoc

type EventingService

type EventingService interface {
	SetForApplication(ctx context.Context, runtimeID uuid.UUID, app model.Application) (*model.ApplicationEventingConfiguration, error)
	UnsetForApplication(ctx context.Context, app model.Application) (*model.ApplicationEventingConfiguration, error)
}

EventingService missing godoc

type FormationService

type FormationService interface {
	ListFormationsForObject(ctx context.Context, objectID string) ([]*model.Formation, error)
	ListObjectIDsOfTypeForFormations(ctx context.Context, tenantID string, formationNames []string, objectType model.FormationAssignmentType) ([]string, error)
}

FormationService is responsible for managing formations. Provides functionality for listing all formations by object ID and listing all IDs of objects that are part of the specified formations.

type LabelRepository

type LabelRepository interface {
	Delete(ctx context.Context, tenant string, objectType model.LabelableObject, objectID string, key string) error
	GetByKey(ctx context.Context, tenant string, objectType model.LabelableObject, objectID, key string) (*model.Label, error)
	DeleteByKey(ctx context.Context, tenant string, key string) error
	Upsert(ctx context.Context, tenant string, label *model.Label) error
}

LabelRepository missing godoc

type Resolver

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

Resolver missing godoc

func NewResolver

func NewResolver(transact persistence.Transactioner, eventingSvc EventingService, appSvc ApplicationService) *Resolver

NewResolver missing godoc

func (*Resolver) SetEventingForApplication

func (r *Resolver) SetEventingForApplication(ctx context.Context, appID string, runtime string) (*graphql.ApplicationEventingConfiguration, error)

SetEventingForApplication missing godoc

func (*Resolver) UnsetEventingForApplication

func (r *Resolver) UnsetEventingForApplication(ctx context.Context, appID string) (*graphql.ApplicationEventingConfiguration, error)

UnsetEventingForApplication missing godoc

type RuntimeRepository

type RuntimeRepository interface {
	GetByID(ctx context.Context, tenant, id string) (*model.Runtime, error)
	GetOldestFromIDs(ctx context.Context, tenant string, runtimeIDs []string) (*model.Runtime, error)
	List(ctx context.Context, tenant string, runtimeIDs []string, filters []*labelfilter.LabelFilter, pageSize int, cursor string) (*model.RuntimePage, error)
}

RuntimeRepository missing godoc