connector

Documentation

Index

• type Connector
  • func AddConnector(handler ConnectorsHandler, loadedOptions common.DefaultOptions, ...) (*Connector, error)
  • func CopyConnector(origin *Connector) (*Connector, error)
  • func EditConnector(origin *Connector, isCopyMode bool) (*Connector, error)
  • func NewConnector(handler ConnectorsHandler, loadedOptions common.DefaultOptions, ...) *Connector
  • func (c *Connector) Clone() *Connector
  • func (c *Connector) ColoredYaml() string
  • func (c *Connector) GetBindingNames() []string
  • func (c *Connector) GetIntegrationsForCluster(endPoints []string) []*common.Binding
  • func (c *Connector) GetManifest() *common.Manifest
  • func (c *Connector) Key() string
  • func (c *Connector) SetHandler(value ConnectorsHandler) *Connector
  • func (c *Connector) SetLoadedOptions(value common.DefaultOptions) *Connector
  • func (c *Connector) Update(loadedOptions common.DefaultOptions, targets, sources []byte) *Connector
  • func (c *Connector) Validate() error
• type ConnectorsHandler
• type Name
  • func NewName() *Name
  • func (n *Name) Render(defaultName string) (*Name, error)
  • func (n *Name) SetTakenNames(value []string) *Name
  • func (n *Name) Validate() error
• type Namespace
  • func NewNamespace() *Namespace
  • func (n *Namespace) Render() (*Namespace, error)
  • func (n *Namespace) SetNamespaces(value []string) *Namespace
  • func (n *Namespace) Validate() error
• type Replicas
  • func NewReplicas() *Replicas
  • func (r *Replicas) Render(defaultVal int) (int, error)
  • func (r *Replicas) Validate() error
• type Status
• type Validator

Types

type Connector

type Connector struct {
	Name         string            `json:"name"`
	Namespace    string            `json:"namespace"`
	Type         string            `json:"type"`
	Replicas     int               `json:"replicas"`
	Config       string            `json:"config"`
	NodePort     int               `json:"node_port"`
	ServiceType  string            `json:"service_type"`
	Image        string            `json:"image"`
	Integrations *common.Bindings  `json:"-" yaml:"-"`
	Bridges      *bridges.Bindings `json:"-" yaml:"-"`
	Status       *Status           `json:"-" yaml:"-"`
	// contains filtered or unexported fields
}

func AddConnector

func AddConnector(handler ConnectorsHandler, loadedOptions common.DefaultOptions, targetsManifests, sourceManifest []byte) (*Connector, error)

func CopyConnector

func CopyConnector(origin *Connector) (*Connector, error)

func EditConnector

func EditConnector(origin *Connector, isCopyMode bool) (*Connector, error)

func NewConnector

func NewConnector(handler ConnectorsHandler, loadedOptions common.DefaultOptions, targetManifest, sourceManifest []byte) *Connector

func (*Connector) Clone

func (c *Connector) Clone() *Connector

func (*Connector) ColoredYaml

func (c *Connector) ColoredYaml() string

func (*Connector) GetBindingNames

func (c *Connector) GetBindingNames() []string

func (*Connector) GetIntegrationsForCluster

func (c *Connector) GetIntegrationsForCluster(endPoints []string) []*common.Binding

func (*Connector) GetManifest

func (c *Connector) GetManifest() *common.Manifest

func (*Connector) Key

func (c *Connector) Key() string

func (*Connector) SetHandler

func (c *Connector) SetHandler(value ConnectorsHandler) *Connector

func (*Connector) SetLoadedOptions

func (c *Connector) SetLoadedOptions(value common.DefaultOptions) *Connector

func (*Connector) Update

func (c *Connector) Update(loadedOptions common.DefaultOptions, targets, sources []byte) *Connector

func (*Connector) Validate

func (c *Connector) Validate() error

type ConnectorsHandler

type ConnectorsHandler interface {
	Name() string
	Add(connector *Connector) error
	Edit(connector *Connector) error
	Delete(connector *Connector) error
	Get(namespace, name string) (*Connector, error)
	List() ([]*Connector, error)
}

type Name

type Name struct {
	Name string
	// contains filtered or unexported fields
}

func NewName

func NewName() *Name

func (*Name) Render

func (n *Name) Render(defaultName string) (*Name, error)

func (*Name) SetTakenNames

func (n *Name) SetTakenNames(value []string) *Name

func (*Name) Validate

func (n *Name) Validate() error

type Namespace

type Namespace struct {
	Namespace string
	// contains filtered or unexported fields
}

func NewNamespace

func NewNamespace() *Namespace

func (*Namespace) Render

func (n *Namespace) Render() (*Namespace, error)

func (*Namespace) SetNamespaces

func (n *Namespace) SetNamespaces(value []string) *Namespace

func (*Namespace) Validate

func (n *Namespace) Validate() error

type Replicas

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

func NewReplicas

func NewReplicas() *Replicas

func (*Replicas) Render

func (r *Replicas) Render(defaultVal int) (int, error)

func (*Replicas) Validate

func (r *Replicas) Validate() error

type Status

type Status struct {
	Replicas int32  `json:"replicas"`
	Type     string `json:"type"`
	Image    string `json:"image"`
	Api      string `json:"api"`
	Status   string `json:"status"`
}

type Validator

type Validator interface {
	Validate() error
}