middleware

Documentation

Index

• Constants
• func CheckPrecondidtionsOfApiProduct(apiProduct *connector.APIProduct) error
• func CheckWebhookEligible(apiProduct *connector.APIProduct) bool
• func MapToAxTagSolaceApiProduct(apiProductDisplayName string) string
• func MapToExternalApiId(apiProductName string) string
• func MapToNormalizedAxApiName(apiProductId, apiProductDisplayName string) string
• func MapToNormalizedAxAssetName(apiProductDisplayName, apiProductId string) string
• type AxwayDeployment
• type ConnectorMiddleware
  • func NewMiddleware(connectorConfig *config.ConnectorConfig) (*ConnectorMiddleware, error)
  • func (a *ConnectorMiddleware) DiscoverAPIs() error
  • func (a *ConnectorMiddleware) LogTraceLevelFine(logMessage string)
  • func (a *ConnectorMiddleware) LogTraceLevelFiner(logMessage string)
  • func (a *ConnectorMiddleware) LogTraceLevelFinest(logMessage string)
  • func (a *ConnectorMiddleware) PingConnector() (string, error)
  • func (a *ConnectorMiddleware) PrepareConnectorForAgent() error
  • func (a *ConnectorMiddleware) ProvisionApis() error
  • func (a *ConnectorMiddleware) PublishSchemas() error
• type ConnectorProvisioner
  • func NewConnectorProvisioner(connectorConfig *config.ConnectorConfig) (*ConnectorProvisioner, error)
  • func (c *ConnectorProvisioner) AccessRequestDeprovision(request provisioning.AccessRequest) provisioning.RequestStatus
  • func (c *ConnectorProvisioner) AccessRequestProvision(request provisioning.AccessRequest) (provisioning.RequestStatus, provisioning.AccessData)
  • func (c *ConnectorProvisioner) ApplicationRequestDeprovision(request provisioning.ApplicationRequest) provisioning.RequestStatus
  • func (c *ConnectorProvisioner) ApplicationRequestProvision(request provisioning.ApplicationRequest) provisioning.RequestStatus
  • func (c *ConnectorProvisioner) CredentialDeprovision(request provisioning.CredentialRequest) provisioning.RequestStatus
  • func (c *ConnectorProvisioner) CredentialProvision(request provisioning.CredentialRequest) (provisioning.RequestStatus, provisioning.Credential)
  • func (a *ConnectorProvisioner) LogTraceLevelFine(format string, args ...interface{})
  • func (a *ConnectorProvisioner) LogTraceLevelFiner(format string, args ...interface{})
  • func (a *ConnectorProvisioner) LogTraceLevelFinest(format string, args ...interface{})
• type DiscoverAysyncApisJob
  • func (j *DiscoverAysyncApisJob) Execute() error
  • func (j *DiscoverAysyncApisJob) Ready() bool
  • func (j *DiscoverAysyncApisJob) Status() error

Constants

const ATTRIBUTE_AP_BUSINESS_GROUP_OWNING_ID_ = "_AP_BUSINESS_GROUP_OWNING_ID_"

const ATTRIBUTE_AX_SERVICEREVISION_CON_APIPRODUCT_DISPLAYNAME = "_solace__apiproduct_displayname"

const ATTRIBUTE_AX_SERVICEREVISION_CON_APIPRODUCT_NAME = "_solace__apiproduct_name"

const ATTRIBUTE_AX_SERVICEREVISION_CON_APIPRODUCT_STAGE = "_solace__apiproduct_stage"

const ATTRIBUTE_AX_SERVICEREVISION_CON_APIPRODUCT_VERSION = "_solace__apiproduct_version"

const ATTRIBUTE_AX_SERVICEREVISION_CON_API_NAME = "_solace__api_name"

const ATTRIBUTE_AX_SERVICEREVISION_CON_API_VERSION = "_solace__api_version"

const ATTRIBUTE_CON_META_APIPRODUCT_AXDEPLOYMENT = "_AX_APIPRODUCT_AXDEPLOYMENT"

const TAG_AX_SOLACE_ASYNCAPI = "solace-asyncapi"

const TAG_AX_SOLACE_DEPRECATED = "solace-stage-deprecated"

const TAG_AX_SOLACE_RELEASED = "solace-stage-released"

const TAG_AX_SOLACE_RETIRED = "solace-stage-retired"

Functions

func CheckPrecondidtionsOfApiProduct

func CheckPrecondidtionsOfApiProduct(apiProduct *connector.APIProduct) error

func CheckWebhookEligible

func CheckWebhookEligible(apiProduct *connector.APIProduct) bool

func MapToAxTagSolaceApiProduct

func MapToAxTagSolaceApiProduct(apiProductDisplayName string) string

func MapToExternalApiId

func MapToExternalApiId(apiProductName string) string

MapToApiId - creates Axway Serviceid `{apiProductName}`

func MapToNormalizedAxApiName

func MapToNormalizedAxApiName(apiProductId, apiProductDisplayName string) string

