test

package
v1.53.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 4, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 (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 (*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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL