Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
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.GetQueryParams) }
Strategy defines the operations that every different isolation strategy in processor must implement
func GetStrategy ¶
GetStrategy returns the strategy for the given isolation mode. An error is returned if the mode is invalid
Click to show internal directories.
Click to hide internal directories.