latticestore

Aug 31, 2023

Changes in this version

type LatticeDataStore

+ func NewLatticeDataStoreWithLog(log gwlog.Logger) *LatticeDataStore

+ func (ds *LatticeDataStore) GetTargetGroupsByName(name string) []TargetGroup

Jun 29, 2023

Changes in this version

+ func LatticeServiceName(name string, namespace string) string

May 24, 2023

Changes in this version

+ func TargetGroupLongName(k8sName string, routeName string, vpcid string) string

type LatticeDataStore

+ func (ds *LatticeDataStore) GetTargetGroupsByTG(name string) []TargetGroup

type TargetGroupKey

+ RouteName string

Nov 28, 2022

Changes in this version

+ const DATASTORE_LISTENER_NOT_EXIST

+ const DATASTORE_SERVICE_NETWORK_CREATED

+ const DATASTORE_SERVICE_NETWORK_CREATE_IN_PROGRESS

+ const DATASTORE_SERVICE_NETWORK_NOT_EXIST

+ const DATASTORE_SERVICE_NOT_EXIST

+ const DATASTORE_TG_NOT_EXIST

+ func AWSServiceName(name string, namespace string) string

+ func TargetGroupName(name string, namespace string) string

+ type LatticeDataStore struct

+ func GetDefaultLatticeDataStore() *LatticeDataStore

+ func NewLatticeDataStore() *LatticeDataStore

+ func (c *LatticeDataStore) ServeIntrospection()

+ func (ds *LatticeDataStore) AddLatticeService(name string, namespace string, arn string, id string, dns string) error

+ func (ds *LatticeDataStore) AddListener(name string, namespace string, port int64, protocol string, arn string, ...) error

+ func (ds *LatticeDataStore) AddServiceNetwork(name string, account string, arn string, id string, status string) error

+ func (ds *LatticeDataStore) AddTargetGroup(name string, vpc string, arn string, tgID string, isServiceImport bool) error

+ func (ds *LatticeDataStore) DelLatticeService(name string, namespace string) error

+ func (ds *LatticeDataStore) DelListener(name string, namespace string, port int64, protocol string) error

+ func (ds *LatticeDataStore) DelServiceNetwork(name string, account string) error

+ func (ds *LatticeDataStore) DelTargetGroup(name string, isServiceImport bool) error

+ func (ds *LatticeDataStore) GetAllListeners(name string, namespace string) ([]*Listener, error)

+ func (ds *LatticeDataStore) GetLatticeService(name string, namespace string) (LatticeService, error)

+ func (ds *LatticeDataStore) GetServiceNetworkStatus(name string, account string) (ServiceNetwork, error)

+ func (ds *LatticeDataStore) GetTargetGroup(name string, isServiceImport bool) (TargetGroup, error)

+ func (ds *LatticeDataStore) GetlListener(name string, namespace string, port int64, protocol string) (Listener, error)

+ func (ds *LatticeDataStore) SetTargetGroupByBackendRef(name string, isServiceImport bool, byBackendRef bool) error

+ func (ds *LatticeDataStore) SetTargetGroupByServiceExport(name string, isServiceImport bool, byServiceExport bool) error

+ func (ds *LatticeDataStore) UpdateTargetsForTargetGroup(name string, targetList []Target) error

+ type LatticeDataStoreInfo struct

+ LatticeServices map[string]LatticeService

+ Listeners map[string]Listener

+ ServiceNetworks map[string]ServiceNetwork

+ TargetGroups map[string]TargetGroup

+ type LatticeService struct

+ ARN string

+ DNS string

+ ID string

+ LatticeServiceKey LatticeServiceKey

+ type LatticeServiceKey struct

+ Name string

+ Namespace string

+ type LatticeServicePool map[LatticeServiceKey]*LatticeService

+ type Listener struct

+ ARN string

+ ID string

+ Key ListenerKey

+ type ListenerKey struct

+ Name string

+ Namespace string

+ Port int64

+ Protocol string

+ type ListenerPool map[ListenerKey]*Listener

+ type LoggingHandler struct

+ func (lh LoggingHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type ServiceNetwork struct

+ ARN string

+ ID string

+ Key ServiceNetworkKey

+ Status string

+ type ServiceNetworkKey struct

+ AccountID string

+ Name string

+ type ServiceNetworkPool map[ServiceNetworkKey]*ServiceNetwork

+ type Target struct

+ TargetIP string

+ TargetPort int64

+ type TargetGroup struct

+ ARN string

+ ByBackendRef bool

+ ByServiceExport bool

+ EndPoints []Target

+ ID string

+ TargetGroupKey TargetGroupKey

+ VpcID string

+ type TargetGroupKey struct

+ IsServiceImport bool

+ Name string

+ type TargetGroupPool map[TargetGroupKey]*TargetGroup