()
| 37 | } |
| 38 | |
| 39 | func (o *UniqueOpts) StateBitmask() byte { |
| 40 | states := uniqueOptsByStateDefault |
| 41 | if len(o.ByState) > 0 { |
| 42 | states = o.ByState |
| 43 | } |
| 44 | return uniquestates.UniqueStatesToBitmask(states) |
| 45 | } |
| 46 | |
| 47 | func UniqueKey(timeGen rivertype.TimeGenerator, uniqueOpts *UniqueOpts, params *rivertype.JobInsertParams) ([]byte, error) { |
| 48 | uniqueKeyString, err := buildUniqueKeyString(timeGen, uniqueOpts, params) |