Versions in this module Expand all Collapse all v0 v0.0.2 Nov 3, 2023 v0.0.1 Nov 3, 2023 Changes in this version + var ErrAlreadyExists = fmt.Errorf("entity already exists") + var ErrNotFound = fmt.Errorf("entity not found") + type ACLGroup struct + func (b1 *ACLGroup) Console() string + func (b1 *ACLGroup) Equal(b2 *ACLGroup) bool + func (b1 *ACLGroup) EqualWithOpts(b2 *ACLGroup, ignoreID, ignoreTS, ignoreForeign bool) bool + type ACLGroupsCollection collection + func (k *ACLGroupsCollection) Add(aclGroup ACLGroup) error + func (k *ACLGroupsCollection) Delete(id string) error + func (k *ACLGroupsCollection) Get(consumerID, groupOrID string) (*ACLGroup, error) + func (k *ACLGroupsCollection) GetAll() ([]*ACLGroup, error) + func (k *ACLGroupsCollection) GetAllByConsumerID(id string) ([]*ACLGroup, error) + func (k *ACLGroupsCollection) GetByID(id string) (*ACLGroup, error) + func (k *ACLGroupsCollection) Update(aclGroup ACLGroup) error + type BasicAuth struct + func (b1 *BasicAuth) Console() string + func (b1 *BasicAuth) Equal(b2 *BasicAuth) bool + func (b1 *BasicAuth) EqualWithOpts(b2 *BasicAuth, ignoreID, ignoreTS, ignorePassword, ignoreForeign bool) bool + func (b1 *BasicAuth) GetConsumer() string + func (b1 *BasicAuth) GetID() string + func (b1 *BasicAuth) GetID2() string + type BasicAuthsCollection struct + func (k *BasicAuthsCollection) Add(basicAuth BasicAuth) error + func (k *BasicAuthsCollection) Delete(keyOrID string) error + func (k *BasicAuthsCollection) Get(keyOrID string) (*BasicAuth, error) + func (k *BasicAuthsCollection) GetAll() ([]*BasicAuth, error) + func (k *BasicAuthsCollection) GetAllByConsumerID(id string) ([]*BasicAuth, error) + func (k *BasicAuthsCollection) Schema() *memdb.TableSchema + func (k *BasicAuthsCollection) TableName() string + func (k *BasicAuthsCollection) Update(basicAuth BasicAuth) error + type CACertificate struct + func (c1 *CACertificate) Console() string + func (c1 *CACertificate) Equal(c2 *CACertificate) bool + func (c1 *CACertificate) EqualWithOpts(c2 *CACertificate, ignoreID bool, ignoreTS bool) bool + func (c1 *CACertificate) Identifier() string + type CACertificatesCollection collection + func (k *CACertificatesCollection) Add(caCert CACertificate) error + func (k *CACertificatesCollection) Delete(certOrID string) error + func (k *CACertificatesCollection) Get(certOrID string) (*CACertificate, error) + func (k *CACertificatesCollection) GetAll() ([]*CACertificate, error) + func (k *CACertificatesCollection) Update(caCert CACertificate) error + type Certificate struct + func (c1 *Certificate) Console() string + func (c1 *Certificate) Equal(c2 *Certificate) bool + func (c1 *Certificate) EqualWithOpts(c2 *Certificate, ignoreID bool, ignoreTS bool) bool + func (c1 *Certificate) Identifier() string + type CertificatesCollection collection + func (k *CertificatesCollection) Add(certificate Certificate) error + func (k *CertificatesCollection) Delete(id string) error + func (k *CertificatesCollection) DeleteByCertKey(cert, key string) error + func (k *CertificatesCollection) Get(id string) (*Certificate, error) + func (k *CertificatesCollection) GetAll() ([]*Certificate, error) + func (k *CertificatesCollection) GetByCertKey(cert, key string) (*Certificate, error) + func (k *CertificatesCollection) Update(certificate Certificate) error + type ConsoleString interface + Console func() string + type Consumer struct + func (c1 *Consumer) Console() string + func (c1 *Consumer) Equal(c2 *Consumer) bool + func (c1 *Consumer) EqualWithOpts(c2 *Consumer, ignoreID bool, ignoreTS bool) bool + func (c1 *Consumer) Identifier() string + type ConsumerGroup struct + func (c1 *ConsumerGroup) Console() string + func (c1 *ConsumerGroup) Equal(c2 *ConsumerGroup) bool + func (c1 *ConsumerGroup) EqualWithOpts(c2 *ConsumerGroup, ignoreID bool, ignoreTS bool) bool + func (c1 *ConsumerGroup) Identifier() string + type ConsumerGroupConsumer struct + func (c1 *ConsumerGroupConsumer) Console() string + func (c1 *ConsumerGroupConsumer) Equal(c2 *ConsumerGroupConsumer) bool + func (c1 *ConsumerGroupConsumer) EqualWithOpts(c2 *ConsumerGroupConsumer, ignoreID bool, ignoreTS bool) bool + func (c1 *ConsumerGroupConsumer) Identifier() string + type ConsumerGroupConsumersCollection collection + func (k *ConsumerGroupConsumersCollection) Add(consumer ConsumerGroupConsumer) error + func (k *ConsumerGroupConsumersCollection) Delete(nameOrID, consumerGroupID string) error + func (k *ConsumerGroupConsumersCollection) Get(nameOrID, consumerGroupID string) (*ConsumerGroupConsumer, error) + func (k *ConsumerGroupConsumersCollection) GetAll() ([]*ConsumerGroupConsumer, error) + func (k *ConsumerGroupConsumersCollection) Update(consumer ConsumerGroupConsumer) error + type ConsumerGroupObject struct + func (c1 *ConsumerGroupObject) Console() string + func (c1 *ConsumerGroupObject) Equal(c2 *ConsumerGroupObject) bool + func (c1 *ConsumerGroupObject) EqualWithOpts(c2 *ConsumerGroupObject, ignoreID bool, ignoreTS bool) bool + func (c1 *ConsumerGroupObject) Identifier() string + type ConsumerGroupPlugin struct + func (c1 *ConsumerGroupPlugin) Console() string + func (c1 *ConsumerGroupPlugin) Equal(c2 *ConsumerGroupPlugin) bool + func (c1 *ConsumerGroupPlugin) EqualWithOpts(c2 *ConsumerGroupPlugin, ignoreID bool, ignoreTS bool) bool + func (c1 *ConsumerGroupPlugin) Identifier() string + type ConsumerGroupPluginsCollection collection + func (k *ConsumerGroupPluginsCollection) Add(plugin ConsumerGroupPlugin) error + func (k *ConsumerGroupPluginsCollection) Delete(nameOrID, consumerGroupID string) error + func (k *ConsumerGroupPluginsCollection) Get(nameOrID, consumerGroupID string) (*ConsumerGroupPlugin, error) + func (k *ConsumerGroupPluginsCollection) GetAll() ([]*ConsumerGroupPlugin, error) + func (k *ConsumerGroupPluginsCollection) Update(plugin ConsumerGroupPlugin) error + type ConsumerGroupsCollection collection + func (k *ConsumerGroupsCollection) Add(consumerGroup ConsumerGroup) error + func (k *ConsumerGroupsCollection) Delete(nameOrID string) error + func (k *ConsumerGroupsCollection) Get(nameOrID string) (*ConsumerGroup, error) + func (k *ConsumerGroupsCollection) GetAll() ([]*ConsumerGroup, error) + func (k *ConsumerGroupsCollection) Update(consumerGroup ConsumerGroup) error + type ConsumersCollection collection + func (k *ConsumersCollection) Add(consumer Consumer) error + func (k *ConsumersCollection) Delete(userNameOrID string) error + func (k *ConsumersCollection) GetAll() ([]*Consumer, error) + func (k *ConsumersCollection) GetByCustomID(customID string) (*Consumer, error) + func (k *ConsumersCollection) GetByIDOrUsername(userNameOrID string) (*Consumer, error) + func (k *ConsumersCollection) Update(consumer Consumer) error + type Document struct + func (d1 *Document) Console() string + func (d1 *Document) Equal(d2 *Document) bool + func (d1 *Document) EqualWithOpts(d2 *Document, ignoreID, _, ignoreForeign bool) bool + func (d1 *Document) Identifier() string + type DocumentsCollection collection + func (k *DocumentsCollection) Add(document Document) error + func (k *DocumentsCollection) DeleteByParent(parent konnect.ParentInfoer, pathOrID string) error + func (k *DocumentsCollection) GetAll() ([]*Document, error) + func (k *DocumentsCollection) GetAllByParent(parent konnect.ParentInfoer) ([]*Document, error) + func (k *DocumentsCollection) GetByParent(parent konnect.ParentInfoer, pathOrID string) (*Document, error) + func (k *DocumentsCollection) Update(document Document) error + type HMACAuth struct + func (h1 *HMACAuth) Console() string + func (h1 *HMACAuth) Equal(h2 *HMACAuth) bool + func (h1 *HMACAuth) EqualWithOpts(h2 *HMACAuth, ignoreID, ignoreTS, ignoreForeign bool) bool + func (h1 *HMACAuth) GetConsumer() string + func (h1 *HMACAuth) GetID() string + func (h1 *HMACAuth) GetID2() string + type HMACAuthsCollection struct + func (k *HMACAuthsCollection) Add(hmacAuth HMACAuth) error + func (k *HMACAuthsCollection) Delete(keyOrID string) error + func (k *HMACAuthsCollection) Get(keyOrID string) (*HMACAuth, error) + func (k *HMACAuthsCollection) GetAll() ([]*HMACAuth, error) + func (k *HMACAuthsCollection) GetAllByConsumerID(id string) ([]*HMACAuth, error) + func (k *HMACAuthsCollection) Schema() *memdb.TableSchema + func (k *HMACAuthsCollection) TableName() string + func (k *HMACAuthsCollection) Update(hmacAuth HMACAuth) error + type JWTAuth struct + func (j1 *JWTAuth) Console() string + func (j1 *JWTAuth) Equal(j2 *JWTAuth) bool + func (j1 *JWTAuth) EqualWithOpts(j2 *JWTAuth, ignoreID, ignoreTS, ignoreForeign bool) bool + func (j1 *JWTAuth) GetConsumer() string + func (j1 *JWTAuth) GetID() string + func (j1 *JWTAuth) GetID2() string + type JWTAuthsCollection struct + func (k *JWTAuthsCollection) Add(jwtAuth JWTAuth) error + func (k *JWTAuthsCollection) Delete(keyOrID string) error + func (k *JWTAuthsCollection) Get(keyOrID string) (*JWTAuth, error) + func (k *JWTAuthsCollection) GetAll() ([]*JWTAuth, error) + func (k *JWTAuthsCollection) GetAllByConsumerID(id string) ([]*JWTAuth, error) + func (k *JWTAuthsCollection) Schema() *memdb.TableSchema + func (k *JWTAuthsCollection) TableName() string + func (k *JWTAuthsCollection) Update(jwtAuth JWTAuth) error + type KeyAuth struct + func (k1 *KeyAuth) Console() string + func (k1 *KeyAuth) Equal(k2 *KeyAuth) bool + func (k1 *KeyAuth) EqualWithOpts(k2 *KeyAuth, ignoreID, ignoreTS, ignoreForeign bool) bool + func (k1 *KeyAuth) GetConsumer() string + func (k1 *KeyAuth) GetID() string + func (k1 *KeyAuth) GetID2() string + type KeyAuthsCollection struct + func (k *KeyAuthsCollection) Add(keyAuth KeyAuth) error + func (k *KeyAuthsCollection) Delete(keyOrID string) error + func (k *KeyAuthsCollection) Get(keyOrID string) (*KeyAuth, error) + func (k *KeyAuthsCollection) GetAll() ([]*KeyAuth, error) + func (k *KeyAuthsCollection) GetAllByConsumerID(id string) ([]*KeyAuth, error) + func (k *KeyAuthsCollection) Schema() *memdb.TableSchema + func (k *KeyAuthsCollection) TableName() string + func (k *KeyAuthsCollection) Update(keyAuth KeyAuth) error + type KongState struct + ACLGroups *ACLGroupsCollection + BasicAuths *BasicAuthsCollection + CACertificates *CACertificatesCollection + Certificates *CertificatesCollection + ConsumerGroupConsumers *ConsumerGroupConsumersCollection + ConsumerGroupPlugins *ConsumerGroupPluginsCollection + ConsumerGroups *ConsumerGroupsCollection + Consumers *ConsumersCollection + Documents *DocumentsCollection + HMACAuths *HMACAuthsCollection + JWTAuths *JWTAuthsCollection + KeyAuths *KeyAuthsCollection + MTLSAuths *MTLSAuthsCollection + Oauth2Creds *Oauth2CredsCollection + Plugins *PluginsCollection + RBACEndpointPermissions *RBACEndpointPermissionsCollection + RBACRoles *RBACRolesCollection + Routes *RoutesCollection + SNIs *SNIsCollection + ServicePackages *ServicePackagesCollection + ServiceVersions *ServiceVersionsCollection + Services *ServicesCollection + Targets *TargetsCollection + Upstreams *UpstreamsCollection + Vaults *VaultsCollection + func Get(raw *utils.KongRawState) (*KongState, error) + func GetKonnectState(rawKong *utils.KongRawState, rawKonnect *utils.KonnectRawState) (*KongState, error) + func NewKongState() (*KongState, error) + type MTLSAuth struct + func (b1 *MTLSAuth) Console() string + func (b1 *MTLSAuth) Equal(b2 *MTLSAuth) bool + func (b1 *MTLSAuth) EqualWithOpts(b2 *MTLSAuth, ignoreID, ignoreTS, ignoreForeign bool) bool + func (b1 *MTLSAuth) GetConsumer() string + func (b1 *MTLSAuth) GetID() string + func (b1 *MTLSAuth) GetID2() string + type MTLSAuthsCollection struct + func (k *MTLSAuthsCollection) Add(mtlsAuth MTLSAuth) error + func (k *MTLSAuthsCollection) Delete(ID string) error + func (k *MTLSAuthsCollection) Get(ID string) (*MTLSAuth, error) + func (k *MTLSAuthsCollection) GetAll() ([]*MTLSAuth, error) + func (k *MTLSAuthsCollection) GetAllByConsumerID(id string) ([]*MTLSAuth, error) + func (k *MTLSAuthsCollection) Schema() *memdb.TableSchema + func (k *MTLSAuthsCollection) TableName() string + func (k *MTLSAuthsCollection) Update(mtlsAuth MTLSAuth) error + type Meta struct + func (m *Meta) AddMeta(key string, obj interface{}) + func (m *Meta) GetMeta(key string) interface{} + type Oauth2Credential struct + func (k1 *Oauth2Credential) Console() string + func (k1 *Oauth2Credential) Equal(k2 *Oauth2Credential) bool + func (k1 *Oauth2Credential) EqualWithOpts(k2 *Oauth2Credential, ignoreID, ignoreTS, ignoreForeign bool) bool + func (k1 *Oauth2Credential) GetConsumer() string + func (k1 *Oauth2Credential) GetID() string + func (k1 *Oauth2Credential) GetID2() string + type Oauth2CredsCollection struct + func (k *Oauth2CredsCollection) Add(keyAuth Oauth2Credential) error + func (k *Oauth2CredsCollection) Delete(keyOrID string) error + func (k *Oauth2CredsCollection) Get(keyOrID string) (*Oauth2Credential, error) + func (k *Oauth2CredsCollection) GetAll() ([]*Oauth2Credential, error) + func (k *Oauth2CredsCollection) GetAllByConsumerID(id string) ([]*Oauth2Credential, error) + func (k *Oauth2CredsCollection) Schema() *memdb.TableSchema + func (k *Oauth2CredsCollection) TableName() string + func (k *Oauth2CredsCollection) Update(keyAuth Oauth2Credential) error + type Plugin struct + func (p1 *Plugin) Console() string + func (p1 *Plugin) Equal(p2 *Plugin) bool + func (p1 *Plugin) EqualWithOpts(p2 *Plugin, ignoreID, ignoreTS, ignoreForeign bool) bool + func (p1 *Plugin) Identifier() string + type PluginsCollection collection + func (k *PluginsCollection) Add(plugin Plugin) error + func (k *PluginsCollection) Delete(id string) error + func (k *PluginsCollection) Get(id string) (*Plugin, error) + func (k *PluginsCollection) GetAll() ([]*Plugin, error) + func (k *PluginsCollection) GetAllByConsumerGroupID(id string) ([]*Plugin, error) + func (k *PluginsCollection) GetAllByConsumerID(id string) ([]*Plugin, error) + func (k *PluginsCollection) GetAllByName(name string) ([]*Plugin, error) + func (k *PluginsCollection) GetAllByRouteID(id string) ([]*Plugin, error) + func (k *PluginsCollection) GetAllByServiceID(id string) ([]*Plugin, error) + func (k *PluginsCollection) GetByProp(name, serviceID, routeID, consumerID, consumerGroupID string) (*Plugin, error) + func (k *PluginsCollection) Update(plugin Plugin) error + type RBACEndpointPermission struct + ID string + func (r1 *RBACEndpointPermission) Console() string + func (r1 *RBACEndpointPermission) Equal(r2 *RBACEndpointPermission) bool + func (r1 *RBACEndpointPermission) EqualWithOpts(r2 *RBACEndpointPermission, ignoreID, ignoreTS, _ bool) bool + func (r1 *RBACEndpointPermission) Identifier() string + type RBACEndpointPermissionsCollection collection + func (k *RBACEndpointPermissionsCollection) Add(rbacEndpointPermission RBACEndpointPermission) error + func (k *RBACEndpointPermissionsCollection) Delete(endpointIdentifier string) error + func (k *RBACEndpointPermissionsCollection) Get(nameOrID string) (*RBACEndpointPermission, error) + func (k *RBACEndpointPermissionsCollection) GetAll() ([]*RBACEndpointPermission, error) + func (k *RBACEndpointPermissionsCollection) GetAllByRoleID(id string) ([]*RBACEndpointPermission, error) + func (k *RBACEndpointPermissionsCollection) Update(rbacEndpointPermission RBACEndpointPermission) error + type RBACRole struct + func (r1 *RBACRole) Console() string + func (r1 *RBACRole) Equal(r2 *RBACRole) bool + func (r1 *RBACRole) EqualWithOpts(r2 *RBACRole, ignoreID, ignoreTS, _ bool) bool + func (r1 *RBACRole) Identifier() string + type RBACRolesCollection collection + func (k *RBACRolesCollection) Add(rbacRole RBACRole) error + func (k *RBACRolesCollection) Delete(nameOrID string) error + func (k *RBACRolesCollection) Get(nameOrID string) (*RBACRole, error) + func (k *RBACRolesCollection) GetAll() ([]*RBACRole, error) + func (k *RBACRolesCollection) Update(rbacRole RBACRole) error + type Route struct + func (r1 *Route) Console() string + func (r1 *Route) Equal(r2 *Route) bool + func (r1 *Route) EqualWithOpts(r2 *Route, ignoreID, ignoreTS, ignoreForeign bool) bool + func (r1 *Route) Identifier() string + type RoutesCollection collection + func (k *RoutesCollection) Add(route Route) error + func (k *RoutesCollection) Delete(nameOrID string) error + func (k *RoutesCollection) Get(nameOrID string) (*Route, error) + func (k *RoutesCollection) GetAll() ([]*Route, error) + func (k *RoutesCollection) GetAllByServiceID(id string) ([]*Route, error) + func (k *RoutesCollection) Update(route Route) error + type SNI struct + func (s1 *SNI) Console() string + func (s1 *SNI) Equal(s2 *SNI) bool + func (s1 *SNI) EqualWithOpts(s2 *SNI, ignoreID, ignoreTS, ignoreForeign bool) bool + func (s1 *SNI) Identifier() string + type SNIsCollection collection + func (k *SNIsCollection) Add(sni SNI) error + func (k *SNIsCollection) Delete(nameOrID string) error + func (k *SNIsCollection) Get(nameOrID string) (*SNI, error) + func (k *SNIsCollection) GetAll() ([]*SNI, error) + func (k *SNIsCollection) GetAllByCertID(id string) ([]*SNI, error) + func (k *SNIsCollection) Update(sni SNI) error + type Service struct + func (s1 *Service) Console() string + func (s1 *Service) Equal(s2 *Service) bool + func (s1 *Service) EqualWithOpts(s2 *Service, ignoreID bool, ignoreTS bool) bool + func (s1 *Service) Identifier() string + type ServicePackage struct + func (s1 *ServicePackage) Console() string + func (s1 *ServicePackage) Equal(s2 *ServicePackage) bool + func (s1 *ServicePackage) EqualWithOpts(s2 *ServicePackage, ignoreID bool, _ bool) bool + func (s1 *ServicePackage) Identifier() string + type ServicePackagesCollection collection + func (k *ServicePackagesCollection) Add(servicePackage ServicePackage) error + func (k *ServicePackagesCollection) Delete(nameOrID string) error + func (k *ServicePackagesCollection) Get(nameOrID string) (*ServicePackage, error) + func (k *ServicePackagesCollection) GetAll() ([]*ServicePackage, error) + func (k *ServicePackagesCollection) Update(servicePackage ServicePackage) error + type ServiceVersion struct + func (s1 *ServiceVersion) Console() string + func (s1 *ServiceVersion) Equal(s2 *ServiceVersion) bool + func (s1 *ServiceVersion) EqualWithOpts(s2 *ServiceVersion, ignoreID, _, ignoreForeign bool) bool + func (s1 *ServiceVersion) Identifier() string + type ServiceVersionsCollection collection + func (k *ServiceVersionsCollection) Add(serviceVersion ServiceVersion) error + func (k *ServiceVersionsCollection) Delete(packageID, nameOrID string) error + func (k *ServiceVersionsCollection) Get(packageID, nameOrID string) (*ServiceVersion, error) + func (k *ServiceVersionsCollection) GetAll() ([]*ServiceVersion, error) + func (k *ServiceVersionsCollection) GetAllByServicePackageID(id string) ([]*ServiceVersion, error) + func (k *ServiceVersionsCollection) Update(serviceVersion ServiceVersion) error + type ServicesCollection collection + func (k *ServicesCollection) Add(service Service) error + func (k *ServicesCollection) Delete(nameOrID string) error + func (k *ServicesCollection) Get(nameOrID string) (*Service, error) + func (k *ServicesCollection) GetAll() ([]*Service, error) + func (k *ServicesCollection) Update(service Service) error + type Target struct + func (t1 *Target) Console() string + func (t1 *Target) Equal(t2 *Target) bool + func (t1 *Target) EqualWithOpts(t2 *Target, ignoreID, ignoreTS, ignoreForeign bool) bool + func (t1 *Target) Identifier() string + type TargetsCollection collection + func (k *TargetsCollection) Add(target Target) error + func (k *TargetsCollection) Delete(upstreamID, targetOrID string) error + func (k *TargetsCollection) Get(upstreamID, targetOrID string) (*Target, error) + func (k *TargetsCollection) GetAll() ([]*Target, error) + func (k *TargetsCollection) GetAllByUpstreamID(id string) ([]*Target, error) + func (k *TargetsCollection) Update(target Target) error + type Upstream struct + func (u1 *Upstream) Console() string + func (u1 *Upstream) Equal(u2 *Upstream) bool + func (u1 *Upstream) EqualWithOpts(u2 *Upstream, ignoreID bool, ignoreTS bool) bool + func (u1 *Upstream) Identifier() string + type UpstreamsCollection collection + func (k *UpstreamsCollection) Add(upstream Upstream) error + func (k *UpstreamsCollection) Delete(nameOrID string) error + func (k *UpstreamsCollection) Get(nameOrID string) (*Upstream, error) + func (k *UpstreamsCollection) GetAll() ([]*Upstream, error) + func (k *UpstreamsCollection) Update(upstream Upstream) error + type Vault struct + func (v1 *Vault) Console() string + func (v1 *Vault) Equal(v2 *Vault) bool + func (v1 *Vault) EqualWithOpts(v2 *Vault, ignoreID, ignoreTS bool) bool + func (v1 *Vault) Identifier() string + type VaultsCollection collection + func (k *VaultsCollection) Add(vault Vault) error + func (k *VaultsCollection) Delete(prefixOrID string) error + func (k *VaultsCollection) Get(prefixOrID string) (*Vault, error) + func (k *VaultsCollection) GetAll() ([]*Vault, error) + func (k *VaultsCollection) Update(vault Vault) error