graph

Documentation

Index

• func CollectInDependencyOrder[T any](ctx context.Context, project *types.Project, ...) (map[string]T, error)
• func InDependencyOrder(ctx context.Context, project *types.Project, fn VisitorFn[types.ServiceConfig], ...) error
• func InReverseOrder(o *Options)
• func WithMaxConcurrency(max int) func(*Options)
• func WithRootNodesAndDown(nodes []string) func(*Options)
• type CollectorFn
• type Options
• type VisitorFn

Functions

func CollectInDependencyOrder

func CollectInDependencyOrder[T any](ctx context.Context, project *types.Project, fn CollectorFn[types.ServiceConfig, T], options ...func(*Options)) (map[string]T, error)

CollectInDependencyOrder walk the service graph an invoke CollectorFn in respect to dependency order, then return result for each call

func InDependencyOrder

func InDependencyOrder(ctx context.Context, project *types.Project, fn VisitorFn[types.ServiceConfig], options ...func(*Options)) error

InDependencyOrder walk the service graph an invoke VisitorFn in respect to dependency order

func InReverseOrder

func InReverseOrder(o *Options)

InReverseOrder configure traversal to walk the graph in reverse dependency order

func WithMaxConcurrency

func WithMaxConcurrency(max int) func(*Options)

WithMaxConcurrency configure traversal to limit concurrency walking graph nodes

func WithRootNodesAndDown

func WithRootNodesAndDown(nodes []string) func(*Options)

WithRootNodesAndDown creates a graphTraversal to start from selected nodes

Types

type CollectorFn

type CollectorFn[S any, T any] func(context.Context, string, S) (T, error)

CollectorFn executes on each graph vertex based on visit order and return associated value

type Options

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

type VisitorFn

type VisitorFn[S any] func(context.Context, string, S) error

VisitorFn executes on each graph nodes based on visit order