proxy

README

Proxy Package Documentation

This package includes modules that the hooks package utilizes to redirect the outgoing calls of the user API. This redirection is done with the aim to record or stub the outputs of dependency calls.

Documentation

Overview

Package proxy provides functionality for handling proxies.

Index

• func SetupCA(ctx context.Context, logger *zap.Logger) error
• type Conn
  • func (c *Conn) Read(p []byte) (int, error)
• type MockManager
  • func NewMockManager(filtered, unfiltered *TreeDb, logger *zap.Logger) *MockManager
  • func (m *MockManager) DeleteFilteredMock(mock *models.Mock) bool
  • func (m *MockManager) DeleteUnFilteredMock(mock *models.Mock) bool
  • func (m *MockManager) FlagMockAsUsed(mock *models.Mock) error
  • func (m *MockManager) GetConsumedMocks() []string
  • func (m *MockManager) GetFilteredMocks() ([]*models.Mock, error)
  • func (m *MockManager) GetUnFilteredMocks() ([]*models.Mock, error)
  • func (m *MockManager) SetFilteredMocks(mocks []*models.Mock)
  • func (m *MockManager) SetUnFilteredMocks(mocks []*models.Mock)
  • func (m *MockManager) UpdateUnFilteredMock(old *models.Mock, new *models.Mock) bool
• type Option
• type Proxy
  • func New(logger *zap.Logger, info core.DestInfo, opts config.Config) *Proxy
  • func (p *Proxy) GetConsumedMocks(_ context.Context, id uint64) ([]string, error)
  • func (p *Proxy) InitIntegrations(_ context.Context) error
  • func (p *Proxy) Mock(_ context.Context, id uint64, opts models.OutgoingOptions) error
  • func (p *Proxy) Record(_ context.Context, id uint64, mocks chan<- *models.Mock, ...) error
  • func (p *Proxy) ServeDNS(w dns.ResponseWriter, r *dns.Msg)
  • func (p *Proxy) SetMocks(_ context.Context, id uint64, filtered []*models.Mock, ...) error
  • func (p *Proxy) StartProxy(ctx context.Context, opts core.ProxyOptions) error
  • func (p *Proxy) StopProxyServer(ctx context.Context)
• type TreeDb
  • func NewTreeDb(comparator func(a, b interface{}) int) *TreeDb

Functions

func SetupCA

func SetupCA(ctx context.Context, logger *zap.Logger) error

SetupCA setups custom certificate authority to handle TLS connections

Types

type Conn

type Conn struct {
	net.Conn
	// contains filtered or unexported fields
}

func (*Conn) Read

func (c *Conn) Read(p []byte) (int, error)

type MockManager

type MockManager struct {
	// contains filtered or unexported fields
}

func NewMockManager

func NewMockManager(filtered, unfiltered *TreeDb, logger *zap.Logger) *MockManager

func (*MockManager) DeleteFilteredMock

func (m *MockManager) DeleteFilteredMock(mock *models.Mock) bool

func (*MockManager) DeleteUnFilteredMock

func (m *MockManager) DeleteUnFilteredMock(mock *models.Mock) bool

func (*MockManager) FlagMockAsUsed

func (m *MockManager) FlagMockAsUsed(mock *models.Mock) error

func (*MockManager) GetConsumedMocks

func (m *MockManager) GetConsumedMocks() []string

func (*MockManager) GetFilteredMocks

func (m *MockManager) GetFilteredMocks() ([]*models.Mock, error)

func (*MockManager) GetUnFilteredMocks

func (m *MockManager) GetUnFilteredMocks() ([]*models.Mock, error)

func (*MockManager) SetFilteredMocks

func (m *MockManager) SetFilteredMocks(mocks []*models.Mock)

func (*MockManager) SetUnFilteredMocks

func (m *MockManager) SetUnFilteredMocks(mocks []*models.Mock)

func (*MockManager) UpdateUnFilteredMock

func (m *MockManager) UpdateUnFilteredMock(old *models.Mock, new *models.Mock) bool

type Option

type Option struct {
	Port          uint32
	DNSPort       uint32
	MongoPassword string
}

Option provides a means to initiate the proxy based on user input.

type Proxy

type Proxy struct {
	IP4     string
	IP6     string
	Port    uint32
	DNSPort uint32

	DestInfo     core.DestInfo
	Integrations map[string]integrations.Integrations

	MockManagers sync.Map

	Listener net.Listener

	UDPDNSServer *dns.Server
	TCPDNSServer *dns.Server
	// contains filtered or unexported fields
}

func New

func New(logger *zap.Logger, info core.DestInfo, opts config.Config) *Proxy

func (*Proxy) GetConsumedMocks

func (p *Proxy) GetConsumedMocks(_ context.Context, id uint64) ([]string, error)

GetConsumedMocks returns the consumed filtered mocks for a given app id

func (*Proxy) InitIntegrations

func (p *Proxy) InitIntegrations(_ context.Context) error

func (*Proxy) Mock

func (p *Proxy) Mock(_ context.Context, id uint64, opts models.OutgoingOptions) error

func (*Proxy) Record

func (p *Proxy) Record(_ context.Context, id uint64, mocks chan<- *models.Mock, opts models.OutgoingOptions) error

func (*Proxy) ServeDNS

func (p *Proxy) ServeDNS(w dns.ResponseWriter, r *dns.Msg)

func (*Proxy) SetMocks

func (p *Proxy) SetMocks(_ context.Context, id uint64, filtered []*models.Mock, unFiltered []*models.Mock) error

func (*Proxy) StartProxy

func (p *Proxy) StartProxy(ctx context.Context, opts core.ProxyOptions) error

func (*Proxy) StopProxyServer

func (p *Proxy) StopProxyServer(ctx context.Context)

type TreeDb

type TreeDb struct {
	// contains filtered or unexported fields
}

func NewTreeDb

func NewTreeDb(comparator func(a, b interface{}) int) *TreeDb