runtime

README

ownCloud Infinite Scale: Runtime

Pman is a slim utility library for supervising long-running processes. It can be embedded or used as a cli command.

When used as a CLI command it relays actions to a running runtime.

Usage

Start a runtime

package main
import "github.com/owncloud/ocis/ocis/pkg/runtime/service"

func main() {
    service.Start()
}

Start sending messages

Example

package main

import (
	"fmt"
	"github.com/owncloud/ocis/ocis/pkg/runtime/process"
	"github.com/owncloud/ocis/ocis/pkg/runtime/service"
	"github.com/rs/zerolog/log"
	"os"
	"os/signal"
	"syscall"
	"time"
)

func main() {
	s := service.NewService()
	var c = make(chan os.Signal, 1)
	var o int

	signal.Notify(c, syscall.SIGINT, syscall.SIGTERM)
	if err := s.Start(process.NewProcEntry("ocs", nil, "ocs"), &o); err != nil {
		os.Exit(1)
	}

	time.AfterFunc(3*time.Second, func() {
		var acc = "ocs"
		fmt.Printf(fmt.Sprintf("shutting down service: %s", acc))
		if err := s.Controller.Kill(&acc); err != nil {
			log.Fatal()
		}
		os.Exit(0)
	})

	for {
		select {
		case <-c:
			return
		}
	}
}

Run the above example with RUNTIME_KEEP_ALIVE=true and with no RUNTIME_KEEP_ALIVE set to see its behavior. It requires an oCIS binary present in your $PATH for it to work.

Documentation

Index

• type Option
  • func Context(c *cli.Context) Option
  • func Services(s []string) Option
• type Options
• type Runtime
  • func New(cfg *config.Config) Runtime
  • func (r *Runtime) Start() error

Types

type Option

type Option func(o *Options)

Option undocumented

func Context

func Context(c *cli.Context) Option

Context option

func Services

func Services(s []string) Option

Services option

type Options

type Options struct {
	Services []string
	Logger   log.Logger
	Context  *cli.Context
}

Options is a runtime option

type Runtime

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

Runtime represents an oCIS runtime environment.

func New

func New(cfg *config.Config) Runtime

New creates a new oCIS + micro runtime

func (*Runtime) Start

func (r *Runtime) Start() error

Start rpc runtime