db

package
v0.1.3 Latest Latest
Warning

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

Go to latest
Published: Feb 7, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AppDatabase

type AppDatabase interface {
	AddDatabaseBinding(binding DatabaseBinding) error
	UpdateDatabaseBindingState(bindingId NamespaceUniqueId, newState State) error
	UpdateDatabaseInstanceState(instanceId NamespaceUniqueId, newState State) error
	AddDatabaseInstance(instance DatabaseInstance) error
	UpdateDatabaseInstanceCredentials(instanceId NamespaceUniqueId, newCredentials map[string][]byte) error
	DeleteDatabaseBinding(bindingId NamespaceUniqueId) error
	DeleteDatabaseInstance(bindingInstance NamespaceUniqueId) error
	WasProcessed(eventId string) bool
	MarkProcessed(eventId string)
	FindDatabaseInstanceById(instanceId NamespaceUniqueId) (DatabaseInstance, error)
	FindAllDatabaseInstances() []DatabaseInstance
	FindAllDatabaseBindings() []DatabaseBinding
}

func NewYamlAppDatabase

func NewYamlAppDatabase(yamlFile string) AppDatabase

type DatabaseBinding

type DatabaseBinding struct {
	K8sName            string
	DatabaseInstanceId NamespaceUniqueId
	SecretName         string
	Namespace          string
	Meta               Meta
}

func (DatabaseBinding) NamespaceUniqueId

func (this DatabaseBinding) NamespaceUniqueId() NamespaceUniqueId

type DatabaseInstance

type DatabaseInstance struct {
	K8sName      string
	DbmsServer   string
	DatabaseName string
	Namespace    string
	Credentials  map[string][]byte
	Meta         Meta
}

func (DatabaseInstance) NamespaceUniqueId

func (this DatabaseInstance) NamespaceUniqueId() NamespaceUniqueId

func (DatabaseInstance) PrefixedDatabaseName

func (this DatabaseInstance) PrefixedDatabaseName() string

type DbData

type DbData struct {
	DatabaseInstances []DatabaseInstance
	DatabaseBindings  []DatabaseBinding
	ProcessedEvents   []string
}

type Meta

type Meta struct {
	Previous State
	Current  State
}

type NamespaceUniqueId

type NamespaceUniqueId string

func NewNamespaceUniqueId

func NewNamespaceUniqueId(namespace, k8sName string) NamespaceUniqueId

type ProvisioningAction

type ProvisioningAction string
const (
	CREATE ProvisioningAction = "create"
	DELETE ProvisioningAction = "delete"
)

func (ProvisioningAction) String added in v0.1.2

func (this ProvisioningAction) String() string

type ProvisioningState

type ProvisioningState string
const (
	PENDING ProvisioningState = "pending"
	READY   ProvisioningState = "ready"
	ERROR   ProvisioningState = "error"
)

func (ProvisioningState) String added in v0.1.2

func (this ProvisioningState) String() string

type State

type State struct {
	Action     ProvisioningAction
	State      ProvisioningState
	Message    string
	LastUpdate time.Time
}

func (State) String

func (this State) String() string

type YamlAppDatabase

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

func (*YamlAppDatabase) AddDatabaseBinding

func (this *YamlAppDatabase) AddDatabaseBinding(binding DatabaseBinding) error

func (*YamlAppDatabase) AddDatabaseInstance

func (this *YamlAppDatabase) AddDatabaseInstance(instance DatabaseInstance) error

func (*YamlAppDatabase) DeleteDatabaseBinding

func (this *YamlAppDatabase) DeleteDatabaseBinding(bindingId NamespaceUniqueId) error

func (*YamlAppDatabase) DeleteDatabaseInstance

func (this *YamlAppDatabase) DeleteDatabaseInstance(instanceId NamespaceUniqueId) error

func (*YamlAppDatabase) FindAllDatabaseBindings

func (this *YamlAppDatabase) FindAllDatabaseBindings() []DatabaseBinding

func (*YamlAppDatabase) FindAllDatabaseInstances

func (this *YamlAppDatabase) FindAllDatabaseInstances() []DatabaseInstance

func (*YamlAppDatabase) FindDatabaseInstanceById

func (this *YamlAppDatabase) FindDatabaseInstanceById(instanceId NamespaceUniqueId) (DatabaseInstance, error)

func (*YamlAppDatabase) MarkProcessed

func (this *YamlAppDatabase) MarkProcessed(eventId string)

func (*YamlAppDatabase) UpdateDatabaseBindingState

func (this *YamlAppDatabase) UpdateDatabaseBindingState(bindingId NamespaceUniqueId, newState State) error

func (*YamlAppDatabase) UpdateDatabaseInstanceCredentials

func (this *YamlAppDatabase) UpdateDatabaseInstanceCredentials(instanceId NamespaceUniqueId, newCredentials map[string][]byte) error

func (*YamlAppDatabase) UpdateDatabaseInstanceState

func (this *YamlAppDatabase) UpdateDatabaseInstanceState(instanceId NamespaceUniqueId, newState State) error

func (*YamlAppDatabase) WasProcessed

func (this *YamlAppDatabase) WasProcessed(eventId string) bool

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL