lattice

package
v1.0.4 Latest Latest
Warning

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

Go to latest
Published: Mar 26, 2024 License: Apache-2.0 Imports: 24 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"
)
View Source
const (
	LATTICE_RETRY = "LATTICE_RETRY"
)

Variables

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,
	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, cloud pkg_aws.Cloud) *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 CreateSnSvcAssocResp added in v0.0.16

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 DelSnSvcAssocResp added in v0.0.16

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 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 (*IAMAuthPolicyManager) Put added in v0.0.18

type ListSnSvcAssocsReq added in v0.0.16

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

Create mocks base method.

func (*MockAccessLogSubscriptionManager) Delete added in v0.0.18

Delete mocks base method.

func (*MockAccessLogSubscriptionManager) EXPECT added in v0.0.18

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

func (*MockAccessLogSubscriptionManager) Update added in v0.0.18

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

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

func (*MockListenerManager) List

List mocks base method.

func (*MockListenerManager) Upsert added in v0.0.18

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

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

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

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

func (*MockServiceManager) Upsert added in v0.0.18

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

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

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

Delete mocks base method.

func (*MockTargetGroupManager) EXPECT

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

func (*MockTargetGroupManager) IsTargetGroupMatch added in v0.0.18

IsTargetGroupMatch mocks base method.

func (*MockTargetGroupManager) List

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

List mocks base method.

func (*MockTargetGroupManager) Upsert added in v0.0.18

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) 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

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

func (*MockTargetsManager) List added in v1.0.4

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 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)
}

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL