rubyserver

Documentation

Index

• Variables
• func CommitServiceClient(ctx context.Context) (pb.CommitServiceClient, error)
• func DiffServiceClient(ctx context.Context) (pb.DiffServiceClient, error)
• func Proxy(recvSend func() error) (err error)
• func RefServiceClient(ctx context.Context) (pb.RefServiceClient, error)
• func SetHeaders(ctx context.Context, repo *pb.Repository) (context.Context, error)
• type Server
  • func Start() (*Server, 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 CommitServiceClient

func 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 DiffServiceClient

func 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 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 RefServiceClient

func 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 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
}

Server represents a gitaly-ruby helper process.

func Start

func Start() (*Server, error)

Start spawns the Ruby server.

func (*Server) Stop

func (s *Server) Stop()

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