middleware

package
v0.0.21 Latest Latest
Warning

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

 Go to latest Published: May 10, 2022 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AxwayEndpoint 

type AxwayEndpoint struct {
	Host     string
	Port     int32
	Protocol string
}

AxwayEndpoint represents an Axway Endpoint

type AxwaySubscription 

type AxwaySubscription interface {
	LogText() string
	GetServiceAttributes() map[string]string
	GetServiceResourceMetaAttributes() map[string]string
	GetSolaceAsyncAPIAppInternalID() string
	GetSolaceAsyncAPIHint() string
	GetCatalogItemName() string
	SetSolaceAsyncAPIAppInternalID(id string)
	SetSolaceAsyncAPIHint(hint string)
	SetSubscriptionCredentials(credentials *connector.SolaceCredentialsDto)
	GetSubscriptionCredentials() *connector.SolaceCredentialsDto
	GetSubscriberEmailAddress() string
	GetSubscriberUserName() string
	GetRevisionName() string
	GetRevisionId() string
	IsEnvironmentDefined() bool
	GetEnvironmentName() string
	IsExternalAPIIDDefined() bool
	IsExternalAPINameDefined() bool
	GetExternalAPIID() string
	GetExternalAPIName() string
	GetAPISpec() string
	GetSubscriptionName() string
	GetSubscriptionAPIServiceName() string
	GetSubscriptionID() string
	GetSubscriptionOwningTeamID() string
	GetSubscriptionCatalogItemID() string
	GetSubscriptionPropertyValue(key string) string
	GetServiceInstanceMetadataScopeName() string
	GetServiceInstanceSpecEndpoints() []AxwayEndpoint
}

AxwaySubscription represents Axway Subscription content

type SubscriptionContainer 

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

SubscriptionContainer - holds additional information for a subscription

func (*SubscriptionContainer) GetAPISpec 

func (c *SubscriptionContainer) GetAPISpec() string

GetAPISpec - Facade ti get API Spec (AsyncAPI spec)

func (*SubscriptionContainer) GetCatalogItemName 

func (c *SubscriptionContainer) GetCatalogItemName() string

GetCatalogItemName - getter

func (*SubscriptionContainer) GetEnvironmentName 

func (c *SubscriptionContainer) GetEnvironmentName() string

GetEnvironmentName - Facade to get environment name (Service Instance Scope Name)

func (*SubscriptionContainer) GetExternalAPIID 

func (c *SubscriptionContainer) GetExternalAPIID() string

GetExternalAPIID - Facade to get External API ID

func (*SubscriptionContainer) GetExternalAPIName 

func (c *SubscriptionContainer) GetExternalAPIName() string

GetExternalAPIName - Facade to get External API Name

func (*SubscriptionContainer) GetRevisionId added in v0.0.16 

func (c *SubscriptionContainer) GetRevisionId() string

GetRevisionId - Facade to retrieve RevisionId (metadata.id)

func (*SubscriptionContainer) GetRevisionName 

func (c *SubscriptionContainer) GetRevisionName() string

GetRevisionName - Facade to retrieve RevisionName

func (*SubscriptionContainer) GetServiceAttributes 

func (c *SubscriptionContainer) GetServiceAttributes() map[string]string

GetServiceAttributes getter

func (*SubscriptionContainer) GetServiceInstanceMetadataScopeName 

func (c *SubscriptionContainer) GetServiceInstanceMetadataScopeName() string

GetServiceInstanceMetadataScopeName getter

func (*SubscriptionContainer) GetServiceInstanceSpecEndpoints 

func (c *SubscriptionContainer) GetServiceInstanceSpecEndpoints() []AxwayEndpoint

GetServiceInstanceSpecEndpoints getter

func (*SubscriptionContainer) GetServiceResourceMetaAttributes added in v0.0.20 

func (c *SubscriptionContainer) GetServiceResourceMetaAttributes() map[string]string

GetServiceResourceMetaAttributes getter

func (*SubscriptionContainer) GetSolaceAsyncAPIAppInternalID 

func (c *SubscriptionContainer) GetSolaceAsyncAPIAppInternalID() string

GetSolaceAsyncAPIAppInternalID - getter

