lattice

package
v0.0.17 Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2023 License: Apache-2.0 Imports: 23 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.

Index

Constants

View Source 
const (
	LATTICE_RETRY = "LATTICE_RETRY"
)

Variables

View Source 
var RetryErr = errors.New(LATTICE_RETRY)

Functions

func NewDefaultServiceNetworkManager 

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

func NewListenerManager 

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

func NewListenerSynthesizer 

func NewListenerSynthesizer(
	log gwlog.Logger,
	ListenerManager ListenerManager,
	stack core.Stack,
	store *latticestore.LatticeDataStore,
) *listenerSynthesizer

func NewRuleManager 

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

func NewRuleSynthesizer 

func NewRuleSynthesizer(
	log gwlog.Logger,
	ruleManager RuleManager,
	stack core.Stack,
	store *latticestore.LatticeDataStore,
) *ruleSynthesizer

func NewServiceManager 

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

func NewServiceNetworkSynthesizer 

func NewServiceNetworkSynthesizer(
	log gwlog.Logger,
	client client.Client,
	serviceNetworkManager ServiceNetworkManager,
	stack core.Stack,
) *serviceNetworkSynthesizer

func NewServiceSynthesizer 

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

func NewTargetGroupManager 

func NewTargetGroupManager(log gwlog.Logger, cloud pkg_aws.Cloud) *defaultTargetGroupManager

func NewTargetsManager 

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

func NewTargetsSynthesizer 

func NewTargetsSynthesizer(
	log gwlog.Logger,
	cloud pkg_aws.Cloud,
	tgManager TargetsManager,
	stack core.Stack,
	latticeDataStore *latticestore.LatticeDataStore,
) *targetsSynthesizer

Types

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

type GetSvcReq = vpclattice.GetServiceInput

type ListSnSvcAssocsReq added in v0.0.16 

type ListSnSvcAssocsReq = vpclattice.ListServiceNetworkServiceAssociationsInput

type ListenerLSNProvider added in v0.0.17 

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

func (*ListenerLSNProvider) LatticeServiceName added in v0.0.17 

func (r *ListenerLSNProvider) LatticeServiceName() string

type ListenerManager 

type ListenerManager interface {
	Cloud() pkg_aws.Cloud
	Create(ctx context.Context, service *model.Listener) (model.ListenerStatus, error)
	Delete(ctx context.Context, listenerID string, serviceID string) error
	List(ctx context.Context, serviceID string) ([]*vpclattice.ListenerSummary, error)
}

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) Cloud added in v0.0.17 

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

Cloud mocks base method.

func (*MockListenerManager) Create 

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

Create mocks base method.

func (*MockListenerManager) Delete 

func (m *MockListenerManager) Delete(ctx context.Context, listenerID, serviceID string) 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(ctx context.Context, serviceID string) ([]*vpclattice.ListenerSummary, error)

List mocks base method.

type MockListenerManagerMockRecorder 

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

MockListenerManagerMockRecorder is the mock recorder for MockListenerManager.

func (*MockListenerManagerMockRecorder) Cloud added in v0.0.17 

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

Cloud indicates an expected call of Cloud.

func (*MockListenerManagerMockRecorder) Create 

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

Create indicates an expected call of Create.

func (*MockListenerManagerMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

func (*MockListenerManagerMockRecorder) List 

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

List indicates an expected call of List.

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) Cloud added in v0.0.17 

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

Cloud mocks base method.

func (*MockRuleManager) Create 

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

Create mocks base method.

func (*MockRuleManager) Delete 

