knative

Documentation

Index

• Constants
• type CamelEndpointKind
• type CamelEnvironment
  • func NewCamelEnvironment() CamelEnvironment
  • func (env *CamelEnvironment) ContainsService(name string, endpointKind CamelEndpointKind, serviceType CamelServiceType, ...) bool
  • func (env *CamelEnvironment) Deserialize(str string) error
  • func (env *CamelEnvironment) FindService(name string, endpointKind CamelEndpointKind, serviceType CamelServiceType, ...) *CamelServiceDefinition
  • func (env *CamelEnvironment) Serialize() (string, error)
  • func (env *CamelEnvironment) SetSinkBinding(name string, endpointKind CamelEndpointKind, serviceType CamelServiceType, ...)
  • func (env *CamelEnvironment) ToCamelProperties() map[string]string
• type CamelServiceDefinition
  • func BuildCamelServiceDefinition(name string, endpointKind CamelEndpointKind, serviceType CamelServiceType, ...) (CamelServiceDefinition, error)
• type CamelServiceType
  • func (s CamelServiceType) ResourceDescription(subject string) string

Constants

const (
	CamelMetaKnativeKind       = "knative.kind"
	CamelMetaKnativeAPIVersion = "knative.apiVersion"
	CamelMetaKnativeReply      = "knative.reply"
	CamelMetaKnativeName       = "knative.name"

	CamelMetaEndpointKind = "camel.endpoint.kind"

	CamelMetaFilterPrefix = "filter."
)

Meta Options.

Types

type CamelEndpointKind

type CamelEndpointKind string

CamelEndpointKind -- .

const (
	// CamelEndpointKindSource is a service that can be used to consume events.
	CamelEndpointKindSource CamelEndpointKind = "source"
	// CamelEndpointKindSink is a service that can be used to send events to.
	CamelEndpointKindSink CamelEndpointKind = "sink"
)

type CamelEnvironment

type CamelEnvironment struct {
	Services []CamelServiceDefinition `json:"services"`
}

CamelEnvironment is the top level configuration object expected by the Camel Knative component.

func NewCamelEnvironment

func NewCamelEnvironment() CamelEnvironment

NewCamelEnvironment creates a new env.

func (*CamelEnvironment) ContainsService

func (env *CamelEnvironment) ContainsService(name string, endpointKind CamelEndpointKind, serviceType CamelServiceType, apiVersion, kind string) bool

ContainsService tells if the environment contains a service with the given name and type.

func (*CamelEnvironment) Deserialize

func (env *CamelEnvironment) Deserialize(str string) error

Deserialize deserializes a camel environment into this struct.

func (*CamelEnvironment) FindService

func (env *CamelEnvironment) FindService(name string, endpointKind CamelEndpointKind, serviceType CamelServiceType, apiVersion, kind string) *CamelServiceDefinition

FindService -- .

func (*CamelEnvironment) Serialize

func (env *CamelEnvironment) Serialize() (string, error)

Serialize serializes a CamelEnvironment.

func (*CamelEnvironment) SetSinkBinding

func (env *CamelEnvironment) SetSinkBinding(name string, endpointKind CamelEndpointKind, serviceType CamelServiceType, apiVersion, kind string)

SetSinkBinding marks one of the service as SinkBinding.

func (*CamelEnvironment) ToCamelProperties

func (env *CamelEnvironment) ToCamelProperties() map[string]string

ToCamelProperties returns the application properties representation of the services.

type CamelServiceDefinition

type CamelServiceDefinition struct {
	ServiceType CamelServiceType  `json:"type"`
	Name        string            `json:"name"`
	URL         string            `json:"url,omitempty"`
	Path        string            `json:"path,omitempty"`
	Metadata    map[string]string `json:"metadata,omitempty"`
	SinkBinding bool              `json:"sinkBinding,omitempty"`
}

CamelServiceDefinition defines the parameters to connect to Knative service. It's also used for exposed services.

func BuildCamelServiceDefinition

func BuildCamelServiceDefinition(name string, endpointKind CamelEndpointKind, serviceType CamelServiceType,
	serviceURL url.URL, apiVersion, kind string) (CamelServiceDefinition, error)

BuildCamelServiceDefinition creates a CamelServiceDefinition from a given URL.

type CamelServiceType

type CamelServiceType string

CamelServiceType -- .

const (
	// CamelServiceTypeEndpoint is a callable endpoint.
	CamelServiceTypeEndpoint CamelServiceType = "endpoint"
	// CamelServiceTypeChannel is a callable endpoint that will be also associated to a subscription.
	CamelServiceTypeChannel CamelServiceType = "channel"
	// CamelServiceTypeEvent is used when the target service is the Knative broker.
	CamelServiceTypeEvent CamelServiceType = "event"
)

func (CamelServiceType) ResourceDescription

func (s CamelServiceType) ResourceDescription(subject string) string