server

Documentation

Index

• func DoWithContext(ctx context.Context, f func() error) error
• func DoWithTimeout(f func() error, d time.Duration) error
• func Recv(ctx context.Context, fn func() (*browsercontrollerV1.DoRequest, error)) (*browsercontrollerV1.DoRequest, error)
• func Send(fn func(*browsercontrollerV1.DoReply) error, ...) error
• type ApiServer
  • func NewApiServer(listenInterface string, listenPort int, sessions *session.Registry, ...) *ApiServer
  • func (a *ApiServer) Close()
  • func (a *ApiServer) Do(stream browsercontrollerV1.BrowserController_DoServer) (err error)
  • func (a *ApiServer) Start() error

Functions

func DoWithContext

func DoWithContext(ctx context.Context, f func() error) error

DoWithContext runs f and returns its error. If the context is cancelled or times out first, it returns the context's error instead.

func DoWithTimeout

func DoWithTimeout(f func() error, d time.Duration) error

DoWithTimeout runs f and returns its error. If the deadline d elapses first, it returns a grpc DeadlineExceeded error instead.

func Recv

func Recv(ctx context.Context, fn func() (*browsercontrollerV1.DoRequest, error)) (*browsercontrollerV1.DoRequest, error)

func Send

func Send(fn func(*browsercontrollerV1.DoReply) error, reply *browsercontrollerV1.DoReply) error

Types

type ApiServer

type ApiServer struct {
	browsercontrollerV1.UnimplementedBrowserControllerServer
	// contains filtered or unexported fields
}

ApiServer is the gRPC api endpoint for the Browser Controller

func NewApiServer

func NewApiServer(listenInterface string, listenPort int, sessions *session.Registry, robotsEvaluator robotsevaluator.RobotsEvaluator, logWriter logwriter.LogWriter) *ApiServer

NewApiServer returns a new instance of ApiServer listening on the given port

func (*ApiServer) Close

func (a *ApiServer) Close()

func (*ApiServer) Do

func (a *ApiServer) Do(stream browsercontrollerV1.BrowserController_DoServer) (err error)

Implements BrowserController

func (*ApiServer) Start

func (a *ApiServer) Start() error