util

Documentation

Index

• Variables
• func NewAppContextInterceptor(config *config.Config) connect.Interceptor
• func ResolveEvent(ctx context.Context, conn repository.Querier, sel *commonv1.EventSelector) (*eventv1.Event, error)
• func ResolveTenant(ctx context.Context, conn repository.Querier, sel *commonv1.TenantSelector) (*model.Tenant, error)

Variables

var (
	ErrMissingEventSelector     = errors.New("missing event selector")
	ErrInvalidEventSelector     = errors.New("invalid event selector")
	ErrMissingStartSelector     = errors.New("missing start selector")
	ErrInvalidStartSelector     = errors.New("invalid start selector")
	ErrUnsupportedStartSelector = errors.New("unsupported start selector")
)

var ErrTenantSelectorRequired = errors.New("tenant selector is required")

Functions

func NewAppContextInterceptor

func NewAppContextInterceptor(config *config.Config) connect.Interceptor

func ResolveEvent

func ResolveEvent(
	ctx context.Context,
	conn repository.Querier,
	sel *commonv1.EventSelector,
) (*eventv1.Event, error)

returns the event for the given selector if the event is not found, a connect error with code NotFound is returned

func ResolveTenant

func ResolveTenant(
	ctx context.Context,
	conn repository.Querier,
	sel *commonv1.TenantSelector,
) (*model.Tenant, error)

returns the tenant for the given selector if tenants are supported if tenants are supported a selector must be provided