metadata

Documentation

Index

• Constants
• Variables
• type Badger
  • func NewBadgerStorage(ctx context.Context, config configuration.Config) (storage *Badger, err error)
  • func (this *Badger) EnsureKnownDeployments(knownCamundaDeploymentIds []string) (known []Metadata, err error)
  • func (this *Badger) IsPlaceholder() bool
  • func (this *Badger) List() (known []Metadata, err error)
  • func (this *Badger) Read(deploymentId string) (result Metadata, err error)
  • func (this *Badger) Remove(camundaDeploymentId string) (err error)
  • func (this *Badger) Store(metadata Metadata) error
• type Bolt
  • func NewBoltStorage(ctx context.Context, config configuration.Config) (storage *Bolt, err error)
  • func (this *Bolt) EnsureKnownDeployments(knownCamundaDeploymentIds []string) (known []Metadata, err error)
  • func (this *Bolt) IsPlaceholder() bool
  • func (this *Bolt) List() (known []Metadata, err error)
  • func (this *Bolt) Read(deploymentId string) (result Metadata, err error)
  • func (this *Bolt) Remove(camundaDeploymentId string) (err error)
  • func (this *Bolt) Store(metadata Metadata) error
• type Metadata
• type MongoStorage
  • func (this *MongoStorage) EnsureKnownDeployments(knownCamundaDeploymentIds []string) (known []Metadata, err error)
  • func (this *MongoStorage) Init() (err error)
  • func (this *MongoStorage) IsPlaceholder() bool
  • func (this *MongoStorage) List() (known []Metadata, err error)
  • func (this *MongoStorage) Read(deploymentId string) (result Metadata, err error)
  • func (this *MongoStorage) Remove(camundaDeploymentId string) (err error)
  • func (this *MongoStorage) Store(metadata Metadata) error
• type Storage
  • func NewMongoStorage(ctx context.Context, config configuration.Config) (storage Storage, err error)
  • func NewStorage(ctx context.Context, config configuration.Config) (storage Storage, err error)
• type VoidStorage
  • func (this VoidStorage) EnsureKnownDeployments(knownCamundaDeploymentIds []string) (known []Metadata, err error)
  • func (this VoidStorage) IsPlaceholder() bool
  • func (this VoidStorage) List() (known []Metadata, err error)
  • func (this VoidStorage) Read(deploymentId string) (Metadata, error)
  • func (this VoidStorage) Remove(camundaDeploymentId string) (err error)
  • func (this VoidStorage) Store(metadata Metadata) error

Constants

const DeploymentMetadataMongoCollection = "deployment_metadata"

Variables

var BADGER_PREFETCH = true

var BBOLT_BUCKET_NAME = []byte("metadata")

Types

type Badger

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

func NewBadgerStorage

func NewBadgerStorage(ctx context.Context, config configuration.Config) (storage *Badger, err error)

func (*Badger) EnsureKnownDeployments

func (this *Badger) EnsureKnownDeployments(knownCamundaDeploymentIds []string) (known []Metadata, err error)

func (*Badger) IsPlaceholder

func (this *Badger) IsPlaceholder() bool

func (*Badger) List

func (this *Badger) List() (known []Metadata, err error)

func (*Badger) Read

func (this *Badger) Read(deploymentId string) (result Metadata, err error)

func (*Badger) Remove

func (this *Badger) Remove(camundaDeploymentId string) (err error)

func (*Badger) Store

func (this *Badger) Store(metadata Metadata) error

type Bolt

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

func NewBoltStorage

func NewBoltStorage(ctx context.Context, config configuration.Config) (storage *Bolt, err error)

func (*Bolt) EnsureKnownDeployments

func (this *Bolt) EnsureKnownDeployments(knownCamundaDeploymentIds []string) (known []Metadata, err error)

func (*Bolt) IsPlaceholder

func (this *Bolt) IsPlaceholder() bool

func (*Bolt) List

func (this *Bolt) List() (known []Metadata, err error)

func (*Bolt) Read

func (this *Bolt) Read(deploymentId string) (result Metadata, err error)

func (*Bolt) Remove

func (this *Bolt) Remove(camundaDeploymentId string) (err error)

func (*Bolt) Store

func (this *Bolt) Store(metadata Metadata) error

type Metadata

type Metadata struct {
	CamundaDeploymentId string                           `json:"camunda_deployment_id"`
	ProcessParameter    map[string]camundamodel.Variable `json:"process_parameter"`
	DeploymentModel     model.FogDeploymentMessage       `json:"deployment_model"`
}

type MongoStorage

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

func (*MongoStorage) EnsureKnownDeployments

func (this *MongoStorage) EnsureKnownDeployments(knownCamundaDeploymentIds []string) (known []Metadata, err error)

removes unknown deployments returns all all known deployment metadata

func (*MongoStorage) Init

func (this *MongoStorage) Init() (err error)

func (*MongoStorage) IsPlaceholder

func (this *MongoStorage) IsPlaceholder() bool

func (*MongoStorage) List

func (this *MongoStorage) List() (known []Metadata, err error)

func (*MongoStorage) Read

func (this *MongoStorage) Read(deploymentId string) (result Metadata, err error)

func (*MongoStorage) Remove

func (this *MongoStorage) Remove(camundaDeploymentId string) (err error)

func (*MongoStorage) Store

func (this *MongoStorage) Store(metadata Metadata) error

type Storage

type Storage interface {
	Store(Metadata) error
	Remove(camundaDeploymentId string) (err error)

	//removes unknown deployments
	//returns all all known deployment metadata
	EnsureKnownDeployments(knownCamundaDeploymentIds []string) (known []Metadata, err error)

	Read(deploymentId string) (Metadata, error)

	List() (known []Metadata, err error)

	IsPlaceholder() bool
}

func NewMongoStorage

func NewMongoStorage(ctx context.Context, config configuration.Config) (storage Storage, err error)

func NewStorage

func NewStorage(ctx context.Context, config configuration.Config) (storage Storage, err error)

type VoidStorage

type VoidStorage struct {
	Debug bool
}

func (VoidStorage) EnsureKnownDeployments

func (this VoidStorage) EnsureKnownDeployments(knownCamundaDeploymentIds []string) (known []Metadata, err error)

func (VoidStorage) IsPlaceholder

func (this VoidStorage) IsPlaceholder() bool

func (VoidStorage) List

func (this VoidStorage) List() (known []Metadata, err error)

func (VoidStorage) Read

func (this VoidStorage) Read(deploymentId string) (Metadata, error)

func (VoidStorage) Remove

func (this VoidStorage) Remove(camundaDeploymentId string) (err error)

func (VoidStorage) Store

func (this VoidStorage) Store(metadata Metadata) error