wfgc

Documentation

Index

• Constants
• type GarbageCollector
  • func New(lg Logger, registries []string, names *shorteruuid.Names, ...) *GarbageCollector
  • func (gc *GarbageCollector) Gc(ctx context.Context) error
• type Logger

Constants

const (
	ConfigDuRootMaxActiveDays = 1
	ConfigDuRootMaxActive     = ConfigDuRootMaxActiveDays * 24 * time.Hour

	ConfigDuRootDeleteAfterDays = 5
	ConfigDuRootDeleteAfter     = ConfigDuRootDeleteAfterDays * 24 * time.Hour

	ConfigPingRegistryMaxActiveDays = 1
	ConfigPingRegistryMaxActive     = ConfigPingRegistryMaxActiveDays * 24 * time.Hour

	ConfigPingRegistryDeleteAfterDays = 5
	ConfigPingRegistryDeleteAfter     = ConfigPingRegistryDeleteAfterDays * 24 * time.Hour

	ConfigSplitRootMaxActiveDays = 5
	ConfigSplitRootMaxActive     = ConfigSplitRootMaxActiveDays * 24 * time.Hour

	ConfigSplitRootDeleteAfterDays = 30
	ConfigSplitRootDeleteAfter     = ConfigSplitRootDeleteAfterDays * 24 * time.Hour
)

const (
	NsFsoRegistryEphemeralWorkflows = "fsoregephwfl"
)

Types

type GarbageCollector

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

func New

func New(
	lg Logger,
	registries []string,
	names *shorteruuid.Names,
	ephWorkflowsJ *events.Journal,
	workflowIndexes *wfindexes.Indexes,
	duRootWorkflows *durootwf.Workflows,
	pingRegistryWorkflows *pingregistrywf.Workflows,
	splitRootWorkflows *splitrootwf.Workflows,
) *GarbageCollector

func (*GarbageCollector) Gc

func (gc *GarbageCollector) Gc(ctx context.Context) error

type Logger

type Logger interface {
	Infow(msg string, kv ...interface{})
	Warnw(msg string, kv ...interface{})
}