core

Documentation

Index

• func CreateFile(path string) (*os.File, error)
• func FormatManifest(manifest []byte) string
• func GetConsumerAdapters(config *model.ServiceUnitConfig) []model.ConsumerConfig
• func GetFilePath(dir, name, kind string) string
• func GetRepositoryAdapter(config *model.ServiceUnitConfig) *model.RepositoryConfig
• func HasConsumerAdapters(config *model.ServiceUnitConfig) bool
• func HasGatewayConfig(config *model.ServiceUnitConfig) bool
• func HasRepositoryAdapter(config *model.ServiceUnitConfig) bool
• type BrokerManifestError
  • func NewBrokerManifestError(brokerAdapterConfig *model.ConsumerConfig, message string) BrokerManifestError
  • func NewBrokerManifestFileError(serviceUnitConfig *model.ServiceUnitConfig, message string) BrokerManifestError
  • func (e *BrokerManifestError) Error() string
• type CommonManifestError
  • func NewCommonManifestError(serviceUnitConfig *model.ServiceUnitConfig, message string) CommonManifestError
  • func (e *CommonManifestError) Error() string
• type LoadGeneratorManifestError
  • func NewLoadGeneratorManifestError(serviceUnitConfig *model.ServiceUnitConfig, message string) LoadGeneratorManifestError
  • func (e *LoadGeneratorManifestError) Error() string
• type Manifest
• type ManifestErrors
  • func (me ManifestErrors) Exist() bool
  • func (me *ManifestErrors) Extend(other ManifestErrors)
  • func (me ManifestErrors) Print()
• type StatefulManifestError
  • func NewStatefulManifestError(serviceUnitConfig *model.ServiceUnitConfig, message string) StatefulManifestError
  • func (e *StatefulManifestError) Error() string
• type StatelessManifestError
  • func NewStatelessManifestError(serviceUnitConfig *model.ServiceUnitConfig, message string) StatelessManifestError
  • func (e *StatelessManifestError) Error() string

Functions

func CreateFile

func CreateFile(path string) (*os.File, error)

CreateFile create and open file in append

func FormatManifest

func FormatManifest(manifest []byte) string

func GetConsumerAdapters

func GetConsumerAdapters(config *model.ServiceUnitConfig) []model.ConsumerConfig

func GetFilePath

func GetFilePath(dir, name, kind string) string

func GetRepositoryAdapter

func GetRepositoryAdapter(config *model.ServiceUnitConfig) *model.RepositoryConfig

func HasConsumerAdapters

func HasConsumerAdapters(config *model.ServiceUnitConfig) bool

func HasGatewayConfig

func HasGatewayConfig(config *model.ServiceUnitConfig) bool

func HasRepositoryAdapter

func HasRepositoryAdapter(config *model.ServiceUnitConfig) bool

Types

type BrokerManifestError

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

broker error

func NewBrokerManifestError

func NewBrokerManifestError(brokerAdapterConfig *model.ConsumerConfig, message string) BrokerManifestError

func NewBrokerManifestFileError

func NewBrokerManifestFileError(serviceUnitConfig *model.ServiceUnitConfig, message string) BrokerManifestError

func (*BrokerManifestError) Error

func (e *BrokerManifestError) Error() string

type CommonManifestError

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

stateless error

func NewCommonManifestError

func NewCommonManifestError(serviceUnitConfig *model.ServiceUnitConfig, message string) CommonManifestError

func (*CommonManifestError) Error

func (e *CommonManifestError) Error() string

type LoadGeneratorManifestError

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

stateless error

func NewLoadGeneratorManifestError

func NewLoadGeneratorManifestError(serviceUnitConfig *model.ServiceUnitConfig, message string) LoadGeneratorManifestError

func (*LoadGeneratorManifestError) Error

func (e *LoadGeneratorManifestError) Error() string

type Manifest

type Manifest interface {
	// Generate generates manifest in
	Generate(*v1.ServiceUnitConfig, string) ManifestErrors
}

Manifest interface should be implemented by structs that represent kubernetes resources required by entities such as service unit

type ManifestErrors

type ManifestErrors struct {
	Stateless     []StatelessManifestError
	Broker        []BrokerManifestError
	Stateful      []StatefulManifestError
	Common        []CommonManifestError
	LoadGenerator []LoadGeneratorManifestError
}

func (ManifestErrors) Exist

func (me ManifestErrors) Exist() bool

func (*ManifestErrors) Extend

func (me *ManifestErrors) Extend(other ManifestErrors)

func (ManifestErrors) Print

func (me ManifestErrors) Print()

type StatefulManifestError

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

stateful error

func NewStatefulManifestError

func NewStatefulManifestError(serviceUnitConfig *model.ServiceUnitConfig, message string) StatefulManifestError

func (*StatefulManifestError) Error

func (e *StatefulManifestError) Error() string

type StatelessManifestError

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

stateless error

func NewStatelessManifestError

func NewStatelessManifestError(serviceUnitConfig *model.ServiceUnitConfig, message string) StatelessManifestError

func (*StatelessManifestError) Error

func (e *StatelessManifestError) Error() string