Source File
ss_rpc_consumer.go
Belonging Package
github.com/pancsta/asyncmachine-go/pkg/rpc/states
package statesimport (am)// ConsumerStatesDef contains all the states of the Consumer state machine.type ConsumerStatesDef struct {*am.StatesBaseException string// WorkerPayload RPC server delivers the requested payload to the Client.WorkerPayload string}// ConsumerSchema represents all relations and properties of ConsumerStates.var ConsumerSchema = am.Schema{ssCo.WorkerPayload: {Multi: true},}// ConsumerHandlers is the required interface for Consumer's state handlers.type ConsumerHandlers interface {WorkerPayloadState(e *am.Event)}// EXPORTS AND GROUPSvar (// ssCo is Consumer states from ConsumerStatesDef.ssCo = am.NewStates(ConsumerStatesDef{})// ConsumerStates contains all the states for the Consumer machine.ConsumerStates = ssCo)
![]() |
The pages are generated with Golds v0.8.2. (GOOS=linux GOARCH=amd64) Golds is a Go 101 project developed by Tapir Liu. PR and bug reports are welcome and can be submitted to the issue list. Please follow @zigo_101 (reachable from the left QR code) to get the latest news of Golds. |