rubyserver

package
v1.87.0 Latest Latest
Warning

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

Go to latest
Published: Feb 17, 2020 License: MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// ConnectTimeout is the timeout for establishing a connection to the gitaly-ruby process.
	ConnectTimeout = 40 * time.Second
)
View Source
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 added in v0.31.0

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 added in v0.45.0

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 *gitalypb.Repository) (context.Context, error)

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

func SetHeadersWithoutRepoCheck added in v0.68.0

func SetHeadersWithoutRepoCheck(ctx context.Context, repo *gitalypb.Repository) (context.Context, error)

SetHeadersWithoutRepoCheck adds headers that tell gitaly-ruby the full path to the repository. It is not an error if the repository does not yet exist. This can be used on RPC calls that will create a repository.

Types

type CloseSender added in v0.45.0

type CloseSender interface {
	CloseSend() error
}

CloseSender captures the CloseSend method from gRPC streams.

type Server added in v0.34.0

type Server struct {
	// contains filtered or unexported fields
}

Server represents a gitaly-ruby helper process.

func (*Server) BlobServiceClient added in v0.71.0

func (s *Server) BlobServiceClient(ctx context.Context) (gitalypb.BlobServiceClient, error)

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

func (*Server) CommitServiceClient added in v0.39.0

func (s *Server) CommitServiceClient(ctx context.Context) (gitalypb.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) ConflictsServiceClient added in v0.60.0

func (s *Server) ConflictsServiceClient(ctx context.Context) (gitalypb.ConflictsServiceClient, error)

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

func (*Server) DiffServiceClient added in v0.39.0

func (s *Server) DiffServiceClient(ctx context.Context) (gitalypb.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 added in v0.41.0

func (s *Server) OperationServiceClient(ctx context.Context) (gitalypb.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 added in v0.39.0

func (s *Server) RefServiceClient(ctx context.Context) (gitalypb.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) RemoteServiceClient added in v0.61.0

func (s *Server) RemoteServiceClient(ctx context.Context) (gitalypb.RemoteServiceClient, error)

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

func (*Server) RepositoryServiceClient added in v0.41.0

func (s *Server) RepositoryServiceClient(ctx context.Context) (gitalypb.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) Start added in v1.62.0

func (s *Server) Start() error

Start spawns the Ruby server.

func (*Server) Stop added in v0.34.0

func (s *Server) Stop()

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

func (*Server) WikiServiceClient added in v0.48.0

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

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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