lattice

package
v1.1.5 Latest Latest
Warning

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

 Go to latest Published: Sep 28, 2025 License: Apache-2.0 Imports: 26 Imported by: 1

Documentation

Overview

Package lattice is a generated GoMock package.

Package lattice is a generated GoMock package.

Package lattice is a generated GoMock package.

Package lattice is a generated GoMock package.

Package lattice is a generated GoMock package.

Package lattice is a generated GoMock package.

Package lattice is a generated GoMock package.

Index

Constants

View Source 
const (
	LatticeReadinessGateConditionType = webhook.PodReadinessGateConditionType

	ReadinessReasonHealthy                = "Healthy"
	ReadinessReasonUnhealthy              = "Unhealthy"
	ReadinessReasonUnused                 = "Unused"
	ReadinessReasonInitial                = "Initial"
	ReadinessReasonHealthCheckUnavailable = "HealthCheckUnavailable"
	ReadinessReasonTargetNotFound         = "TargetNotFound"
)

Variables

This section is empty.

Functions

func NewAccessLogSubscriptionManager added in v0.0.18 

func NewAccessLogSubscriptionManager(
	log gwlog.Logger,
	cloud an_aws.Cloud,
) *defaultAccessLogSubscriptionManager

func NewAccessLogSubscriptionSynthesizer added in v0.0.18 

func NewAccessLogSubscriptionSynthesizer(
	log gwlog.Logger,
	client client.Client,
	accessLogSubscriptionManager AccessLogSubscriptionManager,
	stack core.Stack,
) *accessLogSubscriptionSynthesizer

func NewDefaultServiceNetworkManager 

func NewDefaultServiceNetworkManager(log gwlog.Logger, cloud pkg_aws.Cloud) *defaultServiceNetworkManager

func NewListenerManager 

func NewListenerManager(
	log gwlog.Logger,
	cloud pkg_aws.Cloud,
) *defaultListenerManager

func NewListenerSynthesizer 

func NewListenerSynthesizer(
	log gwlog.Logger,
	ListenerManager ListenerManager,
	tgManager TargetGroupManager,
	stack core.Stack,
) *listenerSynthesizer

func NewRuleManager 

func NewRuleManager(
	log gwlog.Logger,
	cloud pkg_aws.Cloud,
) *defaultRuleManager

func NewRuleSynthesizer 

func NewRuleSynthesizer(
	log gwlog.Logger,
	ruleManager RuleManager,
	tgManager TargetGroupManager,
	stack core.Stack,
) *ruleSynthesizer

func NewServiceManager 

func NewServiceManager(log gwlog.Logger, cloud pkg_aws.Cloud) *defaultServiceManager

func NewServiceSynthesizer 

func NewServiceSynthesizer(
	log gwlog.Logger,
	serviceManager ServiceManager,
	dnsEndpointManager externaldns.DnsEndpointManager,
	stack core.Stack,
) *serviceSynthesizer

func NewTargetGroupManager 

func NewTargetGroupManager(log gwlog.Logger, awsCloud pkg_aws.Cloud, k8sClient client.Client) *defaultTargetGroupManager

func NewTargetsManager 

func NewTargetsManager(
	log gwlog.Logger,
	cloud pkg_aws.Cloud,
) *defaultTargetsManager

func NewTargetsSynthesizer 

func NewTargetsSynthesizer(
	log gwlog.Logger,
	client client.Client,
	tgManager TargetsManager,
	stack core.Stack,
) *targetsSynthesizer

Types

type AccessLogSubscriptionManager added in v0.0.18 

type AccessLogSubscriptionManager interface {
	Create(ctx context.Context, accessLogSubscription *lattice.AccessLogSubscription) (*lattice.AccessLogSubscriptionStatus, error)
	Update(ctx context.Context, accessLogSubscription *lattice.AccessLogSubscription) (*lattice.AccessLogSubscriptionStatus, error)
	Delete(ctx context.Context, accessLogSubscriptionArn string) error
}

type CreateSnSvcAssocReq added in v0.0.16 

type CreateSnSvcAssocReq = vpclattice.CreateServiceNetworkServiceAssociationInput

type CreateSnSvcAssocResp added in v0.0.16 

type CreateSnSvcAssocResp = vpclattice.CreateServiceNetworkServiceAssociationOutput

type CreateSvcReq added in v0.0.16 

type CreateSvcReq = vpclattice.CreateServiceInput

type CreateSvcResp added in v0.0.16 

type CreateSvcResp = vpclattice.CreateServiceOutput

type DelSnSvcAssocReq added in v0.0.16 

type DelSnSvcAssocReq = vpclattice.DeleteServiceNetworkServiceAssociationInput

type DelSnSvcAssocResp added in v0.0.16 

type DelSnSvcAssocResp = vpclattice.DeleteServiceNetworkServiceAssociationOutput

type DeleteUnusedResult added in v1.0.3 

type DeleteUnusedResult struct {
	Arn string
	Err error
}

result of deletion attempt, if err is nil target group was deleted

type GetSvcReq added in v0.0.16 

type GetSvcReq = vpclattice.GetServiceInput

type HealthCheckConfigResolver added in v1.1.4 

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

HealthCheckConfigResolver provides centralized logic for resolving health check configuration from TargetGroupPolicy resources for target groups.

func NewHealthCheckConfigResolver added in v1.1.4 

func NewHealthCheckConfigResolver(log gwlog.Logger, client client.Client) *HealthCheckConfigResolver

NewHealthCheckConfigResolver creates a new health check configuration resolver.

func (*HealthCheckConfigResolver) ResolveHealthCheckConfig added in v1.1.4 

func (r *HealthCheckConfigResolver) ResolveHealthCheckConfig(ctx context.Context, targetGroup *model.TargetGroup) (*vpclattice.HealthCheckConfig, error)

ResolveHealthCheckConfig takes a target group model and returns the appropriate health check configuration by checking for applicable TargetGroupPolicy resources. It implements proper error handling and fallback to default configuration when policy resolution fails, ensuring existing behavior is preserved when no policies are applicable.

This function: 1. Checks if the target group is eligible for policy-based health check configuration 2. Attempts to resolve applicable TargetGroupPolicy resources for the target group's service 3. Converts TargetGroupPolicy health check specification to VPC Lattice health check configuration format 4. Falls back gracefully to nil (allowing caller to apply defaults) when policy resolution fails 5. Preserves existing behavior when no policies are applicable

type IAMAuthPolicyManager added in v0.0.18 

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

func NewIAMAuthPolicyManager added in v0.0.18 

func NewIAMAuthPolicyManager(cloud pkg_aws.Cloud) *IAMAuthPolicyManager

func (*IAMAuthPolicyManager) Delete added in v0.0.18 

func (m *IAMAuthPolicyManager) Delete(ctx context.Context, policy model.IAMAuthPolicy) (model.IAMAuthPolicyStatus, error)

func (*IAMAuthPolicyManager) Put added in v0.0.18 

func (m *IAMAuthPolicyManager) Put(ctx context.Context, policy model.IAMAuthPolicy) (model.IAMAuthPolicyStatus, error)

type ListSnSvcAssocsReq added in v0.0.16 

type ListSnSvcAssocsReq = vpclattice.ListServiceNetworkServiceAssociationsInput

type ListenerManager 

type ListenerManager interface {
	Upsert(ctx context.Context, modelListener *model.Listener, modelSvc *model.Service) (model.ListenerStatus, error)
	Delete(ctx context.Context, modelListener *model.Listener) error
	List(ctx context.Context, serviceID string) ([]*vpclattice.ListenerSummary, error)
}

type MockAccessLogSubscriptionManager added in v0.0.18 

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

MockAccessLogSubscriptionManager is a mock of AccessLogSubscriptionManager interface.

func NewMockAccessLogSubscriptionManager added in v0.0.18 

func NewMockAccessLogSubscriptionManager(ctrl *gomock.Controller) *MockAccessLogSubscriptionManager

NewMockAccessLogSubscriptionManager creates a new mock instance.

func (*MockAccessLogSubscriptionManager) Create added in v0.0.18 

func (m *MockAccessLogSubscriptionManager) Create(arg0 context.Context, arg1 *lattice.AccessLogSubscription) (*lattice.AccessLogSubscriptionStatus, error)

Create mocks base method.

func (*MockAccessLogSubscriptionManager) Delete added in v0.0.18 

func (m *MockAccessLogSubscriptionManager) Delete(arg0 context.Context, arg1 string) error

Delete mocks base method.

func (*MockAccessLogSubscriptionManager) EXPECT added in v0.0.18 

func (m *MockAccessLogSubscriptionManager) EXPECT() *MockAccessLogSubscriptionManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockAccessLogSubscriptionManager) Update added in v0.0.18 

