runtime

Documentation

Index

• type Instance
  • func (i *Instance) Load() error
  • func (r *Instance) Query(ctx context.Context, stmt *infra.Statement) (*sqlx.Rows, error)
• type Runtime
  • func New(db metadata.DB, logger zerolog.Logger) *Runtime
  • func (r *Runtime) CreateInstance(driver string, dsn string) (*Instance, error)
  • func (r *Runtime) InstanceFromID(id uuid.UUID) *Instance
• type Server
  • func NewServer(opts *ServerOptions, runtime *Runtime, logger zerolog.Logger) *Server
  • func (s *Server) CreateInstance(ctx context.Context, req *proto.CreateInstanceRequest) (*proto.CreateInstanceResponse, error)
  • func (s *Server) MetricsViewMeta(ctx context.Context, req *proto.MetricsViewMetaRequest) (*proto.MetricsViewMetaResponse, error)
  • func (s *Server) MetricsViewTimeSeries(ctx context.Context, req *proto.MetricsViewTimeSeriesRequest) (*proto.MetricsViewTimeSeriesResponse, error)
  • func (s *Server) MetricsViewToplist(ctx context.Context, req *proto.MetricsViewToplistRequest) (*proto.MetricsViewToplistResponse, error)
  • func (s *Server) Ping(ctx context.Context, req *proto.PingRequest) (*proto.PingResponse, error)
  • func (s *Server) QueryDirect(ctx context.Context, req *proto.QueryDirectRequest) (*proto.QueryDirectResponse, error)
  • func (s *Server) Serve(ctx context.Context) error
• type ServerOptions

Types

type Instance

type Instance struct {
	ID   uuid.UUID
	Conn infra.Connection
}

Instance represents a single Rill project (call it session, release, kernel, environment, ...)

func (*Instance) Load

func (i *Instance) Load() error

Load looks for the instance and connects to its infra

func (*Instance) Query

func (r *Instance) Query(ctx context.Context, stmt *infra.Statement) (*sqlx.Rows, error)

type Runtime

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

Runtime is a data infra proxy and orchestrator. It's a multi-tenant service that can manage many projects. Each project is represented by an Instance. It supports scale-out when no local infra drivers are registered (i.e. not DuckDB).

func New

func New(db metadata.DB, logger zerolog.Logger) *Runtime

New creates a Runtime

func (*Runtime) CreateInstance

func (r *Runtime) CreateInstance(driver string, dsn string) (*Instance, error)

CreateInstance creates a new instance

func (*Runtime) InstanceFromID

func (r *Runtime) InstanceFromID(id uuid.UUID) *Instance

InstanceFromID prepares (but doesn't load) and existing instance. Call Load on the instance to connect.

type Server

type Server struct {
	proto.UnimplementedRuntimeServiceServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(opts *ServerOptions, runtime *Runtime, logger zerolog.Logger) *Server

func (*Server) CreateInstance

func (s *Server) CreateInstance(ctx context.Context, req *proto.CreateInstanceRequest) (*proto.CreateInstanceResponse, error)

CreateInstance implements RuntimeService

func (*Server) MetricsViewMeta

func (s *Server) MetricsViewMeta(ctx context.Context, req *proto.MetricsViewMetaRequest) (*proto.MetricsViewMetaResponse, error)

MetricsViewMeta implements RuntimeService

func (*Server) MetricsViewTimeSeries

func (s *Server) MetricsViewTimeSeries(ctx context.Context, req *proto.MetricsViewTimeSeriesRequest) (*proto.MetricsViewTimeSeriesResponse, error)

MetricsViewTimeSeries implements RuntimeService

func (*Server) MetricsViewToplist

func (s *Server) MetricsViewToplist(ctx context.Context, req *proto.MetricsViewToplistRequest) (*proto.MetricsViewToplistResponse, error)

MetricsViewToplist implements RuntimeService

func (*Server) Ping

func (s *Server) Ping(ctx context.Context, req *proto.PingRequest) (*proto.PingResponse, error)

Ping implements RuntimeService

func (*Server) QueryDirect

func (s *Server) QueryDirect(ctx context.Context, req *proto.QueryDirectRequest) (*proto.QueryDirectResponse, error)

QueryDirect implements RuntimeService

func (*Server) Serve

func (s *Server) Serve(ctx context.Context) error

type ServerOptions

type ServerOptions struct {
	HTTPPort int
	GRPCPort int
}