integ

README

Integration tests

This directory contains integration tests for the iWF service.

• How to run
• The integration tests are written without iWF SDKs. The workflows are implemented in REST API routes. e.g. this basic workflow

Documentation

Index

• Constants
• type Codec
  • func (e *Codec) Decode(payloads []*commonpb.Payload) ([]*commonpb.Payload, error)
  • func (e *Codec) Encode(payloads []*commonpb.Payload) ([]*commonpb.Payload, error)
• type DataConverter
  • func NewEncryptionDataConverter(dataConverter converter.DataConverter, options DataConverterOptions) *DataConverter
• type DataConverterOptions
• type IwfServiceTestConfig

Constants

const (
	// MetadataEncodingEncrypted is "binary/encrypted"
	MetadataEncodingEncrypted = "binary/encrypted"

	// MetadataEncryptionKeyID is "encryption-key-id"
	MetadataEncryptionKeyID = "encryption-key-id"
)

Types

type Codec

type Codec struct {
	KeyID string
}

Codec implements PayloadCodec using AES Crypt.

func (*Codec) Decode

func (e *Codec) Decode(payloads []*commonpb.Payload) ([]*commonpb.Payload, error)

Decode implements converter.PayloadCodec.Decode.

func (*Codec) Encode

func (e *Codec) Encode(payloads []*commonpb.Payload) ([]*commonpb.Payload, error)

Encode implements converter.PayloadCodec.Encode.

type DataConverter

type DataConverter struct {
	converter.DataConverter
	// contains filtered or unexported fields
}

func NewEncryptionDataConverter

func NewEncryptionDataConverter(dataConverter converter.DataConverter, options DataConverterOptions) *DataConverter

NewEncryptionDataConverter creates a new instance of EncryptionDataConverter wrapping a DataConverter

type DataConverterOptions

type DataConverterOptions struct {
	KeyID string
	// Enable ZLib compression before encryption.
	Compress bool
}

type IwfServiceTestConfig

type IwfServiceTestConfig struct {
	BackendType                      service.BackendType
	MemoEncryption                   bool
	DisableFailAtMemoIncompatibility bool // default to false so that we will fail at test
	OptimizedVersioning              *bool
	DefaultHeaders                   map[string]string
}