| 26 | func (a ascendingInt64s) Less(i, j int) bool { return a[i] < a[j] } |
| 27 | |
| 28 | type Server interface { |
| 29 | GetBroker() brokersiface.Broker |
| 30 | GetConfig() *config.Config |
| 31 | RegisterTasks(namedTaskFuncs map[string]interface{}) error |
| 32 | SendTaskWithContext(ctx context.Context, signature *tasks.Signature) (*result.AsyncResult, error) |
| 33 | SendTask(signature *tasks.Signature) (*result.AsyncResult, error) |
| 34 | SendChainWithContext(ctx context.Context, chain *tasks.Chain) (*result.ChainAsyncResult, error) |
| 35 | SendChain(chain *tasks.Chain) (*result.ChainAsyncResult, error) |
| 36 | SendGroupWithContext(ctx context.Context, group *tasks.Group, sendConcurrency int) ([]*result.AsyncResult, error) |
| 37 | SendGroup(group *tasks.Group, sendConcurrency int) ([]*result.AsyncResult, error) |
| 38 | SendChordWithContext(ctx context.Context, chord *tasks.Chord, sendConcurrency int) (*result.ChordAsyncResult, error) |
| 39 | SendChord(chord *tasks.Chord, sendConcurrency int) (*result.ChordAsyncResult, error) |
| 40 | } |
| 41 | |
| 42 | func testAll(server Server, t *testing.T) { |
| 43 | testSendTask(server, t) |
no outgoing calls
no test coverage detected