pkg

Documentation

Index

• func Start(ctx context.Context, wg *sync.WaitGroup, config Config, ...) error
• type Config
• type Info
  • func New(config Config, libConfig configuration.Config, repo SmartServiceRepo) *Info
  • func (this *Info) Do(task model.CamundaExternalTask) (modules []model.Module, outputs map[string]interface{}, err error)
  • func (this *Info) Undo(modules []model.Module, reason error)
• type KeyValue
• type SmartServiceRepo

Functions

func Start

func Start(ctx context.Context, wg *sync.WaitGroup, config Config, libConfig configuration.Config) error

Types

type Config

type Config struct {
	WorkerParamPrefix                string `json:"worker_param_prefix"`
	EnableAdditionalModuleDataFields bool   `json:"enable_additional_module_data_fields"`
	Debug                            bool   `json:"debug"`
}

type Info

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

func New

func New(config Config, libConfig configuration.Config, repo SmartServiceRepo) *Info

func (*Info) Do

func (this *Info) Do(task model.CamundaExternalTask) (modules []model.Module, outputs map[string]interface{}, err error)

func (*Info) Undo

func (this *Info) Undo(modules []model.Module, reason error)

type KeyValue

type KeyValue struct {
	Key   string
	Value string
}

type SmartServiceRepo

type SmartServiceRepo interface {
	GetInstanceUser(instanceId string) (userId string, err error)
	UseModuleDeleteInfo(info model.ModuleDeleteInfo) error
	ListExistingModules(processInstanceId string, query model.ModulQuery) (result []model.SmartServiceModule, err error)
}