camunda

type Camunda struct {
	// contains filtered or unexported fields
}

type Handler interface {
	Do(task model.CamundaExternalTask) (outputs map[string]interface{}, err error)
}

type IncidentHandler interface {
	Handle(incident model.Incident) error
}

type IncidentHandlerProvider func(ctx context.Context, wg *sync.WaitGroup, c *Camunda) (IncidentHandler, error)

type NameWrapper struct {
	Name string `json:"name"`
}

type Shards interface {
	GetShards() (result []string, err error)
	GetShardForUser(userId string) (shardUrl string, err error)
}