lattice

Aug 12, 2025

Changes in this version

+ type HealthCheckConfigResolver struct

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

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

Jun 14, 2024

Changes in this version

type MockTargetGroupManager

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

type MockTargetGroupManagerMockRecorder

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

type TargetGroupManager

+ ResolveRuleTgIds func(ctx context.Context, modelRuleAction *model.RuleAction, stack core.Stack) error

Mar 26, 2024

Changes in this version

+ const LatticeReadinessGateConditionType

+ const ReadinessReasonHealthCheckUnavailable

+ const ReadinessReasonHealthy

+ const ReadinessReasonInitial

+ const ReadinessReasonTargetNotFound

+ const ReadinessReasonUnhealthy

+ const ReadinessReasonUnused

type MockTargetsManager

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

type MockTargetsManagerMockRecorder

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

type TargetsManager

+ List func(ctx context.Context, modelTg *model.TargetGroup) ([]*vpclattice.TargetSummary, error)

Jan 19, 2024

Changes in this version

+ type DeleteUnusedResult struct

+ Arn string

+ Err error

Nov 18, 2023

Changes in this version

type MockServiceNetworkManager

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

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

type MockServiceNetworkManagerMockRecorder

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

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

type ServiceNetworkManager

+ DeleteVpcAssociation func(ctx context.Context, snName string) error

+ UpsertVpcAssociation func(ctx context.Context, snName string, sgIds []*string) (string, error)

Nov 10, 2023

Changes in this version

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

+ func NewAccessLogSubscriptionSynthesizer(log gwlog.Logger, client client.Client, ...) *accessLogSubscriptionSynthesizer

+ type AccessLogSubscriptionManager interface

+ Create func(ctx context.Context, accessLogSubscription *lattice.AccessLogSubscription) (*lattice.AccessLogSubscriptionStatus, error)

+ Delete func(ctx context.Context, accessLogSubscriptionArn string) error

+ Update func(ctx context.Context, accessLogSubscription *lattice.AccessLogSubscription) (*lattice.AccessLogSubscriptionStatus, error)

+ type IAMAuthPolicyManager struct

+ func NewIAMAuthPolicyManager(cloud pkg_aws.Cloud) *IAMAuthPolicyManager

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

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

type ListenerManager

+ Upsert func(ctx context.Context, modelListener *model.Listener, modelSvc *model.Service) (model.ListenerStatus, error)

+ type MockAccessLogSubscriptionManager struct

+ func NewMockAccessLogSubscriptionManager(ctrl *gomock.Controller) *MockAccessLogSubscriptionManager

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

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

+ func (m *MockAccessLogSubscriptionManager) EXPECT() *MockAccessLogSubscriptionManagerMockRecorder

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

+ type MockAccessLogSubscriptionManagerMockRecorder struct

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

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

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

type MockListenerManager

+ func (m *MockListenerManager) Upsert(ctx context.Context, modelListener *lattice.Listener, ...) (lattice.ListenerStatus, error)

type MockListenerManagerMockRecorder

+ func (mr *MockListenerManagerMockRecorder) Upsert(ctx, modelListener, modelSvc interface{}) *gomock.Call

type MockRuleManager

+ func (m *MockRuleManager) UpdatePriorities(ctx context.Context, svcId, listenerId string, rules []*lattice.Rule) error

+ func (m *MockRuleManager) Upsert(ctx context.Context, modelRule *lattice.Rule, modelListener *lattice.Listener, ...) (lattice.RuleStatus, error)

type MockRuleManagerMockRecorder

+ func (mr *MockRuleManagerMockRecorder) UpdatePriorities(ctx, svcId, listenerId, rules interface{}) *gomock.Call

+ func (mr *MockRuleManagerMockRecorder) Upsert(ctx, modelRule, modelListener, modelSvc interface{}) *gomock.Call

type MockServiceManager

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

type MockServiceManagerMockRecorder

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

type MockTargetGroupManager

+ func (m *MockTargetGroupManager) IsTargetGroupMatch(ctx context.Context, modelTg *lattice.TargetGroup, ...) (bool, error)

+ func (m *MockTargetGroupManager) Upsert(ctx context.Context, modelTg *lattice.TargetGroup) (lattice.TargetGroupStatus, error)

type MockTargetGroupManagerMockRecorder

+ func (mr *MockTargetGroupManagerMockRecorder) IsTargetGroupMatch(ctx, modelTg, latticeTg, latticeTags interface{}) *gomock.Call

+ func (mr *MockTargetGroupManagerMockRecorder) Upsert(ctx, modelTg interface{}) *gomock.Call

type MockTargetsManager