func (m *MockAccessLogSubscriptionManager) Update(arg0 context.Context, arg1 *lattice.AccessLogSubscription) (*lattice.AccessLogSubscriptionStatus, error)

Update mocks base method.

type MockAccessLogSubscriptionManagerMockRecorder added in v0.0.18 

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

MockAccessLogSubscriptionManagerMockRecorder is the mock recorder for MockAccessLogSubscriptionManager.

func (*MockAccessLogSubscriptionManagerMockRecorder) Create added in v0.0.18 

func (mr *MockAccessLogSubscriptionManagerMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockAccessLogSubscriptionManagerMockRecorder) Delete added in v0.0.18 

func (mr *MockAccessLogSubscriptionManagerMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockAccessLogSubscriptionManagerMockRecorder) Update added in v0.0.18 

func (mr *MockAccessLogSubscriptionManagerMockRecorder) Update(arg0, arg1 interface{}) *gomock.Call

Update indicates an expected call of Update.

type MockListenerManager 

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

MockListenerManager is a mock of ListenerManager interface.

func NewMockListenerManager 

func NewMockListenerManager(ctrl *gomock.Controller) *MockListenerManager

NewMockListenerManager creates a new mock instance.

func (*MockListenerManager) Delete 

func (m *MockListenerManager) Delete(arg0 context.Context, arg1 *lattice.Listener) error

Delete mocks base method.

func (*MockListenerManager) EXPECT 

func (m *MockListenerManager) EXPECT() *MockListenerManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockListenerManager) List 

func (m *MockListenerManager) List(arg0 context.Context, arg1 string) ([]*vpclattice.ListenerSummary, error)

List mocks base method.

func (*MockListenerManager) Upsert added in v0.0.18 

func (m *MockListenerManager) Upsert(arg0 context.Context, arg1 *lattice.Listener, arg2 *lattice.Service) (lattice.ListenerStatus, error)

Upsert mocks base method.

type MockListenerManagerMockRecorder 

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

MockListenerManagerMockRecorder is the mock recorder for MockListenerManager.

func (*MockListenerManagerMockRecorder) Delete 

func (mr *MockListenerManagerMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockListenerManagerMockRecorder) List 

func (mr *MockListenerManagerMockRecorder) List(arg0, arg1 interface{}) *gomock.Call

List indicates an expected call of List.

func (*MockListenerManagerMockRecorder) Upsert added in v0.0.18 

func (mr *MockListenerManagerMockRecorder) Upsert(arg0, arg1, arg2 interface{}) *gomock.Call

Upsert indicates an expected call of Upsert.

type MockRuleManager 

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

MockRuleManager is a mock of RuleManager interface.

func NewMockRuleManager 

func NewMockRuleManager(ctrl *gomock.Controller) *MockRuleManager

NewMockRuleManager creates a new mock instance.

func (*MockRuleManager) Delete 

func (m *MockRuleManager) Delete(arg0 context.Context, arg1, arg2, arg3 string) error

Delete mocks base method.

func (*MockRuleManager) EXPECT 

func (m *MockRuleManager) EXPECT() *MockRuleManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockRuleManager) Get 

func (m *MockRuleManager) Get(arg0 context.Context, arg1, arg2, arg3 string) (*vpclattice.GetRuleOutput, error)

Get mocks base method.

func (*MockRuleManager) List 

func (m *MockRuleManager) List(arg0 context.Context, arg1, arg2 string) ([]*vpclattice.RuleSummary, error)

List mocks base method.

func (*MockRuleManager) UpdatePriorities added in v0.0.18 

func (m *MockRuleManager) UpdatePriorities(arg0 context.Context, arg1, arg2 string, arg3 []*lattice.Rule) error

UpdatePriorities mocks base method.

func (*MockRuleManager) Upsert added in v0.0.18 

func (m *MockRuleManager) Upsert(arg0 context.Context, arg1 *lattice.Rule, arg2 *lattice.Listener, arg3 *lattice.Service) (lattice.RuleStatus, error)

Upsert mocks base method.

type MockRuleManagerMockRecorder 

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

MockRuleManagerMockRecorder is the mock recorder for MockRuleManager.

func (*MockRuleManagerMockRecorder) Delete 

func (mr *MockRuleManagerMockRecorder) Delete(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockRuleManagerMockRecorder) Get 

