run

Nov 14, 2023

Changes in this version

type LocalServices

+ GetDashboard func() *dashboard.Dashboard

Oct 5, 2023

Changes in this version

type LocalServices

+ GetStorageService func() *RunStorageService

Jul 12, 2023

Changes in this version

type BaseHttpGateway

+ func (s *BaseHttpGateway) GetWebsocketAddresses() map[string]string

type LocalServices

+ Websockets func() map[string]string

type RunStackState

+ func (r *RunStackState) WebsocketsTable(port int) (string, int)

+ type RunWebsocketService struct

+ func NewRunWebsocketService() (*RunWebsocketService, error)

+ func (r *RunWebsocketService) Close(ctx context.Context, socket string, connectionId string) error

+ func (r *RunWebsocketService) RegisterConnection(socket string, connectionId string, connection *websocket.Conn)

+ func (r *RunWebsocketService) Send(ctx context.Context, socket string, connectionId string, message []byte) error

Jul 5, 2023

Changes in this version

type BaseHttpGateway

+ func (s *BaseHttpGateway) GetHttpWorkerAddresses() map[int]string

type LocalServices

+ HttpWorkers func() map[int]string

type RunStackState

+ func (r *RunStackState) HttpTable() (string, int)

+ func (r *RunStackState) Warnings() []string

Jul 2, 2023

Changes in this version

type FunctionOpts

+ Runtime runtime.Runtime

May 12, 2023

Changes in this version

+ type BucketNotification struct

+ Bucket string

+ NotificationPrefixFilter string

+ NotificationType v1.BucketNotificationType

type LocalServices

+ GetDashPort func() *int

type RunResourcesService

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

type RunStackState

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

May 3, 2023

Changes in this version

type LocalServices

+ GetWorkerPool func() pool.WorkerPool

type RunStackState

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

Mar 2, 2023

Changes in this version

+ const DEV_SUB_DIR_COLL

+ const DEV_SUB_DIR_QUEUES

+ const DEV_SUB_DIR_SECRETS

+ func NewQueueService() (queue.QueueService, error)

+ func NewSecretService() (secret.SecretService, error)

+ type BoltDoc struct

+ Id string

+ PartitionKey string

+ SortKey string

+ Value map[string]interface{}

+ func (d BoltDoc) String() string

+ type BoltDocService struct

+ func NewBoltService() (*BoltDocService, error)

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

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

+ func (s *BoltDocService) Query(ctx context.Context, collection *document.Collection, ...) (*document.QueryResult, error)

+ func (s *BoltDocService) QueryStream(ctx context.Context, collection *document.Collection, ...) document.DocumentIterator

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

+ type DevQueueService struct

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

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

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

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

+ type DevSecretService struct

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

+ func (s *DevSecretService) Put(ctx context.Context, sec *secret.Secret, val []byte) (*secret.SecretPutResponse, error)

+ type Item struct

+ Data []byte

+ ID int

Dec 6, 2022

Changes in this version

type BaseHttpGateway

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

+ func (s *BaseHttpGateway) GetTriggerAddress() string

+ func (s *BaseHttpGateway) Refresh() error

type LocalServices

+ Apis func() map[string]string

+ Refresh func() error

+ TriggerAddress func() string

type RunStackState

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

Nov 30, 2022

Changes in this version

+ func NewResources(gatewayUri string) common.ResourceService

type LocalServicesStatus

+ StorageEndpoint string

+ type RunResourcesService struct

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

+ type SeaweedServer struct

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

+ func (m *SeaweedServer) GetApiPort() int

+ func (m *SeaweedServer) Start() error

+ func (m *SeaweedServer) Stop() error

+ type StorageOptions struct

+ AccessKey string

+ Endpoint string

+ SecretKey string

Nov 2, 2022

Changes in this version

type FunctionOpts

+ Name string

type RunStackState

+ func StateFromPool(pool worker.WorkerPool) *RunStackState

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

Oct 6, 2022

Changes in this version

+ const MINIO_ACCESS_KEY_ENV

+ const MINIO_ENDPOINT_ENV

+ const MINIO_SECRET_KEY_ENV

+ func NewStorage() (storage.StorageService, error)

+ type RunStorageService struct

+ func (r *RunStorageService) Delete(bucket string, key string) error

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

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

+ func (r *RunStorageService) Read(bucket string, key string) ([]byte, error)

+ func (r *RunStorageService) Write(bucket string, key string, object []byte) error

Mar 18, 2022

Changes in this version

type FunctionOpts

+ ProjectName string

Feb 23, 2022

Changes in this version

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

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

+ type BaseHttpGateway struct

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

+ func (s *BaseHttpGateway) Stop() error

+ type Function struct

+ func FunctionsFromHandlers(s *stack.Stack) ([]*Function, error)

+ func (f *Function) Name() string

+ func (f *Function) Start() error

+ func (f *Function) Stop() error

+ type FunctionOpts struct

+ ContainerEngine containerengine.ContainerEngine

+ Handler string

+ RunCtx string

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

+ type LocalServices interface

+ Running func() bool

+ Start func(pool worker.WorkerPool) error

+ Status func() *LocalServicesStatus

+ Stop func() error

+ func NewLocalServices(stackName, stackPath string) LocalServices

+ type LocalServicesStatus struct

+ GatewayAddress string

+ MembraneAddress string

+ MinioEndpoint string

+ RunDir string

+ type MinioServer struct

+ func NewMinio(dir string, name string) (*MinioServer, error)

+ func (m *MinioServer) GetApiPort() int

+ func (m *MinioServer) Start() error

+ func (m *MinioServer) Stop() error

+ type RunProcessPool struct

+ func NewRunProcessPool() *RunProcessPool

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

+ func (r *RunProcessPool) Listen(l WorkerListener)

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

+ type RunStackState struct

+ func NewStackState() *RunStackState

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

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

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

+ func (r *RunStackState) UpdateFromWorkerEvent(evt WorkerEvent)

+ type WorkerEvent struct

+ Type WorkerEventType

+ Worker worker.Worker

+ type WorkerEventType string

+ const WorkerEventType_Add

+ const WorkerEventType_Remove

+ type WorkerListener = func(WorkerEvent)

+ type WorkerPoolEventService struct

+ func (s *WorkerPoolEventService) Publish(topic string, event *events.NitricEvent) error