Documentation
¶
Index ¶
- Variables
- func NewKeptnEndpointProviderFromEnv() *configurableKeptnEndpointProvider
- func NewKeptnIntegrationIdRetriever(provider KeptnControlPlaneEndpointProvider) *keptnIntegrationIdRetriever
- func NewWebhookSubscriptionHandler(retriever integrationIdRetriever) *webhookSubscriptionHandler
- type KeptnAPIExecutor
- type KeptnConfigurationServiceEndpointProvider
- type KeptnControlPlaneEndpointProvider
- type KeptnEndpointProvider
- type KeptnResourcePusher
- type KeptnSecretsEndpointProvider
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrEndpointNotDefined = errors.New("endpoint not defined")
View Source
var ErrTaskFailed = errors.New("task failed")
Functions ¶
func NewKeptnEndpointProviderFromEnv ¶
func NewKeptnEndpointProviderFromEnv() *configurableKeptnEndpointProvider
func NewKeptnIntegrationIdRetriever ¶
func NewKeptnIntegrationIdRetriever(provider KeptnControlPlaneEndpointProvider) *keptnIntegrationIdRetriever
func NewWebhookSubscriptionHandler ¶
func NewWebhookSubscriptionHandler(retriever integrationIdRetriever) *webhookSubscriptionHandler
Types ¶
type KeptnAPIExecutor ¶
type KeptnAPIExecutor struct {
// contains filtered or unexported fields
}
func NewKeptnExecutor ¶
func NewKeptnExecutor(kep KeptnEndpointProvider) *KeptnAPIExecutor
func (*KeptnAPIExecutor) ActionSupported ¶
func (kae *KeptnAPIExecutor) ActionSupported(actionName string) bool
func (*KeptnAPIExecutor) ExecuteAPI ¶
func (kae *KeptnAPIExecutor) ExecuteAPI(ate model.APITaskExecution) (any, error)
func (*KeptnAPIExecutor) PushResource ¶
func (kae *KeptnAPIExecutor) PushResource(rp model.ResourcePush) (any, error)
type KeptnConfigurationServiceEndpointProvider ¶
type KeptnConfigurationServiceEndpointProvider interface {
GetConfigurationServiceEndpoint() string
}
type KeptnControlPlaneEndpointProvider ¶
type KeptnControlPlaneEndpointProvider interface {
GetControlPlaneEndpoint() string
}
type KeptnEndpointProvider ¶
type KeptnEndpointProvider interface {
KeptnControlPlaneEndpointProvider
KeptnConfigurationServiceEndpointProvider
KeptnSecretsEndpointProvider
}
type KeptnResourcePusher ¶
type KeptnResourcePusher struct {
// contains filtered or unexported fields
}
func (*KeptnResourcePusher) PushToService ¶
func (p *KeptnResourcePusher) PushToService( project string, stage string, service string, content io.ReadCloser, resourceURI string, ) (any, error)
func (*KeptnResourcePusher) PushToStage ¶
func (p *KeptnResourcePusher) PushToStage( project string, stage string, content io.ReadCloser, resourceURI string, ) (any, error)
type KeptnSecretsEndpointProvider ¶
type KeptnSecretsEndpointProvider interface {
GetSecretsServiceEndpoint() string
}
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.