rubyserver

Documentation

Index

• Variables
• func Proxy(recvSend func() error) (err error)
• func SetHeaders(ctx context.Context, repo *pb.Repository) (context.Context, error)
• type Server
  • func Start() (*Server, error)
  • func (s *Server) CommitServiceClient(ctx context.Context) (pb.CommitServiceClient, error)
  • func (s *Server) DiffServiceClient(ctx context.Context) (pb.DiffServiceClient, error)
  • func (s *Server) OperationServiceClient(ctx context.Context) (pb.OperationServiceClient, error)
  • func (s *Server) RefServiceClient(ctx context.Context) (pb.RefServiceClient, error)
  • func (s *Server) RepositoryServiceClient(ctx context.Context) (pb.RepositoryServiceClient, error)
  • func (s *Server) Stop()

Variables

var (

	// ConnectTimeout is the timeout for establishing a connection to the gitaly-ruby process.
	ConnectTimeout = 20 * time.Second
)

Functions

func Proxy

func Proxy(recvSend func() error) (err error)

Proxy calls recvSend until it receives an error. The error is returned to the caller unless it is io.EOF.

func SetHeaders

func SetHeaders(ctx context.Context, repo *pb.Repository) (context.Context, error)

SetHeaders adds headers that tell gitaly-ruby the full path to the repository.

Types

type Server

type Server struct {
	*supervisor.Process
	// contains filtered or unexported fields
}

Server represents a gitaly-ruby helper process.

func Start

func Start() (*Server, error)

Start spawns the Ruby server.

func (*Server) CommitServiceClient

func (s *Server) CommitServiceClient(ctx context.Context) (pb.CommitServiceClient, error)

CommitServiceClient returns a CommitServiceClient instance that is configured to connect to the running Ruby server. This assumes Start() has been called already.

func (*Server) DiffServiceClient

func (s *Server) DiffServiceClient(ctx context.Context) (pb.DiffServiceClient, error)

DiffServiceClient returns a DiffServiceClient instance that is configured to connect to the running Ruby server. This assumes Start() has been called already.

func (*Server) OperationServiceClient

func (s *Server) OperationServiceClient(ctx context.Context) (pb.OperationServiceClient, error)

OperationServiceClient returns a OperationServiceClient instance that is configured to connect to the running Ruby server. This assumes Start() has been called already.

func (*Server) RefServiceClient

func (s *Server) RefServiceClient(ctx context.Context) (pb.RefServiceClient, error)

RefServiceClient returns a RefServiceClient instance that is configured to connect to the running Ruby server. This assumes Start() has been called already.

func (*Server) RepositoryServiceClient

func (s *Server) RepositoryServiceClient(ctx context.Context) (pb.RepositoryServiceClient, error)

RepositoryServiceClient returns a RefServiceClient instance that is configured to connect to the running Ruby server. This assumes Start() has been called already.

func (*Server) Stop

func (s *Server) Stop()

Stop shuts down the gitaly-ruby helper process and cleans up resources.