imports

Documentation

Index

• type Config
• type Imports
  • func New(config Config, libConfig configuration.Config, auth *auth.Auth, ...) *Imports
  • func (this *Imports) Do(task model.CamundaExternalTask) (modules []model.Module, outputs map[string]interface{}, err error)
  • func (this *Imports) Undo(modules []model.Module, reason error)
• type Instance
• type InstanceConfig
• type SmartServiceRepo

Types

type Config

type Config struct {
	ImportDeployUrl   string `json:"import_deploy_url"`
	WorkerParamPrefix string `json:"worker_param_prefix"`
	Debug             bool   `json:"debug"`
}

type Imports

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

func New

func New(config Config, libConfig configuration.Config, auth *auth.Auth, smartServiceRepo SmartServiceRepo) *Imports

func (*Imports) Do

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

func (*Imports) Undo

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

type Instance

type Instance struct {
	Id           string           `json:"id"`
	Name         string           `json:"name"`
	ImportTypeId string           `json:"import_type_id"`
	Image        string           `json:"image"`
	KafkaTopic   string           `json:"kafka_topic"`
	Configs      []InstanceConfig `json:"configs"`
	Restart      *bool            `json:"restart"`
	ServiceId    string           `json:"-"`
	Owner        string           `json:"-"`
	CreatedAt    time.Time        `json:"created_at"`
	UpdatedAt    time.Time        `json:"updated_at"`
	Generated    bool             `json:"generated"`
}

type InstanceConfig

type InstanceConfig struct {
	Name        string      `json:"name"`
	Value       interface{} `json:"value"`
	ValueString *string     `json:"-"`
}

type SmartServiceRepo

type SmartServiceRepo interface {
	GetInstanceUser(instanceId string) (userId string, err error)
}