func (mr *MockRuleManagerMockRecorder) Get(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockRuleManagerMockRecorder) List 

func (mr *MockRuleManagerMockRecorder) List(arg0, arg1, arg2 interface{}) *gomock.Call

List indicates an expected call of List.

func (*MockRuleManagerMockRecorder) UpdatePriorities added in v0.0.18 

func (mr *MockRuleManagerMockRecorder) UpdatePriorities(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

UpdatePriorities indicates an expected call of UpdatePriorities.

func (*MockRuleManagerMockRecorder) Upsert added in v0.0.18 

func (mr *MockRuleManagerMockRecorder) Upsert(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

Upsert indicates an expected call of Upsert.

type MockServiceManager 

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

MockServiceManager is a mock of ServiceManager interface.

func NewMockServiceManager 

func NewMockServiceManager(ctrl *gomock.Controller) *MockServiceManager

NewMockServiceManager creates a new mock instance.

func (*MockServiceManager) Delete 

func (m *MockServiceManager) Delete(arg0 context.Context, arg1 *lattice.Service) error

Delete mocks base method.

func (*MockServiceManager) EXPECT 

func (m *MockServiceManager) EXPECT() *MockServiceManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockServiceManager) Upsert added in v0.0.18 

func (m *MockServiceManager) Upsert(arg0 context.Context, arg1 *lattice.Service) (lattice.ServiceStatus, error)

Upsert mocks base method.

type MockServiceManagerMockRecorder 

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

MockServiceManagerMockRecorder is the mock recorder for MockServiceManager.

func (*MockServiceManagerMockRecorder) Delete 

func (mr *MockServiceManagerMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockServiceManagerMockRecorder) Upsert added in v0.0.18 

func (mr *MockServiceManagerMockRecorder) Upsert(arg0, arg1 interface{}) *gomock.Call

Upsert indicates an expected call of Upsert.

type MockServiceNetworkManager 

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

MockServiceNetworkManager is a mock of ServiceNetworkManager interface.

func NewMockServiceNetworkManager 

func NewMockServiceNetworkManager(ctrl *gomock.Controller) *MockServiceNetworkManager

NewMockServiceNetworkManager creates a new mock instance.

func (*MockServiceNetworkManager) CreateOrUpdate added in v0.0.17 

func (m *MockServiceNetworkManager) CreateOrUpdate(arg0 context.Context, arg1 *lattice.ServiceNetwork) (lattice.ServiceNetworkStatus, error)

CreateOrUpdate mocks base method.

func (*MockServiceNetworkManager) DeleteVpcAssociation added in v1.0.0 

func (m *MockServiceNetworkManager) DeleteVpcAssociation(arg0 context.Context, arg1 string) error

DeleteVpcAssociation mocks base method.

func (*MockServiceNetworkManager) EXPECT 

func (m *MockServiceNetworkManager) EXPECT() *MockServiceNetworkManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockServiceNetworkManager) UpsertVpcAssociation added in v1.0.0 

func (m *MockServiceNetworkManager) UpsertVpcAssociation(arg0 context.Context, arg1 string, arg2 []*string) (string, error)

UpsertVpcAssociation mocks base method.

type MockServiceNetworkManagerMockRecorder 

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

MockServiceNetworkManagerMockRecorder is the mock recorder for MockServiceNetworkManager.

func (*MockServiceNetworkManagerMockRecorder) CreateOrUpdate added in v0.0.17 

func (mr *MockServiceNetworkManagerMockRecorder) CreateOrUpdate(arg0, arg1 interface{}) *gomock.Call

CreateOrUpdate indicates an expected call of CreateOrUpdate.

func (*MockServiceNetworkManagerMockRecorder) DeleteVpcAssociation added in v1.0.0 

func (mr *MockServiceNetworkManagerMockRecorder) DeleteVpcAssociation(arg0, arg1 interface{}) *gomock.Call

DeleteVpcAssociation indicates an expected call of DeleteVpcAssociation.

func (*MockServiceNetworkManagerMockRecorder) UpsertVpcAssociation added in v1.0.0 

func (mr *MockServiceNetworkManagerMockRecorder) UpsertVpcAssociation(arg0, arg1, arg2 interface{}) *gomock.Call

UpsertVpcAssociation indicates an expected call of UpsertVpcAssociation.

type MockTargetGroupManager 

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

MockTargetGroupManager is a mock of TargetGroupManager interface.