func (*SubscriptionContainer) GetSolaceAsyncAPIHint added in v0.0.20 

func (c *SubscriptionContainer) GetSolaceAsyncAPIHint() string

GetSolaceAsyncAPIHint - getter

func (*SubscriptionContainer) GetSubscriberEmailAddress 

func (c *SubscriptionContainer) GetSubscriberEmailAddress() string

GetSubscriberEmailAddress - Returns Email

func (*SubscriptionContainer) GetSubscriberUserName 

func (c *SubscriptionContainer) GetSubscriberUserName() string

GetSubscriberUserName - getter

func (*SubscriptionContainer) GetSubscriptionAPIServiceName 

func (c *SubscriptionContainer) GetSubscriptionAPIServiceName() string

GetSubscriptionAPIServiceName getter

func (*SubscriptionContainer) GetSubscriptionCatalogItemID 

func (c *SubscriptionContainer) GetSubscriptionCatalogItemID() string

GetSubscriptionCatalogItemID getter

func (*SubscriptionContainer) GetSubscriptionCredentials 

func (c *SubscriptionContainer) GetSubscriptionCredentials() *connector.SolaceCredentialsDto

GetSubscriptionCredentials - getter

func (*SubscriptionContainer) GetSubscriptionID 

func (c *SubscriptionContainer) GetSubscriptionID() string

GetSubscriptionID getter

func (*SubscriptionContainer) GetSubscriptionName 

func (c *SubscriptionContainer) GetSubscriptionName() string

GetSubscriptionName getter

func (*SubscriptionContainer) GetSubscriptionOwningTeamID 

func (c *SubscriptionContainer) GetSubscriptionOwningTeamID() string

GetSubscriptionOwningTeamID getter

func (*SubscriptionContainer) GetSubscriptionPropertyValue 

func (c *SubscriptionContainer) GetSubscriptionPropertyValue(key string) string

GetSubscriptionPropertyValue getter

func (*SubscriptionContainer) IsEnvironmentDefined 

func (c *SubscriptionContainer) IsEnvironmentDefined() bool

IsEnvironmentDefined - Facade to check if environment is set in Service Instance

func (*SubscriptionContainer) IsExternalAPIIDDefined 

func (c *SubscriptionContainer) IsExternalAPIIDDefined() bool

IsExternalAPIIDDefined - Facade to check if External API ID is set

func (*SubscriptionContainer) IsExternalAPINameDefined 

func (c *SubscriptionContainer) IsExternalAPINameDefined() bool

IsExternalAPINameDefined - Facade to check if External API Name is set

func (*SubscriptionContainer) LogText 

func (c *SubscriptionContainer) LogText() string

LogText - Extracts Logging Details

func (*SubscriptionContainer) SetSolaceAsyncAPIAppInternalID 

func (c *SubscriptionContainer) SetSolaceAsyncAPIAppInternalID(id string)

SetSolaceAsyncAPIAppInternalID - setter

func (*SubscriptionContainer) SetSolaceAsyncAPIHint added in v0.0.20 

func (c *SubscriptionContainer) SetSolaceAsyncAPIHint(hint string)

SetSolaceAsyncAPIHint - setter

func (*SubscriptionContainer) SetSubscriptionCredentials 

func (c *SubscriptionContainer) SetSubscriptionCredentials(credentials *connector.SolaceCredentialsDto)

SetSubscriptionCredentials - setter

type SubscriptionMiddleware 

type SubscriptionMiddleware struct {
	AxSub AxwaySubscription
	// contains filtered or unexported fields
}

SubscriptionMiddleware holds AxwaySubscription and exposes functionality

func NewSubscriptionMiddleware 

func NewSubscriptionMiddleware(subscription apic.Subscription, connectorOrg string) (*SubscriptionMiddleware, error)

NewSubscriptionMiddleware - creates new SubscriptionContainer

func (*SubscriptionMiddleware) GetAppApis 

func (sm *SubscriptionMiddleware) GetAppApis() ([]*map[string]interface{}, error)

GetAppApis - Facade to retrieve all AsyncApi specs of an app

func (*SubscriptionMiddleware) GetDummySuccessOrFault 

func (sm *SubscriptionMiddleware) GetDummySuccessOrFault(success bool) (bool, error)