MapToApiId - creates Axway ApiName `{apiProductDisplayName}-{apoiProductId}` and replaces all underscores with dashes

func MapToNormalizedAxAssetName

func MapToNormalizedAxAssetName(apiProductDisplayName, apiProductId string) string

Types

type AxwayDeployment

type AxwayDeployment struct {
	ConProductName            string `json:"conProduct"`
	ConDeployedProductVersion string `json:"conDeployedProductVersion"`
	AxExternalApiId           string `json:"axExternalApiId"`
	AxServiceName             string `json:"axServiceName"`
	AxServiceTitle            string `json:"axServiceTitle"`
}

type ConnectorMiddleware

type ConnectorMiddleware struct {
	AdminConnector  *connector.Access
	OrgConnector    *connector.Access
	DefaultOrgName  string
	ConnectorConfig connector.ConnectorConfig
}

ConnectorMiddleware - Provides entry point to discover and publish AsyncAPIs via Solace Connector

func NewMiddleware

func NewMiddleware(connectorConfig *config.ConnectorConfig) (*ConnectorMiddleware, error)

NewMiddleware - Creates a new Middleware

func (*ConnectorMiddleware) DiscoverAPIs

func (a *ConnectorMiddleware) DiscoverAPIs() error

func (*ConnectorMiddleware) LogTraceLevelFine

func (a *ConnectorMiddleware) LogTraceLevelFine(logMessage string)

func (*ConnectorMiddleware) LogTraceLevelFiner

func (a *ConnectorMiddleware) LogTraceLevelFiner(logMessage string)

func (*ConnectorMiddleware) LogTraceLevelFinest

func (a *ConnectorMiddleware) LogTraceLevelFinest(logMessage string)

func (*ConnectorMiddleware) PingConnector

func (a *ConnectorMiddleware) PingConnector() (string, error)

PingConnector - Invokes About of the connector

func (*ConnectorMiddleware) PrepareConnectorForAgent

func (a *ConnectorMiddleware) PrepareConnectorForAgent() error

func (*ConnectorMiddleware) ProvisionApis

func (a *ConnectorMiddleware) ProvisionApis() error

DiscoverAPIs - Start API discovery, synchronization and publishing of AsyncAPIs

func (*ConnectorMiddleware) PublishSchemas

func (a *ConnectorMiddleware) PublishSchemas() error

type ConnectorProvisioner

type ConnectorProvisioner struct {
	OrgConnector         *connector.Access
	DefaultOrgName       string
	DefaultTeamId        string
	DefaultTeamName      string
	AgentBusinessGroupId string
	ConnectorConfig      *config.ConnectorConfig
}

func NewConnectorProvisioner

func NewConnectorProvisioner(connectorConfig *config.ConnectorConfig) (*ConnectorProvisioner, error)

func (*ConnectorProvisioner) AccessRequestDeprovision

func (c *ConnectorProvisioner) AccessRequestDeprovision(request provisioning.AccessRequest) provisioning.RequestStatus

func (*ConnectorProvisioner) AccessRequestProvision

func (c *ConnectorProvisioner) AccessRequestProvision(request provisioning.AccessRequest) (provisioning.RequestStatus, provisioning.AccessData)

func (*ConnectorProvisioner) ApplicationRequestDeprovision

func (c *ConnectorProvisioner) ApplicationRequestDeprovision(request provisioning.ApplicationRequest) provisioning.RequestStatus

func (*ConnectorProvisioner) ApplicationRequestProvision

func (c *ConnectorProvisioner) ApplicationRequestProvision(request provisioning.ApplicationRequest) provisioning.RequestStatus

func (*ConnectorProvisioner) CredentialDeprovision

func (c *ConnectorProvisioner) CredentialDeprovision(request provisioning.CredentialRequest) provisioning.RequestStatus

func (*ConnectorProvisioner) CredentialProvision

func (c *ConnectorProvisioner) CredentialProvision(request provisioning.CredentialRequest) (provisioning.RequestStatus, provisioning.Credential)

func (*ConnectorProvisioner) LogTraceLevelFine

func (a *ConnectorProvisioner) LogTraceLevelFine(format string, args ...interface{})

func (*ConnectorProvisioner) LogTraceLevelFiner

func (a *ConnectorProvisioner) LogTraceLevelFiner(format string, args ...interface{})

func (*ConnectorProvisioner) LogTraceLevelFinest

func (a *ConnectorProvisioner) LogTraceLevelFinest(format string, args ...interface{})

type DiscoverAysyncApisJob

type DiscoverAysyncApisJob struct {
	jobs.Job
	Middleware *ConnectorMiddleware
}

func (*DiscoverAysyncApisJob) Execute

func (j *DiscoverAysyncApisJob) Execute() error

func (*DiscoverAysyncApisJob) Ready

func (j *DiscoverAysyncApisJob) Ready() bool

func (*DiscoverAysyncApisJob) Status

func (j *DiscoverAysyncApisJob) Status() error