integrations

README

Integrations Package Documentation

This package includes modules that are used for parsing different protocols.

Documentation

Overview

Package integrations provides functionality for integrating different types of services.

Index

• Constants
• Variables
• func Register(name string, i Initializer)
• type ConditionalDstCfg
• type Initializer
• type Integrations
• type MockMemDb

Constants

const (
	HTTP        integrationType = "http"
	GRPC        integrationType = "grpc"
	GENERIC     integrationType = "generic"
	MYSQL       integrationType = "mysql"
	POSTGRES_V1 integrationType = "postgres_v1"
	POSTGRES_V2 integrationType = "postgres_v2"
	MONGO       integrationType = "mongo"
)

constants for different types of integrations

Variables

var Registered = make(map[string]Initializer)

Functions

func Register

func Register(name string, i Initializer)

Types

type ConditionalDstCfg

type ConditionalDstCfg struct {
	Addr   string // Destination Addr (ip:port)
	Port   uint
	TLSCfg *tls.Config
}

type Initializer

type Initializer func(logger *zap.Logger) Integrations

type Integrations

type Integrations interface {
	MatchType(ctx context.Context, reqBuf []byte) bool
	RecordOutgoing(ctx context.Context, src net.Conn, dst net.Conn, mocks chan<- *models.Mock, opts models.OutgoingOptions) error
	MockOutgoing(ctx context.Context, src net.Conn, dstCfg *ConditionalDstCfg, mockDb MockMemDb, opts models.OutgoingOptions) error
}

type MockMemDb

type MockMemDb interface {
	GetFilteredMocks() ([]*models.Mock, error)
	GetUnFilteredMocks() ([]*models.Mock, error)
	UpdateUnFilteredMock(old *models.Mock, new *models.Mock) bool
	DeleteFilteredMock(mock *models.Mock) bool
	DeleteUnFilteredMock(mock *models.Mock) bool
	// Flag the mock as used which matches the external request from application in test mode
	FlagMockAsUsed(mock *models.Mock) error
}