+ func (m *MockTargetsManager) Update(ctx context.Context, modelTargets *lattice.Targets, ...) error

type MockTargetsManagerMockRecorder

+ func (mr *MockTargetsManagerMockRecorder) Update(ctx, modelTargets, modelTg interface{}) *gomock.Call

type RuleManager

+ UpdatePriorities func(ctx context.Context, svcId string, listenerId string, rules []*model.Rule) error

+ Upsert func(ctx context.Context, modelRule *model.Rule, modelListener *model.Listener, ...) (model.RuleStatus, error)

type ServiceManager

+ Upsert func(ctx context.Context, service *model.Service) (model.ServiceStatus, error)

type TargetGroupManager

+ IsTargetGroupMatch func(ctx context.Context, modelTg *model.TargetGroup, ...) (bool, error)

+ Upsert func(ctx context.Context, modelTg *model.TargetGroup) (model.TargetGroupStatus, error)

type TargetGroupSynthesizer

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

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

+ func (t *TargetGroupSynthesizer) SynthesizeUnusedDelete(ctx context.Context) error

type TargetsManager

+ Update func(ctx context.Context, modelTargets *model.Targets, modelTg *model.TargetGroup) error

Oct 5, 2023

Changes in this version

+ type ListenerLSNProvider struct

+ func (r *ListenerLSNProvider) LatticeServiceName() string

type ListenerManager

+ Cloud func() pkg_aws.Cloud

type MockListenerManager

+ func (m *MockListenerManager) Cloud() aws.Cloud

type MockListenerManagerMockRecorder

+ func (mr *MockListenerManagerMockRecorder) Cloud() *gomock.Call

type MockRuleManager

+ func (m *MockRuleManager) Cloud() aws.Cloud

type MockRuleManagerMockRecorder

+ func (mr *MockRuleManagerMockRecorder) Cloud() *gomock.Call

type MockServiceNetworkManager

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

type MockServiceNetworkManagerMockRecorder

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

+ type RuleLSNProvider struct

+ func (r *RuleLSNProvider) LatticeServiceName() string

type RuleManager

+ Cloud func() pkg_aws.Cloud

type ServiceNetworkManager

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

Aug 31, 2023

Changes in this version

+ var RetryErr = errors.New(LATTICE_RETRY)

+ type CreateSnSvcAssocReq = vpclattice.CreateServiceNetworkServiceAssociationInput

+ type CreateSnSvcAssocResp = vpclattice.CreateServiceNetworkServiceAssociationOutput

+ type CreateSvcReq = vpclattice.CreateServiceInput

+ type CreateSvcResp = vpclattice.CreateServiceOutput

+ type DelSnSvcAssocReq = vpclattice.DeleteServiceNetworkServiceAssociationInput

+ type DelSnSvcAssocResp = vpclattice.DeleteServiceNetworkServiceAssociationOutput

+ type GetSvcReq = vpclattice.GetServiceInput

+ type ListSnSvcAssocsReq = vpclattice.ListServiceNetworkServiceAssociationsInput

+ type Service = latticemodel.Service

+ type ServiceInfo = latticemodel.ServiceStatus

+ type SnSvcAssocSummary = vpclattice.ServiceNetworkServiceAssociationSummary

+ type SvcSummary = vpclattice.ServiceSummary

+ type TargetGroupSynthesizer struct

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

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

+ func (t *TargetGroupSynthesizer) SynthesizeSDKTargetGroups(ctx context.Context) error

+ func (t *TargetGroupSynthesizer) SynthesizeTriggeredTargetGroup(ctx context.Context) error

+ func (t *TargetGroupSynthesizer) SynthesizeTriggeredTargetGroupsCreation(ctx context.Context) error

+ func (t *TargetGroupSynthesizer) SynthesizeTriggeredTargetGroupsDeletion(ctx context.Context) error

+ type UpdateSvcReq = vpclattice.UpdateServiceInput

+ type UpdateSvcResp = vpclattice.UpdateServiceOutput

Nov 28, 2022

Changes in this version

+ const LATTICE_ALREADY_EXIST

+ const LATTICE_CREATE_IN_PROGRESS

+ const LATTICE_DELETE_IN_PROGRESS

+ const LATTICE_NOT_FOUND

+ const LATTICE_RETRY

+ func NewDefaultServiceNetworkManager(cloud lattice_aws.Cloud) *defaultServiceNetworkManager

+ func NewListenerManager(cloud lattice_aws.Cloud, latticeDataStore *latticestore.LatticeDataStore) *defaultListenerManager