func NewMockTargetGroupManager 

func NewMockTargetGroupManager(ctrl *gomock.Controller) *MockTargetGroupManager

NewMockTargetGroupManager creates a new mock instance.

func (*MockTargetGroupManager) Delete 

func (m *MockTargetGroupManager) Delete(arg0 context.Context, arg1 *lattice0.TargetGroup) error

Delete mocks base method.

func (*MockTargetGroupManager) EXPECT 

func (m *MockTargetGroupManager) EXPECT() *MockTargetGroupManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTargetGroupManager) IsTargetGroupMatch added in v0.0.18 

func (m *MockTargetGroupManager) IsTargetGroupMatch(arg0 context.Context, arg1 *lattice0.TargetGroup, arg2 *vpclattice.TargetGroupSummary, arg3 *lattice0.TargetGroupTagFields) (bool, error)

IsTargetGroupMatch mocks base method.

func (*MockTargetGroupManager) List 

func (m *MockTargetGroupManager) List(arg0 context.Context) ([]tgListOutput, error)

List mocks base method.

func (*MockTargetGroupManager) ResolveRuleTgIds added in v1.0.6 

func (m *MockTargetGroupManager) ResolveRuleTgIds(arg0 context.Context, arg1 *lattice0.RuleAction, arg2 core.Stack) error

ResolveRuleTgIds mocks base method.

func (*MockTargetGroupManager) Upsert added in v0.0.18 

func (m *MockTargetGroupManager) Upsert(arg0 context.Context, arg1 *lattice0.TargetGroup) (lattice0.TargetGroupStatus, error)

Upsert mocks base method.

type MockTargetGroupManagerMockRecorder 

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

MockTargetGroupManagerMockRecorder is the mock recorder for MockTargetGroupManager.

func (*MockTargetGroupManagerMockRecorder) Delete 

func (mr *MockTargetGroupManagerMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockTargetGroupManagerMockRecorder) IsTargetGroupMatch added in v0.0.18 

func (mr *MockTargetGroupManagerMockRecorder) IsTargetGroupMatch(arg0, arg1, arg2, arg3 interface{}) *gomock.Call

IsTargetGroupMatch indicates an expected call of IsTargetGroupMatch.

func (*MockTargetGroupManagerMockRecorder) List 

func (mr *MockTargetGroupManagerMockRecorder) List(arg0 interface{}) *gomock.Call

List indicates an expected call of List.

func (*MockTargetGroupManagerMockRecorder) ResolveRuleTgIds added in v1.0.6 

func (mr *MockTargetGroupManagerMockRecorder) ResolveRuleTgIds(arg0, arg1, arg2 interface{}) *gomock.Call

ResolveRuleTgIds indicates an expected call of ResolveRuleTgIds.

func (*MockTargetGroupManagerMockRecorder) Upsert added in v0.0.18 

func (mr *MockTargetGroupManagerMockRecorder) Upsert(arg0, arg1 interface{}) *gomock.Call

Upsert indicates an expected call of Upsert.

type MockTargetsManager 

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

MockTargetsManager is a mock of TargetsManager interface.

func NewMockTargetsManager 

func NewMockTargetsManager(ctrl *gomock.Controller) *MockTargetsManager

NewMockTargetsManager creates a new mock instance.

func (*MockTargetsManager) EXPECT 

func (m *MockTargetsManager) EXPECT() *MockTargetsManagerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockTargetsManager) List added in v1.0.4 

func (m *MockTargetsManager) List(arg0 context.Context, arg1 *lattice.TargetGroup) ([]*vpclattice.TargetSummary, error)

List mocks base method.

func (*MockTargetsManager) Update added in v0.0.18 

func (m *MockTargetsManager) Update(arg0 context.Context, arg1 *lattice.Targets, arg2 *lattice.TargetGroup) error

Update mocks base method.

type MockTargetsManagerMockRecorder 

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

MockTargetsManagerMockRecorder is the mock recorder for MockTargetsManager.

func (*MockTargetsManagerMockRecorder) List added in v1.0.4 

func (mr *MockTargetsManagerMockRecorder) List(arg0, arg1 interface{}) *gomock.Call

List indicates an expected call of List.

func (*MockTargetsManagerMockRecorder) Update added in v0.0.18 

func (mr *MockTargetsManagerMockRecorder) Update(arg0, arg1, arg2 interface{}) *gomock.Call

Update indicates an expected call of Update.

