cleanup

Documentation

Index

• func FindUnlinkedPid(config configuration.Config, deploymentAgeBuffer time.Duration) (unlinkedPid map[string][]string, err error)
• func FindUnlinkedVid(config configuration.Config) (unlinkedVid []string, err error)
• func Get(url string, result interface{}) (err error)
• func RemovePid(ids map[string][]string) error
• func RemoveVid(config configuration.Config, ids []string) error
• func RemoveVidWithCqrs(cqrs kafka.Interface, config configuration.Config, ids []string) error
• type Deployment
• type DeploymentDeleteCommand
• type Deployments

Functions

func FindUnlinkedPid

func FindUnlinkedPid(config configuration.Config, deploymentAgeBuffer time.Duration) (unlinkedPid map[string][]string, err error)

func FindUnlinkedVid

func FindUnlinkedVid(config configuration.Config) (unlinkedVid []string, err error)

func Get

func Get(url string, result interface{}) (err error)

func RemovePid

func RemovePid(ids map[string][]string) error

func RemoveVid

func RemoveVid(config configuration.Config, ids []string) error

func RemoveVidWithCqrs

func RemoveVidWithCqrs(cqrs kafka.Interface, config configuration.Config, ids []string) error

Types

type Deployment

type Deployment struct {
	Id             string `json:"id"`
	Name           string `json:"name"`
	Source         string `json:"source"`
	DeploymentTime string `json:"deploymentTime"`
	TenantId       string `json:"tenantId"`
}

type DeploymentDeleteCommand

type DeploymentDeleteCommand struct {
	Command string `json:"command"`
	Id      string `json:"id"`
	Owner   string `json:"owner"`
	Source  string `json:"source,omitempty"`
}

type Deployments

type Deployments = []Deployment