+ func NewListenerSynthesizer(ListenerManager ListenerManager, stack core.Stack, ...) *listenerSynthesizer

+ func NewRuleManager(cloud lattice_aws.Cloud, store *latticestore.LatticeDataStore) *defaultRuleManager

+ func NewRuleSynthesizer(ruleManager RuleManager, stack core.Stack, ...) *ruleSynthesizer

+ func NewServiceManager(cloud lattice_aws.Cloud, latticeDataStore *latticestore.LatticeDataStore) *defaultServiceManager

+ func NewServiceNetworkSynthesizer(client client.Client, serviceNetworkManager ServiceNetworkManager, ...) *serviceNetworkSynthesizer

+ func NewServiceSynthesizer(serviceManager ServiceManager, stack core.Stack, ...) *serviceSynthesizer

+ func NewTargetGroupManager(cloud lattice_aws.Cloud) *defaultTargetGroupManager

+ func NewTargetGroupSynthesizer(cloud lattice_aws.Cloud, client client.Client, tgManager TargetGroupManager, ...) *targetGroupSynthesizer

+ func NewTargetsManager(cloud lattice_aws.Cloud, datastore *latticestore.LatticeDataStore) *defaultTargetsManager

+ func NewTargetsSynthesizer(cloud lattice_aws.Cloud, tgManager TargetsManager, stack core.Stack, ...) *targetsSynthesizer

+ type ListenerManager interface

+ Create func(ctx context.Context, service *latticemodel.Listener) (latticemodel.ListenerStatus, error)

+ Delete func(ctx context.Context, listenerID string, serviceID string) error

+ List func(ctx context.Context, serviceID string) ([]*vpclattice.ListenerSummary, error)

+ type MockListenerManager struct

+ func NewMockListenerManager(ctrl *gomock.Controller) *MockListenerManager

+ func (m *MockListenerManager) Create(ctx context.Context, service *lattice.Listener) (lattice.ListenerStatus, error)

+ func (m *MockListenerManager) Delete(ctx context.Context, listenerID, serviceID string) error

+ func (m *MockListenerManager) EXPECT() *MockListenerManagerMockRecorder

+ func (m *MockListenerManager) List(ctx context.Context, serviceID string) ([]*vpclattice.ListenerSummary, error)

+ type MockListenerManagerMockRecorder struct

+ func (mr *MockListenerManagerMockRecorder) Create(ctx, service interface{}) *gomock.Call

+ func (mr *MockListenerManagerMockRecorder) Delete(ctx, listenerID, serviceID interface{}) *gomock.Call

+ func (mr *MockListenerManagerMockRecorder) List(ctx, serviceID interface{}) *gomock.Call

+ type MockRuleManager struct

+ func NewMockRuleManager(ctrl *gomock.Controller) *MockRuleManager

+ func (m *MockRuleManager) Create(ctx context.Context, rule *lattice.Rule) (lattice.RuleStatus, error)

+ func (m *MockRuleManager) Delete(ctx context.Context, ruleID, listenerID, serviceID string) error

+ func (m *MockRuleManager) EXPECT() *MockRuleManagerMockRecorder

+ func (m *MockRuleManager) Get(ctx context.Context, serviceID, listernID, ruleID string) (*vpclattice.GetRuleOutput, error)

+ func (m *MockRuleManager) List(ctx context.Context, serviceID, listenerID string) ([]*lattice.RuleStatus, error)

+ func (m *MockRuleManager) Update(ctx context.Context, rules []*lattice.Rule) error

+ type MockRuleManagerMockRecorder struct

+ func (mr *MockRuleManagerMockRecorder) Create(ctx, rule interface{}) *gomock.Call

+ func (mr *MockRuleManagerMockRecorder) Delete(ctx, ruleID, listenerID, serviceID interface{}) *gomock.Call

+ func (mr *MockRuleManagerMockRecorder) Get(ctx, serviceID, listernID, ruleID interface{}) *gomock.Call

+ func (mr *MockRuleManagerMockRecorder) List(ctx, serviceID, listenerID interface{}) *gomock.Call

+ func (mr *MockRuleManagerMockRecorder) Update(ctx, rules interface{}) *gomock.Call

+ type MockServiceManager struct

+ func NewMockServiceManager(ctrl *gomock.Controller) *MockServiceManager

+ func (m *MockServiceManager) Create(ctx context.Context, service *lattice.Service) (lattice.ServiceStatus, error)

+ func (m *MockServiceManager) Delete(ctx context.Context, service *lattice.Service) error

+ func (m *MockServiceManager) EXPECT() *MockServiceManagerMockRecorder

+ type MockServiceManagerMockRecorder struct

