The highest tagged major version is
Documentation
¶
Index ¶
- Variables
- func ByteSliceHasAnyPrefix(s []byte, prefixes ...string) bool
- func CheckClockSync(ntpHost string, driftThreshold time.Duration) (bool, error)
- func ErrAborted(err error) error
- func ErrAbortedf(format string, a ...interface{}) error
- func ErrAlreadyExists(err error) error
- func ErrAlreadyExistsf(format string, a ...interface{}) error
- func ErrCanceled(err error) error
- func ErrCanceledf(format string, a ...interface{}) error
- func ErrDeadlineExceeded(err error) error
- func ErrDeadlineExceededf(format string, a ...interface{}) 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 ErrPermissionDenied(err error) error
- func ErrPermissionDeniedf(format string, a ...interface{}) error
- func ErrUnavailable(err error) error
- func ErrUnavailablef(format string, a ...interface{}) error
- func ErrWithDetails(err error, details ...proto.Message) (error, error)
- func GrpcCode(err error) codes.Code
- func IsNumber(s []byte) bool
- 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 CountingWriter
- type ManualTicker
- type Ticker
Constants ¶
This section is empty.
Variables ¶
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 ¶
ByteSliceHasAnyPrefix tests whether the byte slice s begins with any of the prefixes.
func CheckClockSync ¶
CheckClockSync checks if machine clock has allowed drift threshold compare to NTP service. ntpHost is a URL of the NTP service to query, if not set the default pool.ntp.org is used. driftThreshold is a time duration that is considered acceptable time offset.
func ErrAborted ¶
ErrAborted wraps err with codes.Aborted, unless err is already a gRPC error.
func ErrAbortedf ¶
ErrAbortedf wraps a formatted error with codes.Aborted, unless the formatted error is a wrapped gRPC error.
func ErrAlreadyExists ¶
ErrAlreadyExists wraps err with codes.AlreadyExists, unless err is already a gRPC error.
func ErrAlreadyExistsf ¶
ErrAlreadyExistsf wraps a formatted error with codes.AlreadyExists, unless the formatted error is a wrapped gRPC error.
func ErrCanceled ¶
ErrCanceled wraps err with codes.Canceled, unless err is already a gRPC error.
func ErrCanceledf ¶ added in v15.3.0
ErrCanceledf wraps a formatted error with codes.Canceled, unless the formatted error is a wrapped gRPC error.
func ErrDeadlineExceeded ¶ added in v15.3.0
ErrDeadlineExceeded wraps err with codes.DeadlineExceeded, unless err is already a gRPC error.
func ErrDeadlineExceededf ¶ added in v15.3.0
ErrDeadlineExceededf wraps a formatted error with codes.DeadlineExceeded, unless the formatted error is a wrapped gRPC error.
func ErrFailedPrecondition ¶
ErrFailedPrecondition wraps err with codes.FailedPrecondition, unless err is already a gRPC error.
func ErrFailedPreconditionf ¶
ErrFailedPreconditionf wraps a formatted error with codes.FailedPrecondition, unless the formatted error is a wrapped gRPC error.
func ErrInternal ¶
ErrInternal wraps err with codes.Internal, unless err is already a gRPC error.
func ErrInternalf ¶
ErrInternalf wraps a formatted error with codes.Internal, unless the formatted error is a wrapped gRPC error.
func ErrInvalidArgument ¶
ErrInvalidArgument wraps err with codes.InvalidArgument, unless err is already a gRPC error.
func ErrInvalidArgumentf ¶
ErrInvalidArgumentf wraps a formatted error with codes.InvalidArgument, unless the formatted error is a wrapped gRPC error.
func ErrNotFound ¶
ErrNotFound wraps error with codes.NotFound, unless err is already a gRPC error.
func ErrNotFoundf ¶
ErrNotFoundf wraps a formatted error with codes.NotFound, unless the formatted error is a wrapped gRPC error.
func ErrPermissionDenied ¶
ErrPermissionDenied wraps err with codes.PermissionDenied, unless err is already a gRPC error.
func ErrPermissionDeniedf ¶
ErrPermissionDeniedf wraps a formatted error with codes.PermissionDenied, unless the formatted error is a wrapped gRPC error.
func ErrUnavailable ¶
ErrUnavailable wraps err with codes.Unavailable, unless err is already a gRPC error.
func ErrUnavailablef ¶
ErrUnavailablef wraps a formatted error with codes.Unavailable, unless the formatted error is a wrapped gRPC error.
func ErrWithDetails ¶
ErrWithDetails adds the given details to the error if it is a gRPC status whose code is not OK.
func GrpcCode ¶
GrpcCode emulates the old grpc.Code function: it translates errors into codes.Code values.
func RepoPathEqual ¶
func RepoPathEqual(a, b repository.GitRepo) bool
RepoPathEqual compares if two repositories are in the same location
func SanitizeError ¶
SanitizeError does the same thing as SanitizeString but for error types
func SanitizeString ¶
SanitizeString will clean password and tokens from URLs, and replace them with [FILTERED].
func SuppressCancellation ¶
SuppressCancellation returns a context that suppresses cancellation or expiration of the parent context.
func UnquoteBytes ¶
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 CountingWriter ¶
CountingWriter wraps an io.Writer and counts all the writes. Accessing the count N is not thread-safe.
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
nolint: stylecheck // This is unintentionally missing documentation.
func (*ManualTicker) Reset ¶
func (mt *ManualTicker) Reset()
nolint: stylecheck // This is unintentionally missing documentation.
func (*ManualTicker) Stop ¶
func (mt *ManualTicker) Stop()
nolint: stylecheck // This is unintentionally missing documentation.
func (*ManualTicker) Tick ¶
func (mt *ManualTicker) Tick()
nolint: stylecheck // This is unintentionally missing documentation.
type Ticker ¶
Ticker ticks on the channel returned by C to signal something.
func NewTimerTicker ¶
NewTimerTicker returns a Ticker that ticks after the specified interval has passed since the previous Reset call.
Source Files
Directories