reducerflow

package
v1.38.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 14, 2026 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Hostname = reducerflowapi.Hostname
	Version  = 1
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Intermediate 

type Intermediate struct {
	*connector.Connector
	ToDo
}

Intermediate extends and customizes the generic base connector.

func NewIntermediate 

func NewIntermediate(impl ToDo) *Intermediate

NewIntermediate creates a new instance of the intermediate.

type Mock 

type Mock struct {
	*Intermediate
	// contains filtered or unexported fields
}

Mock is a mockable version of the microservice, allowing functions, event sinks and web handlers to be mocked.

func NewMock 

func NewMock() *Mock

NewMock creates a new mockable version of the microservice.

func (*Mock) MockReducer 

func (svc *Mock) MockReducer(handler func(ctx context.Context, flow *workflow.Flow) (finalSum int, finalList []string, finalSet []string, err error)) *Mock

MockReducer sets up a mock handler for the Reducer workflow. The handler receives typed inputs from the workflow's state and returns typed outputs. A nil handler clears the mock.

func (*Mock) MockTaskA 

func (svc *Mock) MockTaskA(handler func(ctx context.Context, flow *workflow.Flow) (started bool, err error)) *Mock

MockTaskA sets up a mock handler for TaskA.

func (*Mock) MockTaskB 

func (svc *Mock) MockTaskB(handler func(ctx context.Context, flow *workflow.Flow) (totalOut int, tagsOut []string, seenOut []string, err error)) *Mock

MockTaskB sets up a mock handler for TaskB.

func (*Mock) MockTaskC 

func (svc *Mock) MockTaskC(handler func(ctx context.Context, flow *workflow.Flow) (totalOut int, tagsOut []string, seenOut []string, err error)) *Mock

MockTaskC sets up a mock handler for TaskC.

func (*Mock) MockTaskD 

func (svc *Mock) MockTaskD(handler func(ctx context.Context, flow *workflow.Flow) (totalOut int, tagsOut []string, seenOut []string, err error)) *Mock

MockTaskD sets up a mock handler for TaskD.

func (*Mock) MockTaskE 

func (svc *Mock) MockTaskE(handler func(ctx context.Context, flow *workflow.Flow, total int, tags []string, seen []string) (finalSum int, finalList []string, finalSet []string, err error)) *Mock

MockTaskE sets up a mock handler for TaskE.

func (*Mock) OnShutdown 

func (svc *Mock) OnShutdown(ctx context.Context) (err error)

OnShutdown is called when the microservice is shut down.

func (*Mock) OnStartup 

func (svc *Mock) OnStartup(ctx context.Context) (err error)

OnStartup is called when the microservice is started up.

func (*Mock) Reducer 

func (svc *Mock) Reducer(ctx context.Context) (graph *workflow.Graph, err error)

Reducer returns the workflow graph, or a mocked graph if MockReducer was called.

func (*Mock) TaskA 

func (svc *Mock) TaskA(ctx context.Context, flow *workflow.Flow) (started bool, err error)

TaskA executes the mock handler.

func (*Mock) TaskB 

func (svc *Mock) TaskB(ctx context.Context, flow *workflow.Flow) (totalOut int, tagsOut []string, seenOut []string, err error)

TaskB executes the mock handler.

func (*Mock) TaskC 

func (svc *Mock) TaskC(ctx context.Context, flow *workflow.Flow) (totalOut int, tagsOut []string, seenOut []string, err error)

TaskC executes the mock handler.

func (*Mock) TaskD 

func (svc *Mock) TaskD(ctx context.Context, flow *workflow.Flow) (totalOut int, tagsOut []string, seenOut []string, err error)

TaskD executes the mock handler.

func (*Mock) TaskE 

func (svc *Mock) TaskE(ctx context.Context, flow *workflow.Flow, total int, tags []string, seen []string) (finalSum int, finalList []string, finalSet []string, err error)

TaskE executes the mock handler.

type Service 

type Service struct {
	*Intermediate // IMPORTANT: Do not remove
}

Service implements reducerflow.verify, exercising sum/list/set reducers at fan-in.

func NewService 

func NewService() *Service

NewService creates a new instance of the microservice.

func (*Service) Init 

func (svc *Service) Init(initializer func(svc *Service) (err error)) *Service

Init enables a single-statement pattern for initializing the microservice.

func (*Service) OnShutdown 

func (svc *Service) OnShutdown(ctx context.Context) (err error)

OnShutdown is called when the microservice is shut down.

func (*Service) OnStartup 

func (svc *Service) OnStartup(ctx context.Context) (err error)

OnStartup is called when the microservice is started up.

func (*Service) Reducer 

func (svc *Service) Reducer(ctx context.Context) (graph *workflow.Graph, err error)

Reducer defines the graph A -> {B, C, D} -> E with reducer-managed fan-in fields.

func (*Service) TaskA 

func (svc *Service) TaskA(ctx context.Context, flow *workflow.Flow) (started bool, err error)

TaskA is the fan-out source.

func (*Service) TaskB 

func (svc *Service) TaskB(ctx context.Context, flow *workflow.Flow) (totalOut int, tagsOut, seenOut []string, err error)

TaskB contributes deltas: +10 to total, ["b"] to tags, ["x"] to seen.

func (*Service) TaskC 

func (svc *Service) TaskC(ctx context.Context, flow *workflow.Flow) (totalOut int, tagsOut, seenOut []string, err error)

TaskC contributes deltas: +20 to total, ["c"] to tags, ["y","x"] to seen. The "x" overlaps with TaskB's contribution; seen's union reducer dedupes it.

func (*Service) TaskD 

func (svc *Service) TaskD(ctx context.Context, flow *workflow.Flow) (totalOut int, tagsOut, seenOut []string, err error)

TaskD contributes deltas: +30 to total, ["d"] to tags, ["z"] to seen.

func (*Service) TaskE 

func (svc *Service) TaskE(ctx context.Context, flow *workflow.Flow, total int, tags, seen []string) (finalSum int, finalList, finalSet []string, err error)

TaskE reads the reducer-merged values and surfaces them.

type ToDo 

type ToDo interface {
	OnStartup(ctx context.Context) (err error)
	OnShutdown(ctx context.Context) (err error)
	TaskA(ctx context.Context, flow *workflow.Flow) (started bool, err error)                                                               // MARKER: TaskA
	TaskB(ctx context.Context, flow *workflow.Flow) (totalOut int, tagsOut, seenOut []string, err error)                                    // MARKER: TaskB
	TaskC(ctx context.Context, flow *workflow.Flow) (totalOut int, tagsOut, seenOut []string, err error)                                    // MARKER: TaskC
	TaskD(ctx context.Context, flow *workflow.Flow) (totalOut int, tagsOut, seenOut []string, err error)                                    // MARKER: TaskD
	TaskE(ctx context.Context, flow *workflow.Flow, total int, tags, seen []string) (finalSum int, finalList, finalSet []string, err error) // MARKER: TaskE
	Reducer(ctx context.Context) (graph *workflow.Graph, err error)                                                                         // MARKER: Reducer
}

ToDo is implemented by the service or mock.

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.