run

package
v1.14.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 30, 2022 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewEvents 

func NewEvents(pool worker.WorkerPool) (events.EventService, error)

Create new Dev EventService

func NewGateway 

func NewGateway(address string) (gateway.GatewayService, error)

Create new HTTP gateway XXX: No External Args for function atm (currently the plugin loader does not pass any argument information)

func NewResources added in v1.14.0 

func NewResources(gatewayUri string) common.ResourceService

func NewStorage added in v1.11.0 

func NewStorage(opts StorageOptions) (storage.StorageService, error)

Types

type BaseHttpGateway 

type BaseHttpGateway struct {
	gateway.UnimplementedGatewayPlugin
	// contains filtered or unexported fields
}

func (*BaseHttpGateway) Start 

func (s *BaseHttpGateway) Start(pool worker.WorkerPool) error

func (*BaseHttpGateway) Stop 

func (s *BaseHttpGateway) Stop() error

type Function 

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

func FunctionsFromHandlers 

func FunctionsFromHandlers(p *project.Project) ([]*Function, error)

func (*Function) Name 

func (f *Function) Name() string

func (*Function) Start 

func (f *Function) Start(envMap map[string]string) error

func (*Function) Stop 

func (f *Function) Stop() error

type FunctionOpts 

type FunctionOpts struct {
	Name            string
	ProjectName     string
	Handler         string
	RunCtx          string
	ContainerEngine containerengine.ContainerEngine
}

type HttpMiddleware 

type HttpMiddleware func(*fasthttp.RequestCtx, worker.WorkerPool) bool

type LocalServices 

type LocalServices interface {
	Start(pool worker.WorkerPool) error
	Stop() error
	Running() bool
	Status() *LocalServicesStatus
}

func NewLocalServices 

func NewLocalServices(s *project.Project) LocalServices

type LocalServicesStatus 

type LocalServicesStatus struct {
	RunDir          string `yaml:"runDir"`
	GatewayAddress  string `yaml:"gatewayAddress"`
	MembraneAddress string `yaml:"membraneAddress"`
	StorageEndpoint string `yaml:"storageEndpoint"`
}

type RunProcessPool 

type RunProcessPool struct {
	worker.WorkerPool
	// contains filtered or unexported fields
}

func NewRunProcessPool 

func NewRunProcessPool() *RunProcessPool

func (*RunProcessPool) AddWorker 

func (r *RunProcessPool) AddWorker(w worker.Worker) error

func (*RunProcessPool) Listen 

func (r *RunProcessPool) Listen(l WorkerListener)

func (*RunProcessPool) RemoveWorker 

func (r *RunProcessPool) RemoveWorker(w worker.Worker) error

type RunResourcesService added in v1.14.0 

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

func (*RunResourcesService) Details added in v1.14.0 

func (r *RunResourcesService) Details(ctx context.Context, typ common.ResourceType, name string) (*common.DetailsResponse[any], error)

type RunStackState 

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

func NewStackState 

func NewStackState() *RunStackState

func StateFromPool added in v1.12.0 

func StateFromPool(pool worker.WorkerPool) *RunStackState

func (*RunStackState) ApiTable 

func (r *RunStackState) ApiTable(port int) (string, int)

func (*RunStackState) SchedulesTable 

func (r *RunStackState) SchedulesTable(port int) (string, int)

func (*RunStackState) Tables added in v1.12.0 

func (r *RunStackState) Tables(port int) string

func (*RunStackState) TopicTable 

func (r *RunStackState) TopicTable(port int) (string, int)

func (*RunStackState) UpdateFromWorkerEvent 

func (r *RunStackState) UpdateFromWorkerEvent(evt WorkerEvent)

type RunStorageService added in v1.11.0 

type RunStorageService struct {
	storage.StorageService
	// contains filtered or unexported fields
}

func (*RunStorageService) Delete added in v1.11.0 

func (r *RunStorageService) Delete(ctx context.Context, bucket string, key string) error

func (*RunStorageService) ListFiles added in v1.11.0 

func (r *RunStorageService) ListFiles(ctx context.Context, bucket string) ([]*storage.FileInfo, error)

func (*RunStorageService) PreSignUrl added in v1.11.0 

func (r *RunStorageService) PreSignUrl(ctx context.Context, bucket string, key string, operation storage.Operation, expiry uint32) (string, error)

func (*RunStorageService) Read added in v1.11.0 

func (r *RunStorageService) Read(ctx context.Context, bucket string, key string) ([]byte, error)

func (*RunStorageService) Write added in v1.11.0 

func (r *RunStorageService) Write(ctx context.Context, bucket string, key string, object []byte) error

type SeaweedServer added in v1.14.0 

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

func NewSeaweed added in v1.14.0 

func NewSeaweed(runDir string) (*SeaweedServer, error)

func (*SeaweedServer) GetApiPort added in v1.14.0 

func (m *SeaweedServer) GetApiPort() int

func (*SeaweedServer) Start added in v1.14.0 

func (m *SeaweedServer) Start() error

Start - Start the local SeaweedFS server

func (*SeaweedServer) Stop added in v1.14.0 

func (m *SeaweedServer) Stop() error

type StorageOptions added in v1.14.0 

type StorageOptions struct {
	AccessKey string
	SecretKey string
	Endpoint  string
}

type WorkerEvent 

type WorkerEvent struct {
	Type   WorkerEventType
	Worker worker.Worker
}

type WorkerEventType 

type WorkerEventType string
const (
	WorkerEventType_Add    WorkerEventType = "add"
	WorkerEventType_Remove WorkerEventType = "remove"
)

type WorkerListener 

type WorkerListener = func(WorkerEvent)

type WorkerPoolEventService 

type WorkerPoolEventService struct {
	events.UnimplementedeventsPlugin
	// contains filtered or unexported fields
}

func (*WorkerPoolEventService) Publish 

func (s *WorkerPoolEventService) Publish(ctx context.Context, topic string, delay int, event *events.NitricEvent) error

Publish a message to a given topic

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.