GetDummySuccessOrFault -for development only

func (*SubscriptionMiddleware) GetOrg added in v0.0.19 

func (c *SubscriptionMiddleware) GetOrg() string

func (*SubscriptionMiddleware) GetTeamApp 

func (sm *SubscriptionMiddleware) GetTeamApp() (*connector.AppResponse, error)

GetTeamApp - Facade to retrieve App AxSub

func (*SubscriptionMiddleware) GetTeamAppJson added in v0.0.20 

func (sm *SubscriptionMiddleware) GetTeamAppJson() (*connector.SolaceCredentialsDto, map[string]interface{}, error)

GetTeamAppJson - Facade to retrieve App AxSub generic JSON

func (*SubscriptionMiddleware) IsAPIProductAvailable 

func (sm *SubscriptionMiddleware) IsAPIProductAvailable() (bool, error)

IsAPIProductAvailable - Facade to check via Connector if API-Product exists

func (*SubscriptionMiddleware) IsConnectorAPIAvailable 

func (sm *SubscriptionMiddleware) IsConnectorAPIAvailable() (bool, error)

IsConnectorAPIAvailable - Facade to check via Connector if API already exists

func (*SubscriptionMiddleware) IsConnectorTeamAvailable 

func (sm *SubscriptionMiddleware) IsConnectorTeamAvailable() (bool, error)

IsConnectorTeamAvailable - Facade to check via Connector if Team exists

func (*SubscriptionMiddleware) IsOrgAvailable added in v0.0.19 

func (sm *SubscriptionMiddleware) IsOrgAvailable() (bool, error)

IsOrgAvailable - Facade to check in Connector if an organization exists that has the same name AxSub Axway Environment of the subscription

func (*SubscriptionMiddleware) IsTeamAppAvailable 

func (sm *SubscriptionMiddleware) IsTeamAppAvailable() (bool, error)

IsTeamAppAvailable - Facade to check via Connector if Team Application exists

func (*SubscriptionMiddleware) NotifyFailure 

func (sm *SubscriptionMiddleware) NotifyFailure(trigger string, message string, correlationID string) (bool, error)

NotifyFailure publishes failure notification

func (*SubscriptionMiddleware) NotifySuccess 

func (sm *SubscriptionMiddleware) NotifySuccess(trigger string, message string, correlationID string) (bool, error)

NotifySuccess notifies success

func (*SubscriptionMiddleware) ProcessSubscription 

func (sm *SubscriptionMiddleware) ProcessSubscription() error

ProcessSubscription - Orchestrates entire subscription steps

func (*SubscriptionMiddleware) ProcessUnsubscribeSubscription 

func (sm *SubscriptionMiddleware) ProcessUnsubscribeSubscription() error

ProcessUnsubscribeSubscription - Orchestrates entire unsubscription steps

func (*SubscriptionMiddleware) PublishAPI 

func (sm *SubscriptionMiddleware) PublishAPI() error

PublishAPI - Facade to publish via Connector an API

func (*SubscriptionMiddleware) PublishAPIProduct 

func (sm *SubscriptionMiddleware) PublishAPIProduct() error

PublishAPIProduct - Facade to publish via Connector an API Product (idempotent)

func (*SubscriptionMiddleware) PublishTeam 

func (sm *SubscriptionMiddleware) PublishTeam() error

PublishTeam - Facade to publish via Connector a Team

func (*SubscriptionMiddleware) PublishTeamApp 

func (sm *SubscriptionMiddleware) PublishTeamApp() (*connector.Credentials, error)

PublishTeamApp - Facade to publish via Connector a Team Application

func (*SubscriptionMiddleware) RemoveAPI 

func (sm *SubscriptionMiddleware) RemoveAPI(ignoreConflict bool) error

RemoveAPI - Facade to remove via connector an API

func (*SubscriptionMiddleware) RemoveAPIProduct 

func (sm *SubscriptionMiddleware) RemoveAPIProduct(ignoreConflict bool) error

RemoveAPIProduct - Facade to remove via Connector an API Product

func (*SubscriptionMiddleware) RemoveTeamApp 

func (sm *SubscriptionMiddleware) RemoveTeamApp() error

RemoveTeamApp - Facade to remove via Connector a Team Application

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.