substrate

package

v0.0.0-...-a2bc6c4 Latest Latest Go to latest Published: Nov 11, 2023 License: MPL-2.0 Imports: 25 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

github.com/asimihsan/virtual-cluster

Links

Open Source Insights

Documentation ¶

Index ¶

type ErrorCallback
type HTTPProxyRequest
type HTTPProxyResponse
type ManagedProcess
type Manager
- func NewManager(dbPath string, opts ...ManagerOption) (*Manager, error)
type ManagerOption
- func WithHTTPPort(port int) ManagerOption
- func WithVerbose() ManagerOption
type OutputCallback

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ErrorCallback ¶

type ErrorCallback func(string)

type HTTPProxyRequest ¶

type HTTPProxyRequest struct {
	ID        int
	Timestamp string
	Method    string
	URL       string
	Headers   string
	Body      string
}

type HTTPProxyResponse ¶

type HTTPProxyResponse struct {
	ID            int
	HTTPRequestID int
	Timestamp     string
	StatusCode    int
	Headers       string
	Body          string
}

type ManagedProcess ¶

type ManagedProcess struct {
	Name             string
	RunCommands      []string
	WorkingDirectory string
	Stop             chan struct{}
}

type Manager ¶

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

func NewManager ¶

func NewManager(dbPath string, opts ...ManagerOption) (*Manager, error)

func (*Manager) AddWorkingDirectoryUpward ¶

func (m *Manager) AddWorkingDirectoryUpward(serviceName, path string, verbose bool) error

func (*Manager) BroadcastLogsAndRequests ¶

func (m *Manager) BroadcastLogsAndRequests()

func (*Manager) Close ¶

func (m *Manager) Close() error

func (*Manager) ConsumeAndStoreKafkaMessages ¶

func (m *Manager) ConsumeAndStoreKafkaMessages(brokerName string, port int) error

func (*Manager) GetHTTPProxyRequestsForProcess ¶

func (m *Manager) GetHTTPProxyRequestsForProcess(
	processName string,
) ([]*HTTPProxyRequest, error)

func (*Manager) GetHTTPProxyResponsesForProcess ¶

func (m *Manager) GetHTTPProxyResponsesForProcess(
	processName string,
) ([]*HTTPProxyResponse, error)

func (*Manager) GetLogsForProcess ¶

func (m *Manager) GetLogsForProcess(processName string, outputType string) ([]string, error)

func (*Manager) RunHTTPProxy ¶

func (m *Manager) RunHTTPProxy(
	target string,
	listenAddr string,
	processName string,
	stop chan struct{},
) error

func (*Manager) StartManagedKafka ¶

func (m *Manager) StartManagedKafka(
	managedDependencyName string,
	port int,
) error

func (*Manager) StartManagedLocalstack ¶

func (m *Manager) StartManagedLocalstack(
	managedDependencyName string,
	port int,
) error

func (*Manager) StartServicesAndDependencies ¶

func (m *Manager) StartServicesAndDependencies(
	asts []*parser.VClusterAST,
) error

func (*Manager) StopAllProcesses ¶

func (m *Manager) StopAllProcesses()

func (*Manager) Websocket ¶

func (m *Manager) Websocket() *websocket.Broadcaster

type ManagerOption ¶

type ManagerOption func(*Manager)

func WithHTTPPort ¶

func WithHTTPPort(port int) ManagerOption

func WithVerbose ¶

func WithVerbose() ManagerOption

type OutputCallback ¶

type OutputCallback func(string)

Source Files ¶

View all Source files

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