isolation

Documentation

Index

• type Mode
• type Strategy
  • func GetStrategy(mode Mode, customVal string, destinationFilter func(destinationID string) bool) (Strategy, error)

Types

type Mode

type Mode string

const (
	ModeNone        Mode = "none"
	ModeWorkspace   Mode = "workspace"
	ModeDestination Mode = "destination"
)

type Strategy

type Strategy interface {
	// ActivePartitions returns the list of partitions that are active for the given strategy
	ActivePartitions(ctx context.Context, db jobsdb.JobsDB) ([]string, error)
	// AugmentQueryParams augments the given GetQueryParamsT with the strategy specific parameters
	AugmentQueryParams(partition string, params *jobsdb.GetQueryParamsT)
	// StopIteration returns true if the iteration should be stopped for the given error
	StopIteration(err error) bool
}

Strategy defines the operations that every different isolation strategy in processor must implement

func GetStrategy

func GetStrategy(mode Mode, customVal string, destinationFilter func(destinationID string) bool) (Strategy, error)

GetStrategy returns the strategy for the given isolation mode. An error is returned if the mode is invalid