+ func (mr *MockServiceManagerMockRecorder) Create(ctx, service interface{}) *gomock.Call

+ func (mr *MockServiceManagerMockRecorder) Delete(ctx, service interface{}) *gomock.Call

+ type MockServiceNetworkManager struct

+ func NewMockServiceNetworkManager(ctrl *gomock.Controller) *MockServiceNetworkManager

+ func (m *MockServiceNetworkManager) Create(ctx context.Context, service_network *lattice.ServiceNetwork) (lattice.ServiceNetworkStatus, error)

+ func (m *MockServiceNetworkManager) Delete(ctx context.Context, service_network string) error

+ func (m *MockServiceNetworkManager) EXPECT() *MockServiceNetworkManagerMockRecorder

+ func (m *MockServiceNetworkManager) List(ctx context.Context) ([]string, error)

+ type MockServiceNetworkManagerMockRecorder struct

+ func (mr *MockServiceNetworkManagerMockRecorder) Create(ctx, service_network interface{}) *gomock.Call

+ func (mr *MockServiceNetworkManagerMockRecorder) Delete(ctx, service_network interface{}) *gomock.Call

+ func (mr *MockServiceNetworkManagerMockRecorder) List(ctx interface{}) *gomock.Call

+ type MockTargetGroupManager struct

+ func NewMockTargetGroupManager(ctrl *gomock.Controller) *MockTargetGroupManager

+ func (m *MockTargetGroupManager) Create(ctx context.Context, targetGroup *lattice.TargetGroup) (lattice.TargetGroupStatus, error)

+ func (m *MockTargetGroupManager) Delete(ctx context.Context, targetGroup *lattice.TargetGroup) error

+ func (m *MockTargetGroupManager) EXPECT() *MockTargetGroupManagerMockRecorder

+ func (m *MockTargetGroupManager) Get(tx context.Context, targetGroup *lattice.TargetGroup) (lattice.TargetGroupStatus, error)

+ func (m *MockTargetGroupManager) List(ctx context.Context) ([]vpclattice.GetTargetGroupOutput, error)

+ type MockTargetGroupManagerMockRecorder struct

+ func (mr *MockTargetGroupManagerMockRecorder) Create(ctx, targetGroup interface{}) *gomock.Call

+ func (mr *MockTargetGroupManagerMockRecorder) Delete(ctx, targetGroup interface{}) *gomock.Call

+ func (mr *MockTargetGroupManagerMockRecorder) Get(tx, targetGroup interface{}) *gomock.Call

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

+ type MockTargetsManager struct

+ func NewMockTargetsManager(ctrl *gomock.Controller) *MockTargetsManager

+ func (m *MockTargetsManager) Create(ctx context.Context, targets *lattice.Targets) error

+ func (m *MockTargetsManager) EXPECT() *MockTargetsManagerMockRecorder

+ type MockTargetsManagerMockRecorder struct

+ func (mr *MockTargetsManagerMockRecorder) Create(ctx, targets interface{}) *gomock.Call

+ type RuleManager interface

+ Create func(ctx context.Context, rule *latticemodel.Rule) (latticemodel.RuleStatus, error)

+ Delete func(ctx context.Context, ruleID string, listenerID string, serviceID string) error

+ Get func(ctx context.Context, serviceID string, listernID string, ruleID string) (*vpclattice.GetRuleOutput, error)

+ List func(ctx context.Context, serviceID string, listenerID string) ([]*latticemodel.RuleStatus, error)

+ Update func(ctx context.Context, rules []*latticemodel.Rule) error

+ type ServiceManager interface

+ Create func(ctx context.Context, service *latticemodel.Service) (latticemodel.ServiceStatus, error)

+ Delete func(ctx context.Context, service *latticemodel.Service) error

+ type ServiceNetworkManager interface

+ Create func(ctx context.Context, service_network *latticemodel.ServiceNetwork) (latticemodel.ServiceNetworkStatus, error)

+ Delete func(ctx context.Context, service_network string) error

+ List func(ctx context.Context) ([]string, error)

+ type TargetGroupManager interface

+ Create func(ctx context.Context, targetGroup *latticemodel.TargetGroup) (latticemodel.TargetGroupStatus, error)

+ Delete func(ctx context.Context, targetGroup *latticemodel.TargetGroup) error

+ Get func(tx context.Context, targetGroup *latticemodel.TargetGroup) (latticemodel.TargetGroupStatus, error)

+ List func(ctx context.Context) ([]vpclattice.GetTargetGroupOutput, error)

+ type TargetsManager interface

+ Create func(ctx context.Context, targets *latticemodel.Targets) error