proxy

package

v2.1.0-alpha9 Latest Latest Go to latest Published: Apr 19, 2024 License: Apache-2.0 Imports: 40 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

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
type Option
type Proxy
- func New(logger *zap.Logger, info core.DestInfo, opts config.Config) *Proxy
type TreeDb
- func NewTreeDb(comparator func(a, b interface{}) int) *TreeDb

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
integrations Package integrations provides functionality for integrating different types of services.	Package integrations provides functionality for integrating different types of services.
generic Package generic provides functionality for decoding generic dependencies.	Package generic provides functionality for decoding generic dependencies.
grpc Package grpc provides functionality for integrating with gRPC outgoing calls.	Package grpc provides functionality for integrating with gRPC outgoing calls.
http Package http provides functionality for handling HTTP outgoing calls.	Package http provides functionality for handling HTTP outgoing calls.
mongo Package mongo provides functionality for working with MongoDB outgoing calls.	Package mongo provides functionality for working with MongoDB outgoing calls.
mysql Package mysql provides integration with MySQL outgoing.	Package mysql provides integration with MySQL outgoing.
postgres/v1 Package v1 provides functionality for decoding Postgres requests and responses.	Package v1 provides functionality for decoding Postgres requests and responses.
scram Package scram provides functionality for SCRAM authentication.	Package scram provides functionality for SCRAM authentication.
util Package util provides utility functions for the integration package.	Package util provides utility functions for the integration package.
util Package util provides utility functions for the proxy package.	Package util provides utility functions for the proxy package.

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