coordinator

package

v0.0.1 Latest Latest Go to latest Published: Aug 19, 2025 License: GPL-3.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ethpandaops/cbt

Links

Open Source Insights

Documentation ¶

Overview ¶

Package coordinator handles task coordination and dependency management

Index ¶

Variables
type Direction
type Service
- func NewService(log *logrus.Logger, redisOpt *redis.Options, dag *models.DependencyGraph, ...) (*Service, error)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// ErrShutdownErrors is returned when errors occur during shutdown
	ErrShutdownErrors = errors.New("errors during shutdown")
)

Functions ¶

This section is empty.

Types ¶

type Direction ¶

type Direction string

Direction represents the processing direction for tasks

const (
	// DirectionForward processes tasks in forward direction
	DirectionForward Direction = "forward"
	// DirectionBack processes tasks in backward direction
	DirectionBack Direction = "back"
)

type Service ¶

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

Service coordinates task processing and dependencies

func NewService ¶

func NewService(log *logrus.Logger, redisOpt *redis.Options, dag *models.DependencyGraph, adminService *admin.Service, validator *validation.DependencyValidator) (*Service, error)

NewService creates a new coordinator service

func (*Service) Process ¶

func (s *Service) Process(transformation models.Transformation, direction Direction)

Process handles transformation processing in the specified direction

func (*Service) Start ¶

func (s *Service) Start() error

Start initializes and starts the coordinator service

func (*Service) Stop ¶

func (s *Service) Stop() error

Stop gracefully shuts down the coordinator service

Source Files ¶

View all Source files

service.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL