substrate

Documentation

Index

• type ErrorCallback
• type HTTPProxyRequest
• type HTTPProxyResponse
• type ManagedProcess
• type Manager
  • func NewManager(dbPath string, opts ...ManagerOption) (*Manager, error)
  • func (m *Manager) AddWorkingDirectoryUpward(serviceName, path string, verbose bool) error
  • func (m *Manager) BroadcastLogsAndRequests()
  • func (m *Manager) Close() error
  • func (m *Manager) ConsumeAndStoreKafkaMessages(brokerName string, port int) error
  • func (m *Manager) GetHTTPProxyRequestsForProcess(processName string) ([]*HTTPProxyRequest, error)
  • func (m *Manager) GetHTTPProxyResponsesForProcess(processName string) ([]*HTTPProxyResponse, error)
  • func (m *Manager) GetLogsForProcess(processName string, outputType string) ([]string, error)
  • func (m *Manager) RunHTTPProxy(target string, listenAddr string, processName string, stop chan struct{}) error
  • func (m *Manager) StartManagedKafka(managedDependencyName string, port int) error
  • func (m *Manager) StartManagedLocalstack(managedDependencyName string, port int) error
  • func (m *Manager) StartServicesAndDependencies(asts []*parser.VClusterAST) error
  • func (m *Manager) StopAllProcesses()
  • func (m *Manager) Websocket() *websocket.Broadcaster
• type ManagerOption
  • func WithHTTPPort(port int) ManagerOption
  • func WithVerbose() ManagerOption
• type OutputCallback

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)