test

Documentation

Index

• func NewStartContext(t *testing.T, config *Config) *startContext
• func NewStopContext(t *testing.T) *stopContext
• type Config
• type InboundDescriptor
  • func (m InboundDescriptor) Config() connectorv1.Bindable
  • func (m InboundDescriptor) MessageName() string
  • func (m InboundDescriptor) MessageType() connectorv1.MessageType
  • func (m InboundDescriptor) MimeType() string
  • func (m InboundDescriptor) Name() string
• type InboundResponse
  • func (f *InboundResponse) Body() connectorv1.Bindable
  • func (f *InboundResponse) Headers() connectorv1.Headers
• type IngressConfig
  • func (i IngressConfig) ExternalAddress() string
  • func (i IngressConfig) InternalHost() string
  • func (i IngressConfig) InternalPort() int

Functions

func NewStartContext

func NewStartContext(t *testing.T, config *Config) *startContext

func NewStopContext

func NewStopContext(t *testing.T) *stopContext

Types

type Config

type Config struct {
	UserConfig         []byte              `json:"user_config"`
	Ingress            []IngressConfig     `json:"ingress_config"`
	InboundDescriptors []InboundDescriptor `json:"inbound_descriptors"`
}

type InboundDescriptor

type InboundDescriptor struct {
	ID           string                  `json:"id"`
	ReadableName string                  `json:"name"`
	MsgName      string                  `json:"message_name"`
	Mime         string                  `json:"mime_type"`
	Type         connectorv1.MessageType `json:"type"`
	Options      []byte                  `json:"options"`
}

func (InboundDescriptor) Config

func (m InboundDescriptor) Config() connectorv1.Bindable

func (InboundDescriptor) MessageName

func (m InboundDescriptor) MessageName() string

func (InboundDescriptor) MessageType

func (m InboundDescriptor) MessageType() connectorv1.MessageType

func (InboundDescriptor) MimeType

func (m InboundDescriptor) MimeType() string

func (InboundDescriptor) Name

func (m InboundDescriptor) Name() string

type InboundResponse

type InboundResponse struct {
	HeadersMap connectorv1.Headers
	Payload    []byte
}

func (*InboundResponse) Body

func (f *InboundResponse) Body() connectorv1.Bindable

func (*InboundResponse) Headers

func (f *InboundResponse) Headers() connectorv1.Headers

type IngressConfig

type IngressConfig struct {
	Name       string `json:"name"`
	BindHost   string `json:"host"`
	BindPort   int    `json:"port"`
	ExtAddress string `json:"external_address"`
}

func (IngressConfig) ExternalAddress

func (i IngressConfig) ExternalAddress() string

func (IngressConfig) InternalHost

func (i IngressConfig) InternalHost() string

func (IngressConfig) InternalPort

func (i IngressConfig) InternalPort() int