helper

Documentation

Index

• Variables
• func ByteSliceHasAnyPrefix(s []byte, prefixes ...string) bool
• func ErrCanceled(err error) error
• func ErrFailedPrecondition(err error) error
• func ErrFailedPreconditionf(format string, a ...interface{}) error
• func ErrInternal(err error) error
• func ErrInternalf(format string, a ...interface{}) error
• func ErrInvalidArgument(err error) error
• func ErrInvalidArgumentf(format string, a ...interface{}) error
• func ErrNotFound(err error) error
• func ErrNotFoundf(format string, a ...interface{}) error
• func ErrUnavailable(err error) error
• func ErrUnavailablef(format string, a ...interface{}) error
• func ExtractGitalyServer(ctx context.Context, storageName string) (storage.ServerInfo, error)
• func ExtractGitalyServers(ctx context.Context) (gitalyServersInfo storage.GitalyServers, err error)
• func GrpcCode(err error) codes.Code
• func IncomingToOutgoing(ctx context.Context) context.Context
• func InjectGitalyServers(ctx context.Context, name, address, token string) (context.Context, error)
• func IsNumber(s []byte) bool
• func OutgoingToIncoming(ctx context.Context) context.Context
• func RepoPathEqual(a, b repository.GitRepo) bool
• func SanitizeError(err error) error
• func SanitizeString(str string) string
• func SuppressCancellation(ctx context.Context) context.Context
• func UnquoteBytes(s []byte) []byte
• type ManualTicker
  • func NewCountTicker(n int, callback func()) *ManualTicker
  • func NewManualTicker() *ManualTicker
  • func (mt *ManualTicker) C() <-chan time.Time
  • func (mt *ManualTicker) Reset()
  • func (mt *ManualTicker) Stop()
  • func (mt *ManualTicker) Tick()
• type Ticker
  • func NewTimerTicker(interval time.Duration) Ticker

Variables

var ErrEmptyMetadata = errors.New("empty metadata")

ErrEmptyMetadata indicates that the gRPC metadata was not found in the context

var MaxCommitOrTagMessageSize = 10 * 1024

MaxCommitOrTagMessageSize is the threshold for a commit/tag message, if exceeded then message is truncated and it's up to the client to request it in full separately.

Functions

func ByteSliceHasAnyPrefix

func ByteSliceHasAnyPrefix(s []byte, prefixes ...string) bool

ByteSliceHasAnyPrefix tests whether the byte slice s begins with any of the prefixes.

func ErrCanceled

func ErrCanceled(err error) error

ErrCanceled wraps err with codes.Canceled, unless err is already a gRPC error.

func ErrFailedPrecondition

func ErrFailedPrecondition(err error) error

ErrFailedPrecondition wraps err with codes.FailedPrecondition, unless err is already a gRPC error.

func ErrFailedPreconditionf

func ErrFailedPreconditionf(format string, a ...interface{}) error

ErrFailedPreconditionf wraps a formatted error with codes.FailedPrecondition, unless the formatted error is a wrapped gRPC error.

func ErrInternal

func ErrInternal(err error) error

ErrInternal wraps err with codes.Internal, unless err is already a gRPC error.

func ErrInternalf

func ErrInternalf(format string, a ...interface{}) error

ErrInternalf wraps a formatted error with codes.Internal, unless the formatted error is a wrapped gRPC error.

func ErrInvalidArgument

func ErrInvalidArgument(err error) error

ErrInvalidArgument wraps err with codes.InvalidArgument, unless err is already a gRPC error.

func ErrInvalidArgumentf

func ErrInvalidArgumentf(format string, a ...interface{}) error

ErrInvalidArgumentf wraps a formatted error with codes.InvalidArgument, unless the formatted error is a wrapped gRPC error.

func ErrNotFound

func ErrNotFound(err error) error

ErrNotFound wraps error with codes.NotFound, unless err is already a gRPC error.

func ErrNotFoundf

func ErrNotFoundf(format string, a ...interface{}) error

ErrNotFoundf wraps a formatted error with codes.NotFound, unless the formatted error is a wrapped gRPC error.

func ErrUnavailable

func ErrUnavailable(err error) error

ErrUnavailable wraps err with codes.Unavailable, unless err is already a gRPC error.

func ErrUnavailablef

func ErrUnavailablef(format string, a ...interface{}) error

ErrUnavailablef wraps a formatted error with codes.Unavailable, unless the formatted error is a wrapped gRPC error.

func ExtractGitalyServer

func ExtractGitalyServer(ctx context.Context, storageName string) (storage.ServerInfo, error)

ExtractGitalyServer extracts server information for a specific storage

func ExtractGitalyServers

func ExtractGitalyServers(ctx context.Context) (gitalyServersInfo storage.GitalyServers, err error)

ExtractGitalyServers extracts `storage.GitalyServers` from an incoming context.

func GrpcCode

func GrpcCode(err error) codes.Code

GrpcCode emulates the old grpc.Code function: it translates errors into codes.Code values.

func IncomingToOutgoing

func IncomingToOutgoing(ctx context.Context) context.Context

IncomingToOutgoing creates an outgoing context out of an incoming context with the same storage metadata

func InjectGitalyServers

func InjectGitalyServers(ctx context.Context, name, address, token string) (context.Context, error)

InjectGitalyServers injects gitaly-servers metadata into an outgoing context

func IsNumber

func IsNumber(s []byte) bool

IsNumber tests whether the byte slice s contains only digits or not

func OutgoingToIncoming

func OutgoingToIncoming(ctx context.Context) context.Context

OutgoingToIncoming creates an incoming context out of an outgoing context with the same storage metadata

func RepoPathEqual

func RepoPathEqual(a, b repository.GitRepo) bool

RepoPathEqual compares if two repositories are in the same location

func SanitizeError

func SanitizeError(err error) error

SanitizeError does the same thing as SanitizeString but for error types

func SanitizeString

func SanitizeString(str string) string

SanitizeString will clean password and tokens from URLs, and replace them with [FILTERED].

func SuppressCancellation

func SuppressCancellation(ctx context.Context) context.Context

SuppressCancellation returns a context that suppresses cancellation or expiration of the parent context.

func UnquoteBytes

func UnquoteBytes(s []byte) []byte

UnquoteBytes removes surrounding double-quotes from a byte slice returning a new slice if they exist, otherwise it returns the same byte slice passed.

Types

type ManualTicker

type ManualTicker struct {
	StopFunc  func()
	ResetFunc func()
	// contains filtered or unexported fields
}

ManualTicker implements a ticker that ticks when Tick is called. Stop and Reset functions call the provided functions.

func NewCountTicker

func NewCountTicker(n int, callback func()) *ManualTicker

NewCountTicker returns a ManualTicker with a ResetFunc that calls the provided callback on Reset call after it has been called N times.

func NewManualTicker

func NewManualTicker() *ManualTicker

NewManualTicker returns a Ticker that can be manually controlled.

func (*ManualTicker) C

func (mt *ManualTicker) C() <-chan time.Time

func (*ManualTicker) Reset

func (mt *ManualTicker) Reset()

func (*ManualTicker) Stop

func (mt *ManualTicker) Stop()

func (*ManualTicker) Tick

func (mt *ManualTicker) Tick()

type Ticker

type Ticker interface {
	C() <-chan time.Time
	Stop()
	Reset()
}

Ticker ticks on the channel returned by C to signal something.

func NewTimerTicker

func NewTimerTicker(interval time.Duration) Ticker

NewTimerTicker returns a Ticker that ticks after the specified interval has passed since the previous Reset call.