interceptors

package
v0.9.4 Latest Latest
Warning

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

 Go to latest Published: Dec 16, 2019 License: Apache-2.0, BSD-3-Clause, MIT Imports: 13 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	BrokerCreateNotificationInterceptorName = "BrokerNotificationsCreateInterceptorProvider"
	BrokerUpdateNotificationInterceptorName = "BrokerNotificationsUpdateInterceptorProvider"
	BrokerDeleteNotificationInterceptorName = "BrokerNotificationsDeleteInterceptorProvider"
)
View Source 
const (
	CreateBrokerPublicPlanInterceptorName = "CreateBrokerPublicPlansInterceptor"
	UpdateBrokerPublicPlanInterceptorName = "UpdateBrokerPublicPlansInterceptor"
)
View Source 
const BrokerCreateCatalogInterceptorName = "BrokerCreateCatalogInterceptor"
View Source 
const BrokerDeleteCatalogInterceptorName = "BrokerDeleteCatalogInterceptor"
View Source 
const BrokerUpdateCatalogInterceptorName = "BrokerUpdateCatalogInterceptor"
View Source 
const ServiceInstanceCreateInterceptorName = "ServiceInstanceCreateInterceptor"

Variables

This section is empty.

Functions

func CreateNotification added in v0.3.3 

func CreateNotification(ctx context.Context, repository storage.Repository, op types.NotificationOperation, resource types.ObjectType, platformID string, payload *Payload) error

Types

type BrokerAdditional added in v0.3.0 

type BrokerAdditional struct {
	Services []*types.ServiceOffering `json:"services,omitempty"`
}

func (BrokerAdditional) Validate added in v0.3.0 

func (ba BrokerAdditional) Validate() error

type BrokerCreateCatalogInterceptorProvider added in v0.3.0 

type BrokerCreateCatalogInterceptorProvider struct {
	CatalogFetcher func(ctx context.Context, broker *types.ServiceBroker) ([]byte, error)
}

func (*BrokerCreateCatalogInterceptorProvider) Name added in v0.3.0 

func (c *BrokerCreateCatalogInterceptorProvider) Name() string

func (*BrokerCreateCatalogInterceptorProvider) Provide added in v0.3.0 

func (c *BrokerCreateCatalogInterceptorProvider) Provide() storage.CreateInterceptor

type BrokerDeleteCatalogInterceptorProvider added in v0.3.0 

type BrokerDeleteCatalogInterceptorProvider struct {
	CatalogLoader func(ctx context.Context, brokerID string, repository storage.Repository) (*types.ServiceOfferings, error)
}

BrokerDeleteCatalogInterceptorProvider provides a broker interceptor for delete operations

func (*BrokerDeleteCatalogInterceptorProvider) Name added in v0.3.0 

func (c *BrokerDeleteCatalogInterceptorProvider) Name() string

func (*BrokerDeleteCatalogInterceptorProvider) Provide added in v0.3.0 

func (c *BrokerDeleteCatalogInterceptorProvider) Provide() storage.DeleteInterceptor

type BrokerNotificationsCreateInterceptorProvider added in v0.3.0 

type BrokerNotificationsCreateInterceptorProvider struct {
}

func (*BrokerNotificationsCreateInterceptorProvider) Name added in v0.3.0 

func (*BrokerNotificationsCreateInterceptorProvider) Name() string

func (*BrokerNotificationsCreateInterceptorProvider) Provide added in v0.3.0 

func (*BrokerNotificationsCreateInterceptorProvider) Provide() storage.CreateOnTxInterceptor

type BrokerNotificationsDeleteInterceptorProvider added in v0.3.0 

type BrokerNotificationsDeleteInterceptorProvider struct {
}

func (*BrokerNotificationsDeleteInterceptorProvider) Name added in v0.3.0 

func (*BrokerNotificationsDeleteInterceptorProvider) Name() string

func (*BrokerNotificationsDeleteInterceptorProvider) Provide added in v0.3.0 

func (*BrokerNotificationsDeleteInterceptorProvider) Provide() storage.DeleteOnTxInterceptor

type BrokerNotificationsUpdateInterceptorProvider added in v0.3.0 

type BrokerNotificationsUpdateInterceptorProvider struct {
}

func (*BrokerNotificationsUpdateInterceptorProvider) Name added in v0.3.0 

func (*BrokerNotificationsUpdateInterceptorProvider) Name() string

func (*BrokerNotificationsUpdateInterceptorProvider) Provide added in v0.3.0 

func (*BrokerNotificationsUpdateInterceptorProvider) Provide() storage.UpdateOnTxInterceptor

type BrokerUpdateCatalogInterceptorProvider added in v0.3.0 

type BrokerUpdateCatalogInterceptorProvider struct {
	CatalogFetcher func(ctx context.Context, broker *types.ServiceBroker) ([]byte, error)
	CatalogLoader  func(ctx context.Context, brokerID string, repository storage.Repository) (*types.ServiceOfferings, error)
}

BrokerUpdateCatalogInterceptorProvider provides a broker interceptor for update operations

func (*BrokerUpdateCatalogInterceptorProvider) Name added in v0.3.0 

func (c *BrokerUpdateCatalogInterceptorProvider) Name() string

func (*BrokerUpdateCatalogInterceptorProvider) Provide added in v0.3.0 

func (c *BrokerUpdateCatalogInterceptorProvider) Provide() storage.UpdateInterceptor

type GenerateCredentialsInterceptorProvider added in v0.3.3 

type GenerateCredentialsInterceptorProvider struct {
}

