Documentation
¶
Index ¶
- Constants
- func CamundaError(task messages.CamundaTask, msg string)
- func CamundaWorker()
- func CheckExecutionAccess(token JwtImpersonate, resource string) (err error)
- func CloseProducer()
- func CompleteCamundaTask(msg string) (err error)
- func ExecuteCamundaTask(task messages.CamundaTask)
- func ExecuteNextCamundaTask() (wait bool)
- func GetCamundaTask() (tasks []messages.CamundaTask, err error)
- func GetDeviceInstance(token JwtImpersonate, deviceInstanceId string) (result model.DeviceInstance, err error)
- func GetDeviceService(token JwtImpersonate, serviceId string) (result model.Service, err error)
- func GetWorkerId() string
- func InitConsumer()
- func InitProducer() sarama.AsyncProducer
- func Produce(topic string, message string)
- func SetCamundaRetry(taskid string)
- func ToBpmnRequest(task messages.CamundaTask) (request messages.BpmnMsg, err error)
- type Envelope
- type JwtImpersonate
- func (this JwtImpersonate) Get(url string) (resp *http.Response, err error)
- func (this JwtImpersonate) GetJSON(url string, result interface{}) (err error)
- func (this JwtImpersonate) Post(url string, contentType string, body io.Reader) (resp *http.Response, err error)
- func (this JwtImpersonate) PostJSON(url string, body interface{}, result interface{}) (err error)
- type KeycloakClaims
- type OpenidToken
- type RealmAccess
- type RoleMapping
Constants ¶
View Source
const CAMUNDA_VARIABLES_PAYLOAD = "payload"
Variables ¶
This section is empty.
Functions ¶
func CamundaError ¶
func CamundaError(task messages.CamundaTask, msg string)
func CamundaWorker ¶
func CamundaWorker()
func CheckExecutionAccess ¶
func CheckExecutionAccess(token JwtImpersonate, resource string) (err error)
func CloseProducer ¶
func CloseProducer()
func CompleteCamundaTask ¶
func ExecuteCamundaTask ¶
func ExecuteCamundaTask(task messages.CamundaTask)
func ExecuteNextCamundaTask ¶
func ExecuteNextCamundaTask() (wait bool)
func GetCamundaTask ¶
func GetCamundaTask() (tasks []messages.CamundaTask, err error)
func GetDeviceInstance ¶
func GetDeviceInstance(token JwtImpersonate, deviceInstanceId string) (result model.DeviceInstance, err error)
func GetDeviceService ¶
func GetDeviceService(token JwtImpersonate, serviceId string) (result model.Service, err error)
func GetWorkerId ¶
func GetWorkerId() string
func InitConsumer ¶
func InitConsumer()
func InitProducer ¶
func InitProducer() sarama.AsyncProducer
func SetCamundaRetry ¶
func SetCamundaRetry(taskid string)
func ToBpmnRequest ¶
func ToBpmnRequest(task messages.CamundaTask) (request messages.BpmnMsg, err error)
Types ¶
type JwtImpersonate ¶
type JwtImpersonate string
func EnsureAccess ¶
func EnsureAccess() (token JwtImpersonate, err error)
func GetUserToken ¶
func GetUserToken(user string) (token JwtImpersonate, err error)
func (JwtImpersonate) Get ¶
func (this JwtImpersonate) Get(url string) (resp *http.Response, err error)
func (JwtImpersonate) GetJSON ¶
func (this JwtImpersonate) GetJSON(url string, result interface{}) (err error)
func (JwtImpersonate) PostJSON ¶
func (this JwtImpersonate) PostJSON(url string, body interface{}, result interface{}) (err error)
type KeycloakClaims ¶
type KeycloakClaims struct {
RealmAccess RealmAccess `json:"realm_access"`
jwt.StandardClaims
}
type OpenidToken ¶
type RealmAccess ¶
type RealmAccess struct {
Roles []string `json:"roles"`
}
type RoleMapping ¶
type RoleMapping struct {
Name string `json:"name"`
}
Source Files
¶
Click to show internal directories.
Click to hide internal directories.