server

package
v0.0.0-...-5db00e0 Latest Latest
Warning

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

Go to latest
Published: Nov 16, 2017 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Database

Database represents the interface to the database used by the scheduler, scaler, etc. Mostly, this exists so it can be mocked during testing.

type Server

type Server struct {
	RPCAddress             string
	HTTPPort               string
	Password               string
	TaskServiceServer      tes.TaskServiceServer
	EventServiceServer     events.EventServiceServer
	SchedulerServiceServer pbs.SchedulerServiceServer
	DisableHTTPCache       bool
	DialOptions            []grpc.DialOption
	Log                    *logger.Logger
}

Server represents a Funnel server. The server handles RPC traffic via gRPC, HTTP traffic for the TES API, and also serves the web dashboard.

func DefaultServer

func DefaultServer(db Database, conf config.Server) *Server

DefaultServer returns a new server instance.

func (*Server) Serve

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

Serve starts the server and does not block. This will open TCP ports for both RPC and HTTP.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL