update

Documentation

Index

• func GetFanoutUpdate(ctx context.Context, fn func(context.Context) ([]context.Context, error), ...) (chan<- context.Context, <-chan context.Context)
• func GetPipeUpdate(ctx context.Context, fn func(context.Context) (context.Context, error), ...) (chan<- context.Context, <-chan context.Context)
• func Update(ctx context.Context) (context.Context, error)
• type UpdateGetContexter

Functions

func GetFanoutUpdate

func GetFanoutUpdate(
	ctx context.Context,
	fn func(context.Context) ([]context.Context, error),
	fnErr func(context.Context, error) bool,
) (
	chan<- context.Context,
	<-chan context.Context,
)

GetFanoutUpdate returns new input(chan<- ContextContext)/output(<-chan ContextContext) channels that embedded the given 'func(ContextContext) ContextContext'.

func GetPipeUpdate

func GetPipeUpdate(
	ctx context.Context,
	fn func(context.Context) (context.Context, error),
	fnErr func(context.Context, error) bool,
) (
	chan<- context.Context,
	<-chan context.Context,
)

GetPipeUpdate returns new input(chan<- ContextContext)/output(<-chan ContextContext) channels that embedded the given 'func(ContextContext) ContextContext'.

func Update

func Update(ctx context.Context) (context.Context, error)

Update ...

Types

type UpdateGetContexter

type UpdateGetContexter interface {
	GetContext() context.Context
}