types

Documentation

Index

• func MakeHTTPClient(insecure bool, maxConnections int, timeout time.Duration) *fasthttp.Client
• type Exchange
  • func (e *Exchange) EnsureCorrectType()
• type Invoker
• type OpenFaaSInvocation
  • func NewInvocation(delivery amqp.Delivery) *OpenFaaSInvocation
• type Topology
  • func ReadTopologyFromFile(fs afero.Fs, path string) (Topology, error)

Functions

func MakeHTTPClient

func MakeHTTPClient(insecure bool, maxConnections int, timeout time.Duration) *fasthttp.Client

MakeHTTPClient generates an HTTP Client setting basic properties including timeouts

Types

type Exchange

type Exchange struct {
	Name        string
	Topics      []string
	Declare     bool
	Type        string
	Durable     bool
	AutoDeleted bool
}

Exchange Definition of a RabbitMQ Exchange

func (*Exchange) EnsureCorrectType

func (e *Exchange) EnsureCorrectType()

EnsureCorrectType is responsible to make sure that the read-in type is one of the allowed which right now is direct or topic. If it is not a valid type, will default to direct.

type Invoker

type Invoker interface {
	Invoke(topic string, invocation *OpenFaaSInvocation) error
}

Invoker is the Interface used by the OpenFaaS Connector SDK to perform invocations of Lambdas based on a provided topic and message

type OpenFaaSInvocation

type OpenFaaSInvocation struct {
	ContentType     string
	ContentEncoding string
	Topic           string
	Message         *[]byte
}

OpenFaaSInvocation represent an Event Specification used during invocation

func NewInvocation

func NewInvocation(delivery amqp.Delivery) *OpenFaaSInvocation

NewInvocation creates a OpenFaaSInvocation from an amqp.Delivery.

type Topology

type Topology []struct {
	Name        string   `json:"name"`
	Topics      []string `json:"topics"`
	Declare     bool     `json:"declare"`
	Type        string   `json:"type,omitempty"`
	Durable     bool     `json:"durable,omitempty"`
	AutoDeleted bool     `json:"auto-deleted,omitempty"`
}

Topology definition

func ReadTopologyFromFile

func ReadTopologyFromFile(fs afero.Fs, path string) (Topology, error)

ReadTopologyFromFile reads a topology file in yaml format from the specified path. Further it parses the file and returns it already in the Topology struct format.