Questions about Jobs

[5HT2]

Hi, just checking to be sure I understand correctly from the example given.

• NewJobTracker registers a Worker and it's information, to manage it's own Queue
• A Worker has a pointer to JobTracker, a "job"? and a given Context

What I'm trying to figure out is, what "job" is supposed to be.

As far as I can tell, from how it's used in goop and the filerecurse example, is that it's a "unique" name for the job?

But does it have to be unique? What is it actually used for / what happens when it collides?

I see it being used to spawn a new job using a RecurseWorker inside RecurseWorker, when it encounters a new dir, or in goop each git hash is given it's own job. I'm trying to understand why, and if I can just set it to some static thing and forget about it.

[5HT2]

Okay, I had time to look a bit more. job is used in queue which is a chan string.

Supposedly this means it has to be unique? Does it? I don't really know how to use chan myself.

What I'm trying to solve is, I'm using https://github.com/diamondburned/arikawa/ and I want to call my bot events as async jobs.

The reason I need concurrent states is that some of these events modify the same parts of the bot's config at various times, or if the same event is called concurrently then it will modify the exact same value in the config.

Right now, I can do c.AddHandler(MessageReactionAddEvent), and that handler is my own code:

func MessageReactionAddEvent(e *gateway.MessageReactionAddEvent) {
	TopicReactionHandler(e)
	StarboardReactionHandler(e)
}

I want to do jt.AddJob inside of MessageReactionAddEvent, but my problem now is how do I get e to my own handlers?

[5HT2]

@deletescape would you happen to know how I could accomplish that? / would you mind implementing it into jt?

I'd be happy to make a pull request if I knew how. I'm considering adding an empty interface to Worker which Worker can access, but I still need AddJob to dispatch it in some way`. I don't see a way to do that without deviating away from the string queue setup for dispatching jobs.