| 44 | } |
| 45 | |
| 46 | func (c *Config) AssignedPartitions() []int32 { |
| 47 | if len(c.AssignedPartitionsMap) > 0 { |
| 48 | return c.AssignedPartitionsMap[c.InstanceID] |
| 49 | } |
| 50 | |
| 51 | id, err := ingest.IngesterPartitionID(c.InstanceID) |
| 52 | if err != nil { |
| 53 | return c.AssignedPartitionsMap[c.InstanceID] |
| 54 | } |
| 55 | |
| 56 | assignedPartitions := make([]int32, 0, c.PartitionsPerInstance) |
| 57 | for i := 0; i < c.PartitionsPerInstance; i++ { |
| 58 | assignedPartitions = append(assignedPartitions, id*int32(c.PartitionsPerInstance)+int32(i)) |
| 59 | } |
| 60 | return assignedPartitions |
| 61 | } |
| 62 | |
| 63 | func (c *Config) Validate() error { |
| 64 | if len(c.AssignedPartitionsMap) == 0 && c.PartitionsPerInstance <= 0 { |