(ctx context.Context, params *QueueGetParams)
| 278 | QueueCreateOrSetUpdatedAt(ctx context.Context, params *QueueCreateOrSetUpdatedAtParams) (*rivertype.Queue, error) |
| 279 | QueueDeleteExpired(ctx context.Context, params *QueueDeleteExpiredParams) ([]string, error) |
| 280 | QueueGet(ctx context.Context, params *QueueGetParams) (*rivertype.Queue, error) |
| 281 | QueueList(ctx context.Context, params *QueueListParams) ([]*rivertype.Queue, error) |
| 282 | QueueNameList(ctx context.Context, params *QueueNameListParams) ([]string, error) |
| 283 | QueuePause(ctx context.Context, params *QueuePauseParams) error |
no outgoing calls