func (m *MockRuleManager) Delete(ctx context.Context, ruleId, listenerId, serviceId 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(ctx context.Context, serviceId, listenerId, ruleId string) (*vpclattice.GetRuleOutput, error)

Get mocks base method.

func (*MockRuleManager) List 

func (m *MockRuleManager) List(ctx context.Context, serviceId, listenerId string) ([]*lattice.RuleStatus, error)

List mocks base method.

func (*MockRuleManager) Update 

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

Update mocks base method.

type MockRuleManagerMockRecorder 

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

MockRuleManagerMockRecorder is the mock recorder for MockRuleManager.

func (*MockRuleManagerMockRecorder) Cloud added in v0.0.17 

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

Cloud indicates an expected call of Cloud.

func (*MockRuleManagerMockRecorder) Create 

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

Create indicates an expected call of Create.

func (*MockRuleManagerMockRecorder) Delete 

func (mr *MockRuleManagerMockRecorder) Delete(ctx, ruleId, listenerId, serviceId interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockRuleManagerMockRecorder) Get 

func (mr *MockRuleManagerMockRecorder) Get(ctx, serviceId, listenerId, ruleId interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockRuleManagerMockRecorder) List 

func (mr *MockRuleManagerMockRecorder) List(ctx, serviceId, listenerId interface{}) *gomock.Call

List indicates an expected call of List.

func (*MockRuleManagerMockRecorder) Update 

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

Update indicates an expected call of Update.

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

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

Create mocks base method.

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.

type MockServiceManagerMockRecorder 

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

MockServiceManagerMockRecorder is the mock recorder for MockServiceManager.

func (*MockServiceManagerMockRecorder) Create 

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

Create indicates an expected call of Create.

func (*MockServiceManagerMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

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

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

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

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

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

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

Delete indicates an expected call of Delete.

func (*MockServiceNetworkManagerMockRecorder) List 

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

List indicates an expected call of List.

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

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

Create mocks base method.

func (*MockTargetGroupManager) Delete 

func (m *MockTargetGroupManager) Delete(ctx context.Context, targetGroup *lattice.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) Get 

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

Get mocks base method.

func (*MockTargetGroupManager) List 

func (m *MockTargetGroupManager) List(ctx context.Context) ([]targetGroupOutput, error)

List mocks base method.

type MockTargetGroupManagerMockRecorder 

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

MockTargetGroupManagerMockRecorder is the mock recorder for MockTargetGroupManager.

func (*MockTargetGroupManagerMockRecorder) Create 

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

Create indicates an expected call of Create.

func (*MockTargetGroupManagerMockRecorder) Delete 

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

Delete indicates an expected call of Delete.

func (*MockTargetGroupManagerMockRecorder) Get 

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

Get indicates an expected call of Get.

func (*MockTargetGroupManagerMockRecorder) List 

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

List indicates an expected call of List.

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

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

Create mocks base method.

func (*MockTargetsManager) EXPECT 

func (m *MockTargetsManager) EXPECT() *MockTargetsManagerMockRecorder

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

type MockTargetsManagerMockRecorder 

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

MockTargetsManagerMockRecorder is the mock recorder for MockTargetsManager.

func (*MockTargetsManagerMockRecorder) Create 

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

Create indicates an expected call of Create.

type RuleLSNProvider added in v0.0.17 

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

func (*RuleLSNProvider) LatticeServiceName added in v0.0.17 

func (r *RuleLSNProvider) LatticeServiceName() string

type RuleManager 

type RuleManager interface {
	Cloud() pkg_aws.Cloud
	Create(ctx context.Context, rule *model.Rule) (model.RuleStatus, error)
	Delete(ctx context.Context, ruleId string, listenerId string, serviceId string) error
	Update(ctx context.Context, rules []*model.Rule) error
	List(ctx context.Context, serviceId string, listenerId string) ([]*model.RuleStatus, 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 {
	Create(ctx context.Context, service *model.Service) (model.ServiceStatus, error)
	Delete(ctx context.Context, service *model.Service) error
}

type ServiceNetworkManager 

type ServiceNetworkManager interface {
	CreateOrUpdate(ctx context.Context, serviceNetwork *model.ServiceNetwork) (model.ServiceNetworkStatus, error)
	List(ctx context.Context) ([]string, error)
	Delete(ctx context.Context, serviceNetwork string) 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 {
	Create(ctx context.Context, targetGroup *model.TargetGroup) (model.TargetGroupStatus, error)
	Delete(ctx context.Context, targetGroup *model.TargetGroup) error
	List(ctx context.Context) ([]targetGroupOutput, error)
	Get(tx context.Context, targetGroup *model.TargetGroup) (model.TargetGroupStatus, 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,
	stack core.Stack,
	latticeDataStore *latticestore.LatticeDataStore,
) *TargetGroupSynthesizer

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

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

func (*TargetGroupSynthesizer) SynthesizeTriggeredTargetGroup added in v0.0.16 

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

func (*TargetGroupSynthesizer) SynthesizeTriggeredTargetGroupsCreation added in v0.0.16 

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

func (*TargetGroupSynthesizer) SynthesizeTriggeredTargetGroupsDeletion added in v0.0.16 

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

type TargetsManager 

type TargetsManager interface {
	Create(ctx context.Context, targets *model.Targets) 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.