Documentation ¶
Overview ¶
Package elbv2 is a generated GoMock package.
Index ¶
- func NewDefaultListenerManager(elbv2Client services.ELBV2, trackingProvider tracking.Provider, ...) *defaultListenerManager
- func NewDefaultListenerRuleManager(elbv2Client services.ELBV2, trackingProvider tracking.Provider, ...) *defaultListenerRuleManager
- func NewDefaultLoadBalancerAttributeReconciler(elbv2Client services.ELBV2, logger logr.Logger) *defaultLoadBalancerAttributeReconciler
- func NewDefaultLoadBalancerManager(elbv2Client services.ELBV2, trackingProvider tracking.Provider, ...) *defaultLoadBalancerManager
- func NewDefaultTaggingManager(elbv2Client services.ELBV2, vpcID string, featureGates config.FeatureGates, ...) *defaultTaggingManager
- func NewDefaultTargetGroupAttributesReconciler(elbv2Client services.ELBV2, logger logr.Logger) *defaultTargetGroupAttributeReconciler
- func NewDefaultTargetGroupBindingManager(k8sClient client.Client, trackingProvider tracking.Provider, ...) *defaultTargetGroupBindingManager
- func NewDefaultTargetGroupManager(elbv2Client services.ELBV2, trackingProvider tracking.Provider, ...) *defaultTargetGroupManager
- func NewListenerRuleSynthesizer(elbv2Client services.ELBV2, taggingManager TaggingManager, ...) *listenerRuleSynthesizer
- func NewListenerSynthesizer(elbv2Client services.ELBV2, taggingManager TaggingManager, ...) *listenerSynthesizer
- func NewLoadBalancerSynthesizer(elbv2Client services.ELBV2, trackingProvider tracking.Provider, ...) *loadBalancerSynthesizer
- func NewTargetGroupBindingSynthesizer(k8sClient client.Client, trackingProvider tracking.Provider, ...) *targetGroupBindingSynthesizer
- func NewTargetGroupSynthesizer(elbv2Client services.ELBV2, trackingProvider tracking.Provider, ...) *targetGroupSynthesizer
- type ListenerManager
- type ListenerRuleManager
- type ListenerRuleWithTags
- type ListenerWithTags
- type LoadBalancerAttributeReconciler
- type LoadBalancerManager
- type LoadBalancerWithTags
- type MockTaggingManager
- func (m *MockTaggingManager) EXPECT() *MockTaggingManagerMockRecorder
- func (m *MockTaggingManager) ListListenerRules(arg0 context.Context, arg1 string) ([]ListenerRuleWithTags, error)
- func (m *MockTaggingManager) ListListeners(arg0 context.Context, arg1 string) ([]ListenerWithTags, error)
- func (m *MockTaggingManager) ListLoadBalancers(arg0 context.Context, arg1 ...tracking.TagFilter) ([]LoadBalancerWithTags, error)
- func (m *MockTaggingManager) ListTargetGroups(arg0 context.Context, arg1 ...tracking.TagFilter) ([]TargetGroupWithTags, error)
- func (m *MockTaggingManager) ReconcileTags(arg0 context.Context, arg1 string, arg2 map[string]string, ...) error
- type MockTaggingManagerMockRecorder
- func (mr *MockTaggingManagerMockRecorder) ListListenerRules(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTaggingManagerMockRecorder) ListListeners(arg0, arg1 interface{}) *gomock.Call
- func (mr *MockTaggingManagerMockRecorder) ListLoadBalancers(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockTaggingManagerMockRecorder) ListTargetGroups(arg0 interface{}, arg1 ...interface{}) *gomock.Call
- func (mr *MockTaggingManagerMockRecorder) ReconcileTags(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
- type ReconcileTagsOption
- type ReconcileTagsOptions
- type TaggingManager
- type TargetGroupAttributesReconciler
- type TargetGroupBindingManager
- type TargetGroupManager
- type TargetGroupWithTags
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewDefaultListenerManager ¶
func NewDefaultListenerManager(elbv2Client services.ELBV2, trackingProvider tracking.Provider, taggingManager TaggingManager, externalManagedTags []string, featureGates config.FeatureGates, logger logr.Logger) *defaultListenerManager
func NewDefaultListenerRuleManager ¶
func NewDefaultListenerRuleManager(elbv2Client services.ELBV2, trackingProvider tracking.Provider, taggingManager TaggingManager, externalManagedTags []string, featureGates config.FeatureGates, logger logr.Logger) *defaultListenerRuleManager
NewDefaultListenerRuleManager constructs new defaultListenerRuleManager.
func NewDefaultLoadBalancerAttributeReconciler ¶
func NewDefaultLoadBalancerAttributeReconciler(elbv2Client services.ELBV2, logger logr.Logger) *defaultLoadBalancerAttributeReconciler
NewDefaultLoadBalancerAttributeReconciler constructs new defaultLoadBalancerAttributeReconciler.
func NewDefaultLoadBalancerManager ¶
func NewDefaultLoadBalancerManager(elbv2Client services.ELBV2, trackingProvider tracking.Provider, taggingManager TaggingManager, externalManagedTags []string, logger logr.Logger) *defaultLoadBalancerManager
NewDefaultLoadBalancerManager constructs new defaultLoadBalancerManager.
func NewDefaultTaggingManager ¶
func NewDefaultTaggingManager(elbv2Client services.ELBV2, vpcID string, featureGates config.FeatureGates, rgt services.RGT, logger logr.Logger) *defaultTaggingManager
NewDefaultTaggingManager constructs default TaggingManager.
func NewDefaultTargetGroupAttributesReconciler ¶
func NewDefaultTargetGroupAttributesReconciler(elbv2Client services.ELBV2, logger logr.Logger) *defaultTargetGroupAttributeReconciler
NewDefaultTargetGroupAttributesReconciler constructs new TargetGroupAttributesReconciler.
func NewDefaultTargetGroupBindingManager ¶
func NewDefaultTargetGroupBindingManager(k8sClient client.Client, trackingProvider tracking.Provider, logger logr.Logger) *defaultTargetGroupBindingManager
NewDefaultTargetGroupBindingManager constructs new defaultTargetGroupBindingManager
func NewDefaultTargetGroupManager ¶
func NewDefaultTargetGroupManager(elbv2Client services.ELBV2, trackingProvider tracking.Provider, taggingManager TaggingManager, vpcID string, externalManagedTags []string, logger logr.Logger) *defaultTargetGroupManager
NewDefaultTargetGroupManager constructs new defaultTargetGroupManager.
func NewListenerRuleSynthesizer ¶
func NewListenerRuleSynthesizer(elbv2Client services.ELBV2, taggingManager TaggingManager, lrManager ListenerRuleManager, logger logr.Logger, stack core.Stack) *listenerRuleSynthesizer
NewListenerRuleSynthesizer constructs new listenerRuleSynthesizer.
func NewListenerSynthesizer ¶
func NewListenerSynthesizer(elbv2Client services.ELBV2, taggingManager TaggingManager, lsManager ListenerManager, logger logr.Logger, stack core.Stack) *listenerSynthesizer
func NewLoadBalancerSynthesizer ¶
func NewLoadBalancerSynthesizer(elbv2Client services.ELBV2, trackingProvider tracking.Provider, taggingManager TaggingManager, lbManager LoadBalancerManager, logger logr.Logger, stack core.Stack) *loadBalancerSynthesizer
NewLoadBalancerSynthesizer constructs loadBalancerSynthesizer
func NewTargetGroupBindingSynthesizer ¶
func NewTargetGroupBindingSynthesizer(k8sClient client.Client, trackingProvider tracking.Provider, tgbManager TargetGroupBindingManager, logger logr.Logger, stack core.Stack) *targetGroupBindingSynthesizer
NewTargetGroupBindingSynthesizer constructs new targetGroupBindingSynthesizer
func NewTargetGroupSynthesizer ¶
func NewTargetGroupSynthesizer(elbv2Client services.ELBV2, trackingProvider tracking.Provider, taggingManager TaggingManager, tgManager TargetGroupManager, logger logr.Logger, featureGates config.FeatureGates, stack core.Stack) *targetGroupSynthesizer
NewTargetGroupSynthesizer constructs targetGroupSynthesizer
Types ¶
type ListenerManager ¶
type ListenerManager interface { Create(ctx context.Context, resLS *elbv2model.Listener) (elbv2model.ListenerStatus, error) Update(ctx context.Context, resLS *elbv2model.Listener, sdkLS ListenerWithTags) (elbv2model.ListenerStatus, error) Delete(ctx context.Context, sdkLS ListenerWithTags) error }
ListenerManager is responsible for create/update/delete Listener resources.
type ListenerRuleManager ¶
type ListenerRuleManager interface { Create(ctx context.Context, resLR *elbv2model.ListenerRule) (elbv2model.ListenerRuleStatus, error) Update(ctx context.Context, resLR *elbv2model.ListenerRule, sdkLR ListenerRuleWithTags) (elbv2model.ListenerRuleStatus, error) Delete(ctx context.Context, sdkLR ListenerRuleWithTags) error }
ListenerRuleManager is responsible for create/update/delete ListenerRule resources.
type ListenerRuleWithTags ¶
ListenerRule with tags
type ListenerWithTags ¶
Listener with it's tags.
type LoadBalancerAttributeReconciler ¶
type LoadBalancerAttributeReconciler interface { // Reconcile loadBalancer attributes Reconcile(ctx context.Context, resLB *elbv2model.LoadBalancer, sdkLB LoadBalancerWithTags) error }
reconciler for LoadBalancer attributes
type LoadBalancerManager ¶
type LoadBalancerManager interface { Create(ctx context.Context, resLB *elbv2model.LoadBalancer) (elbv2model.LoadBalancerStatus, error) Update(ctx context.Context, resLB *elbv2model.LoadBalancer, sdkLB LoadBalancerWithTags) (elbv2model.LoadBalancerStatus, error) Delete(ctx context.Context, sdkLB LoadBalancerWithTags) error }
LoadBalancerManager is responsible for create/update/delete LoadBalancer resources.
type LoadBalancerWithTags ¶
type LoadBalancerWithTags struct { LoadBalancer *elbv2sdk.LoadBalancer Tags map[string]string }
LoadBalancer with it's tags.
type MockTaggingManager ¶
type MockTaggingManager struct {
// contains filtered or unexported fields
}
MockTaggingManager is a mock of TaggingManager interface.
func NewMockTaggingManager ¶
func NewMockTaggingManager(ctrl *gomock.Controller) *MockTaggingManager
NewMockTaggingManager creates a new mock instance.
func (*MockTaggingManager) EXPECT ¶
func (m *MockTaggingManager) EXPECT() *MockTaggingManagerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockTaggingManager) ListListenerRules ¶
func (m *MockTaggingManager) ListListenerRules(arg0 context.Context, arg1 string) ([]ListenerRuleWithTags, error)
ListListenerRules mocks base method.
func (*MockTaggingManager) ListListeners ¶
func (m *MockTaggingManager) ListListeners(arg0 context.Context, arg1 string) ([]ListenerWithTags, error)
ListListeners mocks base method.
func (*MockTaggingManager) ListLoadBalancers ¶
func (m *MockTaggingManager) ListLoadBalancers(arg0 context.Context, arg1 ...tracking.TagFilter) ([]LoadBalancerWithTags, error)
ListLoadBalancers mocks base method.
func (*MockTaggingManager) ListTargetGroups ¶
func (m *MockTaggingManager) ListTargetGroups(arg0 context.Context, arg1 ...tracking.TagFilter) ([]TargetGroupWithTags, error)
ListTargetGroups mocks base method.
func (*MockTaggingManager) ReconcileTags ¶
func (m *MockTaggingManager) ReconcileTags(arg0 context.Context, arg1 string, arg2 map[string]string, arg3 ...ReconcileTagsOption) error
ReconcileTags mocks base method.
type MockTaggingManagerMockRecorder ¶
type MockTaggingManagerMockRecorder struct {
// contains filtered or unexported fields
}
MockTaggingManagerMockRecorder is the mock recorder for MockTaggingManager.
func (*MockTaggingManagerMockRecorder) ListListenerRules ¶
func (mr *MockTaggingManagerMockRecorder) ListListenerRules(arg0, arg1 interface{}) *gomock.Call
ListListenerRules indicates an expected call of ListListenerRules.
func (*MockTaggingManagerMockRecorder) ListListeners ¶
func (mr *MockTaggingManagerMockRecorder) ListListeners(arg0, arg1 interface{}) *gomock.Call
ListListeners indicates an expected call of ListListeners.
func (*MockTaggingManagerMockRecorder) ListLoadBalancers ¶
func (mr *MockTaggingManagerMockRecorder) ListLoadBalancers(arg0 interface{}, arg1 ...interface{}) *gomock.Call
ListLoadBalancers indicates an expected call of ListLoadBalancers.
func (*MockTaggingManagerMockRecorder) ListTargetGroups ¶
func (mr *MockTaggingManagerMockRecorder) ListTargetGroups(arg0 interface{}, arg1 ...interface{}) *gomock.Call
ListTargetGroups indicates an expected call of ListTargetGroups.
func (*MockTaggingManagerMockRecorder) ReconcileTags ¶
func (mr *MockTaggingManagerMockRecorder) ReconcileTags(arg0, arg1, arg2 interface{}, arg3 ...interface{}) *gomock.Call
ReconcileTags indicates an expected call of ReconcileTags.
type ReconcileTagsOption ¶
type ReconcileTagsOption func(opts *ReconcileTagsOptions)
func WithCurrentTags ¶
func WithCurrentTags(tags map[string]string) ReconcileTagsOption
WithCurrentTags is a reconcile option that supplies current tags.
func WithIgnoredTagKeys ¶
func WithIgnoredTagKeys(ignoredTagKeys []string) ReconcileTagsOption
WithIgnoredTagKeys is a reconcile option that configures IgnoredTagKeys.
type ReconcileTagsOptions ¶
type ReconcileTagsOptions struct { // CurrentTags on resources. // when it's nil, the TaggingManager will try to get the CurrentTags from AWS CurrentTags map[string]string // IgnoredTagKeys defines the tag keys that should be ignored. // these tags shouldn't be altered or deleted. IgnoredTagKeys []string }
options for ReconcileTags API.
func (*ReconcileTagsOptions) ApplyOptions ¶
func (opts *ReconcileTagsOptions) ApplyOptions(options []ReconcileTagsOption)
type TaggingManager ¶
type TaggingManager interface { // ReconcileTags will reconcile tags on resources. ReconcileTags(ctx context.Context, arn string, desiredTags map[string]string, opts ...ReconcileTagsOption) error // ListLoadBalancers returns LoadBalancers that matches any of the tagging requirements. ListLoadBalancers(ctx context.Context, tagFilters ...tracking.TagFilter) ([]LoadBalancerWithTags, error) // ListTargetGroups returns TargetGroups that matches any of the tagging requirements. ListTargetGroups(ctx context.Context, tagFilters ...tracking.TagFilter) ([]TargetGroupWithTags, error) // ListListeners returns the LoadBalancer listeners along with tags ListListeners(ctx context.Context, lbARN string) ([]ListenerWithTags, error) // ListListenerRules returns the Listener Rules along with tags ListListenerRules(ctx context.Context, lsARN string) ([]ListenerRuleWithTags, error) }
abstraction around tagging operations for ELBV2.
type TargetGroupAttributesReconciler ¶
type TargetGroupAttributesReconciler interface { // Reconcile TargetGroup attributes Reconcile(ctx context.Context, resTG *elbv2model.TargetGroup, sdkTG TargetGroupWithTags) error }
reconciler for TargetGroup attributes
type TargetGroupBindingManager ¶
type TargetGroupBindingManager interface { Create(ctx context.Context, resTGB *elbv2model.TargetGroupBindingResource) (elbv2model.TargetGroupBindingResourceStatus, error) Update(ctx context.Context, resTGB *elbv2model.TargetGroupBindingResource, k8sTGB *elbv2api.TargetGroupBinding) (elbv2model.TargetGroupBindingResourceStatus, error) Delete(ctx context.Context, k8sTGB *elbv2api.TargetGroupBinding) error }
TargetGroupBindingManager is responsible for create/update/delete TargetGroupBinding resources.
type TargetGroupManager ¶
type TargetGroupManager interface { Create(ctx context.Context, resTG *elbv2model.TargetGroup) (elbv2model.TargetGroupStatus, error) Update(ctx context.Context, resTG *elbv2model.TargetGroup, sdkTG TargetGroupWithTags) (elbv2model.TargetGroupStatus, error) Delete(ctx context.Context, sdkTG TargetGroupWithTags) error }
TargetGroupManager is responsible for create/update/delete TargetGroup resources.
type TargetGroupWithTags ¶
type TargetGroupWithTags struct { TargetGroup *elbv2sdk.TargetGroup Tags map[string]string }
TargetGroup with it's tags.
Source Files ¶
- listener_manager.go
- listener_rule_manager.go
- listener_rule_synthesizer.go
- listener_synthesizer.go
- listener_utils.go
- load_balancer_attributes_reconciler.go
- load_balancer_manager.go
- load_balancer_synthesizer.go
- tagging_manager.go
- tagging_manager_mocks.go
- target_group_attributes_reconciler.go
- target_group_binding_manager.go
- target_group_binding_synthesizer.go
- target_group_manager.go
- target_group_synthesizer.go