type RuleManager 

type RuleManager interface {
	Upsert(ctx context.Context, modelRule *model.Rule, modelListener *model.Listener, modelSvc *model.Service) (model.RuleStatus, error)
	Delete(ctx context.Context, ruleId string, serviceId string, listenerId string) error
	UpdatePriorities(ctx context.Context, svcId string, listenerId string, rules []*model.Rule) error
	List(ctx context.Context, serviceId string, listenerId string) ([]*vpclattice.RuleSummary, error)
	Get(ctx context.Context, serviceId string, listenerId string, ruleId string) (*vpclattice.GetRuleOutput, error)
}

type Service added in v0.0.16 

type Service = model.Service

type ServiceInfo added in v0.0.16 

type ServiceInfo = model.ServiceStatus

type ServiceManager 

type ServiceManager interface {
	Upsert(ctx context.Context, service *model.Service) (model.ServiceStatus, error)
	Delete(ctx context.Context, service *model.Service) error
}

type ServiceNetworkManager 

type ServiceNetworkManager interface {
	UpsertVpcAssociation(ctx context.Context, snName string, sgIds []*string) (string, error)
	DeleteVpcAssociation(ctx context.Context, snName string) error

	CreateOrUpdate(ctx context.Context, serviceNetwork *model.ServiceNetwork) (model.ServiceNetworkStatus, error)
}

type SnSvcAssocSummary added in v0.0.16 

type SnSvcAssocSummary = vpclattice.ServiceNetworkServiceAssociationSummary

type SvcSummary added in v0.0.16 

type SvcSummary = vpclattice.ServiceSummary

type TargetGroupManager 

type TargetGroupManager interface {
	Upsert(ctx context.Context, modelTg *model.TargetGroup) (model.TargetGroupStatus, error)
	Delete(ctx context.Context, modelTg *model.TargetGroup) error
	List(ctx context.Context) ([]tgListOutput, error)
	IsTargetGroupMatch(ctx context.Context, modelTg *model.TargetGroup, latticeTg *vpclattice.TargetGroupSummary,
		latticeTags *model.TargetGroupTagFields) (bool, error)
	ResolveRuleTgIds(ctx context.Context, modelRuleAction *model.RuleAction, stack core.Stack) error
}

type TargetGroupSynthesizer added in v0.0.16 

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

func NewTargetGroupSynthesizer 

func NewTargetGroupSynthesizer(
	log gwlog.Logger,
	cloud pkg_aws.Cloud,
	client client.Client,
	tgManager TargetGroupManager,
	svcExportTgBuilder gateway.SvcExportTargetGroupModelBuilder,
	svcBuilder gateway.LatticeServiceBuilder,
	stack core.Stack,
) *TargetGroupSynthesizer

helpful for testing/mocking

func (*TargetGroupSynthesizer) PostSynthesize added in v0.0.16 

func (t *TargetGroupSynthesizer) PostSynthesize(ctx context.Context) error

func (*TargetGroupSynthesizer) Synthesize added in v0.0.16 

func (t *TargetGroupSynthesizer) Synthesize(ctx context.Context) error

func (*TargetGroupSynthesizer) SynthesizeCreate added in v0.0.18 

func (t *TargetGroupSynthesizer) SynthesizeCreate(ctx context.Context) error

func (*TargetGroupSynthesizer) SynthesizeDelete added in v0.0.18 

func (t *TargetGroupSynthesizer) SynthesizeDelete(ctx context.Context) error

func (*TargetGroupSynthesizer) SynthesizeUnusedDelete added in v0.0.18 

func (t *TargetGroupSynthesizer) SynthesizeUnusedDelete(ctx context.Context) ([]DeleteUnusedResult, error)

This method assumes all synthesis. Returns list of deletion results, might include partial failures if cannot produce list for deletion will return error.

TODO: we should do parallel deletion calls, preferably with bounded WorkGroup

type TargetsManager 

type TargetsManager interface {
	List(ctx context.Context, modelTg *model.TargetGroup) ([]*vpclattice.TargetSummary, error)
	Update(ctx context.Context, modelTargets *model.Targets, modelTg *model.TargetGroup) error
}

type UpdateSvcReq added in v0.0.16 

type UpdateSvcReq = vpclattice.UpdateServiceInput

type UpdateSvcResp added in v0.0.16 

type UpdateSvcResp = vpclattice.UpdateServiceOutput

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.