activities

Documentation

Index

• type Activities
  • func (a *Activities) DeploymentDeleteActivity(ctx context.Context, req *model.DeployerDeleteRequest) (model.ResponsePayload, error)
  • func (a *Activities) DeploymentInstallActivity(ctx context.Context, req *model.ApplicationDeployRequest) (model.ResponsePayload, error)
• type Configuration
• type PluginActivities
  • func NewPluginActivities() (*PluginActivities, error)
  • func (p *PluginActivities) PluginDeployPostActionActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)
  • func (p *PluginActivities) PluginDeployPreActionMTLSActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)
  • func (p *PluginActivities) PluginDeployPreActionPostgresStoreActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)
  • func (p *PluginActivities) PluginDeployPreActionVaultStoreActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)
  • func (p *PluginActivities) PluginDeployUpdateStatusActivity(ctx context.Context, pluginName, status string) (model.ResponsePayload, error)
  • func (p *PluginActivities) PluginUndeployActivity(ctx context.Context, req *model.DeployerDeleteRequest) (*model.ResponsePayload, error)
  • func (p *PluginActivities) PluginUndeployPostActionActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)
  • func (p *PluginActivities) PluginUndeployPreActionMTLSActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)
  • func (p *PluginActivities) PluginUndeployPreActionPostgresStoreActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)
  • func (p *PluginActivities) PluginUndeployPreActionVaultStoreActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)

Types

type Activities

type Activities struct {
}

func (*Activities) DeploymentDeleteActivity

func (a *Activities) DeploymentDeleteActivity(ctx context.Context, req *model.DeployerDeleteRequest) (model.ResponsePayload, error)

func (*Activities) DeploymentInstallActivity

func (a *Activities) DeploymentInstallActivity(ctx context.Context, req *model.ApplicationDeployRequest) (model.ResponsePayload, error)

type Configuration

type Configuration struct {
	AgentAddress string `envconfig:"AGENT_ADDRESSES" required:"true"`
}

type PluginActivities

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

func NewPluginActivities

func NewPluginActivities() (*PluginActivities, error)

func (*PluginActivities) PluginDeployPostActionActivity

func (p *PluginActivities) PluginDeployPostActionActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)

PluginDeployPostActionActivity... Updates the plugin deployment as "installed"

func (*PluginActivities) PluginDeployPreActionMTLSActivity

func (p *PluginActivities) PluginDeployPreActionMTLSActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)

func (*PluginActivities) PluginDeployPreActionPostgresStoreActivity

func (p *PluginActivities) PluginDeployPreActionPostgresStoreActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)

func (*PluginActivities) PluginDeployPreActionVaultStoreActivity

func (p *PluginActivities) PluginDeployPreActionVaultStoreActivity(
	ctx context.Context,
	req *clusterpluginspb.Plugin,
) (*model.ResponsePayload, error)

func (*PluginActivities) PluginDeployUpdateStatusActivity

func (p *PluginActivities) PluginDeployUpdateStatusActivity(ctx context.Context, pluginName, status string) (model.ResponsePayload, error)

func (*PluginActivities) PluginUndeployActivity

func (p *PluginActivities) PluginUndeployActivity(ctx context.Context, req *model.DeployerDeleteRequest) (*model.ResponsePayload, error)

func (*PluginActivities) PluginUndeployPostActionActivity

func (p *PluginActivities) PluginUndeployPostActionActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)

PluginDeployPostActionActivity... Updates the plugin deployment as "installed"

func (*PluginActivities) PluginUndeployPreActionMTLSActivity

func (p *PluginActivities) PluginUndeployPreActionMTLSActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)

func (*PluginActivities) PluginUndeployPreActionPostgresStoreActivity

func (p *PluginActivities) PluginUndeployPreActionPostgresStoreActivity(ctx context.Context, req *clusterpluginspb.Plugin) (*model.ResponsePayload, error)

func (*PluginActivities) PluginUndeployPreActionVaultStoreActivity

func (p *PluginActivities) PluginUndeployPreActionVaultStoreActivity(
	ctx context.Context,
	req *clusterpluginspb.Plugin,
) (*model.ResponsePayload, error)