func (*GenerateCredentialsInterceptorProvider) Name added in v0.3.3 

func (c *GenerateCredentialsInterceptorProvider) Name() string

func (*GenerateCredentialsInterceptorProvider) Provide added in v0.3.3 

func (c *GenerateCredentialsInterceptorProvider) Provide() storage.CreateAroundTxInterceptor

type NotificationsInterceptor added in v0.3.0 

type NotificationsInterceptor struct {
	PlatformIdProviderFunc func(ctx context.Context, object types.Object) string
	AdditionalDetailsFunc  func(ctx context.Context, objects types.ObjectList, repository storage.Repository) (objectDetails, error)
}

func NewBrokerNotificationsInterceptor added in v0.3.0 

func NewBrokerNotificationsInterceptor() *NotificationsInterceptor

func NewVisibilityNotificationsInterceptor added in v0.3.0 

func NewVisibilityNotificationsInterceptor() *NotificationsInterceptor

func (*NotificationsInterceptor) OnTxCreate added in v0.3.0 

func (ni *NotificationsInterceptor) OnTxCreate(h storage.InterceptCreateOnTxFunc) storage.InterceptCreateOnTxFunc

func (*NotificationsInterceptor) OnTxDelete added in v0.3.0 

func (ni *NotificationsInterceptor) OnTxDelete(h storage.InterceptDeleteOnTxFunc) storage.InterceptDeleteOnTxFunc

func (*NotificationsInterceptor) OnTxUpdate added in v0.3.0 

func (ni *NotificationsInterceptor) OnTxUpdate(h storage.InterceptUpdateOnTxFunc) storage.InterceptUpdateOnTxFunc

type ObjectPayload added in v0.3.0 

type ObjectPayload struct {
	Resource   types.Object        `json:"resource,omitempty"`
	Additional util.InputValidator `json:"additional,omitempty"`
}

type Payload added in v0.3.0 

type Payload struct {
	New          *ObjectPayload     `json:"new,omitempty"`
	Old          *ObjectPayload     `json:"old,omitempty"`
	LabelChanges query.LabelChanges `json:"label_changes,omitempty"`
}

type PublicPlanCreateInterceptorProvider 

type PublicPlanCreateInterceptorProvider struct {
	IsCatalogPlanPublicFunc publicPlanProcessor
}

func (*PublicPlanCreateInterceptorProvider) Name 

func (p *PublicPlanCreateInterceptorProvider) Name() string

func (*PublicPlanCreateInterceptorProvider) Provide 

func (p *PublicPlanCreateInterceptorProvider) Provide() storage.CreateInterceptor

type PublicPlanUpdateInterceptorProvider 

type PublicPlanUpdateInterceptorProvider struct {
	IsCatalogPlanPublicFunc publicPlanProcessor
}

func (*PublicPlanUpdateInterceptorProvider) Name 

func (p *PublicPlanUpdateInterceptorProvider) Name() string

func (*PublicPlanUpdateInterceptorProvider) Provide 

func (p *PublicPlanUpdateInterceptorProvider) Provide() storage.UpdateInterceptor

type ServiceInstanceCreateInsterceptorProvider added in v0.9.0 

type ServiceInstanceCreateInsterceptorProvider struct {
	TenantIdentifier string
}

func (*ServiceInstanceCreateInsterceptorProvider) Name added in v0.9.0 

func (c *ServiceInstanceCreateInsterceptorProvider) Name() string

func (*ServiceInstanceCreateInsterceptorProvider) Provide added in v0.9.0 

func (c *ServiceInstanceCreateInsterceptorProvider) Provide() storage.CreateOnTxInterceptor

type VisibilityAdditional added in v0.3.0 

type VisibilityAdditional struct {
	BrokerID    string             `json:"broker_id"`
	BrokerName  string             `json:"broker_name"`
	ServicePlan *types.ServicePlan `json:"service_plan,omitempty"`
}

func (VisibilityAdditional) Validate added in v0.3.0 

func (va VisibilityAdditional) Validate() error

type VisibilityCreateNotificationsInterceptorProvider added in v0.3.0 

type VisibilityCreateNotificationsInterceptorProvider struct {
}

func (*VisibilityCreateNotificationsInterceptorProvider) Name added in v0.3.0 

func (*VisibilityCreateNotificationsInterceptorProvider) Name() string

func (*VisibilityCreateNotificationsInterceptorProvider) Provide added in v0.3.0 

func (*VisibilityCreateNotificationsInterceptorProvider) Provide() storage.CreateOnTxInterceptor

type VisibilityDeleteNotificationsInterceptorProvider added in v0.3.0 

type VisibilityDeleteNotificationsInterceptorProvider struct {
}

func (*VisibilityDeleteNotificationsInterceptorProvider) Name added in v0.3.0 

func (*VisibilityDeleteNotificationsInterceptorProvider) Name() string

func (*VisibilityDeleteNotificationsInterceptorProvider) Provide added in v0.3.0 

func (*VisibilityDeleteNotificationsInterceptorProvider) Provide() storage.DeleteOnTxInterceptor

type VisibilityUpdateNotificationsInterceptorProvider added in v0.3.0 

type VisibilityUpdateNotificationsInterceptorProvider struct {
}

func (*VisibilityUpdateNotificationsInterceptorProvider) Name added in v0.3.0 

func (*VisibilityUpdateNotificationsInterceptorProvider) Name() string

func (*VisibilityUpdateNotificationsInterceptorProvider) Provide added in v0.3.0 

func (*VisibilityUpdateNotificationsInterceptorProvider) Provide() storage.UpdateOnTxInterceptor

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.