run

package
v1.18.0 Latest Latest
Warning

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

 Go to latest Published: May 12, 2023 License: Apache-2.0 Imports: 56 Imported by: 0

Documentation

Index

Constants

View Source 
const DEV_SUB_DIR_COLL = "./collections/"
View Source 
const DEV_SUB_DIR_QUEUES = "./queues/"
View Source 
const DEV_SUB_DIR_SECRETS = "./secrets/"

Variables

This section is empty.

Functions

func NewEvents 

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

Create new Dev EventService

func NewQueueService added in v1.15.0 

func NewQueueService() (queue.QueueService, error)

func NewResources added in v1.14.0 

func NewResources(ls *localServices, isStart bool) common.ResourceService

func NewSecretService added in v1.15.0 

func NewSecretService() (secret.SecretService, error)

Create new secret store

Types

type BaseHttpGateway 

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

func NewGateway 

func NewGateway() (*BaseHttpGateway, error)

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

func (*BaseHttpGateway) GetApiAddresses added in v1.14.1 

func (s *BaseHttpGateway) GetApiAddresses() map[string]string

func (*BaseHttpGateway) GetTriggerAddress added in v1.14.1 

func (s *BaseHttpGateway) GetTriggerAddress() string

GetTriggerAddress - Returns the address built-in nitric services this can be used to publishing messages to topics or triggering schedules

func (*BaseHttpGateway) Refresh added in v1.14.1 

func (s *BaseHttpGateway) Refresh() error

Update the gateway and API based on the worker pool

func (*BaseHttpGateway) Start 

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

func (*BaseHttpGateway) Stop 

func (s *BaseHttpGateway) Stop() error

type BoltDoc added in v1.15.0 

type BoltDoc struct {
	Id           string `storm:"id"`
	PartitionKey string `storm:"index"`
	SortKey      string `storm:"index"`
	Value        map[string]interface{}
}

func (BoltDoc) String added in v1.15.0 

func (d BoltDoc) String() string

type BoltDocService added in v1.15.0 

type BoltDocService struct {
	document.UnimplementedDocumentPlugin
	// contains filtered or unexported fields
}

func NewBoltService added in v1.15.0 

func NewBoltService() (*BoltDocService, error)

New - Create a new dev KV plugin

func (*BoltDocService) Delete added in v1.15.0 

func (s *BoltDocService) Delete(ctx context.Context, key *document.Key) error

func (*BoltDocService) Get added in v1.15.0 

func (s *BoltDocService) Get(ctx context.Context, key *document.Key) (*document.Document, error)

func (*BoltDocService) Query added in v1.15.0 

func (s *BoltDocService) Query(ctx context.Context, collection *document.Collection, expressions []document.QueryExpression, limit int, pagingToken map[string]string) (*document.QueryResult, error)

func (*BoltDocService) QueryStream added in v1.15.0 

func (s *BoltDocService) QueryStream(ctx context.Context, collection *document.Collection, expressions []document.QueryExpression, limit int) document.DocumentIterator

func (*BoltDocService) Set added in v1.15.0 

func (s *BoltDocService) Set(ctx context.Context, key *document.Key, content map[string]interface{}) error

type BucketNotification added in v1.18.0 

type BucketNotification struct {
	Bucket                   string
	NotificationType         v1.BucketNotificationType
	NotificationPrefixFilter string
}

type DevQueueService added in v1.15.0 

type DevQueueService struct {
	queue.UnimplementedQueuePlugin
	// contains filtered or unexported fields
}

func (*DevQueueService) Complete added in v1.15.0 

func (s *DevQueueService) Complete(ctx context.Context, queue string, leaseId string) error

Completes a previously popped queue item

func (*DevQueueService) Receive added in v1.15.0 

func (s *DevQueueService) Receive(ctx context.Context, options queue.ReceiveOptions) ([]queue.NitricTask, error)

func (*DevQueueService) Send added in v1.15.0 

func (s *DevQueueService) Send(ctx context.Context, queue string, task queue.NitricTask) error

func (*DevQueueService) SendBatch added in v1.15.0 

func (s *DevQueueService) SendBatch(ctx context.Context, q string, tasks []queue.NitricTask) (*queue.SendBatchResponse, error)

type DevSecretService added in v1.15.0 

type DevSecretService struct {
	secret.UnimplementedSecretPlugin
	// contains filtered or unexported fields
}

func (*DevSecretService) Access added in v1.15.0 

func (s *DevSecretService) Access(ctx context.Context, sv *secret.SecretVersion) (*secret.SecretAccessResponse, error)

func (*DevSecretService) Put added in v1.15.0 

func (s *DevSecretService) Put(ctx context.Context, sec *secret.Secret, val []byte) (*secret.SecretPutResponse, 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, pool.WorkerPool) bool

type Item added in v1.15.0 

type Item struct {
	ID   int `storm:"id,increment"` // primary key with auto increment
	Data []byte
}

type LocalServices 

type LocalServices interface {
	Start(pool pool.WorkerPool) error
	Stop() error
	Running() bool
	Status() *LocalServicesStatus
	Refresh() error
	Apis() map[string]string
	TriggerAddress() string
	GetWorkerPool() pool.WorkerPool
	GetDashPort() *int
}

func NewLocalServices 

func NewLocalServices(s *project.Project, isStart bool, dash *dashboard.Dashboard) 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 {
	pool.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) Declare added in v1.18.0 

func (r *RunResourcesService) Declare(ctx context.Context, req common.ResourceDeclareRequest) error

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 (*RunStackState) ApiTable 

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

func (*RunStackState) BucketNotificationsTable added in v1.18.0 

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

func (*RunStackState) DashboardTable added in v1.16.0 

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

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, dashPort int) string

func (*RunStackState) TopicTable 

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

func (*RunStackState) Update added in v1.14.1 

func (r *RunStackState) Update(workerPool pool.WorkerPool, ls LocalServices)

type RunStorageService added in v1.11.0 

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

func NewStorage added in v1.11.0 

func NewStorage(opts StorageOptions, pool pool.WorkerPool) (*RunStorageService, error)

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.