MessageConsumer consumes state update messages. It's half of the state machine protocol
| 145 | // MessageConsumer consumes state update messages. It's half of |
| 146 | // the state machine protocol |
| 147 | type MessageConsumer interface { |
| 148 | // ConsumeMessage is called on a new incoming message to mutate the state |
| 149 | // of the state machine. Of course messages can be "inband" which actually |
| 150 | // perform state mutations, or might be "out-of-band" that just use the |
| 151 | // Gregor broadcast mechanism to make sure that all clients get the |
| 152 | // notification. It returns a version of the message to broadcast to clients. |
| 153 | ConsumeMessage(ctx context.Context, m Message) (Message, error) |
| 154 | } |
| 155 | |
| 156 | // StateMachine is the central interface of the Gregor system. Various parts of the |
| 157 | // server and client infrastructure will implement various parts of this interface, |
no outgoing calls
no test coverage detected
searching dependent graphs…