metadata

package
v1.0.36 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 22, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const DeploymentMetadataMongoCollection = "deployment_metadata"
View Source 
const InstanceParamPrefix = "instance_parameter."
View Source 
const InstanceParametersMongoCollection = "instance_parameters"

Variables

View Source 
var BADGER_PREFETCH = true
View Source 
var BBOLT_BUCKET_NAME = []byte("metadata")
View Source 
var BBOLT_PARAM_BUCKET_NAME = []byte("instance_parameters")
View Source 
var ErrNotFound = fmt.Errorf("not found")

Functions

This section is empty.

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) GetInstanceParameter added in v1.0.36 

func (this *Badger) GetInstanceParameter(businessKey string) (result map[string]interface{}, err error)

func (*Badger) IsPlaceholder 

func (this *Badger) IsPlaceholder() bool

func (*Badger) List 

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

func (*Badger) ListInstanceParameterBusinessKeys added in v1.0.36 

func (this *Badger) ListInstanceParameterBusinessKeys() (businessKeys []string, 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) RemoveInstanceParameter added in v1.0.36 

func (this *Badger) RemoveInstanceParameter(businessKey string) error

func (*Badger) Store 

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

func (*Badger) StoreInstanceParameter added in v1.0.36 

func (this *Badger) StoreInstanceParameter(businessKey string, params map[string]interface{}) 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) GetInstanceParameter added in v1.0.36 

func (this *Bolt) GetInstanceParameter(businessKey string) (result map[string]interface{}, err error)

func (*Bolt) IsPlaceholder 

func (this *Bolt) IsPlaceholder() bool

func (*Bolt) List 

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

func (*Bolt) ListInstanceParameterBusinessKeys added in v1.0.36 

func (this *Bolt) ListInstanceParameterBusinessKeys() (businessKeys []string, 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) RemoveInstanceParameter added in v1.0.36 

func (this *Bolt) RemoveInstanceParameter(businessKey string) error

func (*Bolt) Store 

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

func (*Bolt) StoreInstanceParameter added in v1.0.36 

func (this *Bolt) StoreInstanceParameter(businessKey string, params map[string]interface{}) error

type InstanceParameter added in v1.0.36 

type InstanceParameter struct {
	BusinessKey string                 `bson:"business_key"`
	Params      map[string]interface{} `bson:"params"`
}

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) GetInstanceParameter added in v1.0.36 

func (this *MongoStorage) GetInstanceParameter(businessKey string) (result map[string]interface{}, err error)

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) ListInstanceParameterBusinessKeys added in v1.0.36 

func (this *MongoStorage) ListInstanceParameterBusinessKeys() (businessKeys []string, 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) RemoveInstanceParameter added in v1.0.36 

func (this *MongoStorage) RemoveInstanceParameter(businessKey string) (err error)

func (*MongoStorage) Store 

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

func (*MongoStorage) StoreInstanceParameter added in v1.0.36 

func (this *MongoStorage) StoreInstanceParameter(businessKey string, params map[string]interface{}) 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

	GetInstanceParameter(businessKey string) (map[string]interface{}, error)
	StoreInstanceParameter(businessKey string, params map[string]interface{}) error
	RemoveInstanceParameter(businessKey string) error
	ListInstanceParameterBusinessKeys() (businessKeys []string, err error)
}

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) GetInstanceParameter added in v1.0.36 

func (this VoidStorage) GetInstanceParameter(businessKey string) (map[string]interface{}, error)

func (VoidStorage) IsPlaceholder 

func (this VoidStorage) IsPlaceholder() bool

func (VoidStorage) List 

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

func (VoidStorage) ListInstanceParameterBusinessKeys added in v1.0.36 

func (this VoidStorage) ListInstanceParameterBusinessKeys() (businessKeys []string, 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) RemoveInstanceParameter added in v1.0.36 

func (this VoidStorage) RemoveInstanceParameter(businessKey string) error

func (VoidStorage) Store 

func (this VoidStorage) Store(metadata Metadata) error

func (VoidStorage) StoreInstanceParameter added in v1.0.36 

func (this VoidStorage) StoreInstanceParameter(businessKey string, params map[string]interface{}) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.