rubyserver

Documentation

Index

• Variables
• func Proxy(recvSend func() error) (err error)
• func ProxyBidi(requestFunc func() error, requestStream CloseSender, responseFunc func() error) error
• func SetHeaders(ctx context.Context, repo *pb.Repository) (context.Context, error)
• type CloseSender
• 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()
  • func (s *Server) WikiServiceClient(ctx context.Context) (pb.WikiServiceClient, error)

Variables

var (

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

var ProxyHeaderWhitelist = []string{"gitaly-servers"}

ProxyHeaderWhitelist is the list of http/2 headers that will be forwarded as-is to gitaly-ruby.

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 ProxyBidi

func ProxyBidi(requestFunc func() error, requestStream CloseSender, responseFunc func() error) error

ProxyBidi works like Proxy but runs multiple callbacks simultaneously. It returns immediately if proxying one of the callbacks fails. If the response stream is done, ProxyBidi returns immediately without waiting for the client stream to finish proxying.

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 CloseSender

type CloseSender interface {
	CloseSend() error
}

CloseSender captures the CloseSend method from gRPC streams.

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.

func (*Server) WikiServiceClient

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

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