core

Documentation

Index

• Constants
• Variables
• func Debug(format string, args ...any)
• func FatalIf(err error, msg string, args ...interface{})
• func If[T any](cond bool, whenTrue T, whenFalse T) T
• func Info(format string, args ...any)
• func IsErr(err error, msg string, args ...interface{}) bool
• func NewBytesReader(bs []byte) io.ReadSeekCloser
• func NewStringReader(s string) io.ReadSeekCloser
• func Now() time.Time
• func ReadBytes(r io.Reader) ([]byte, error)
• func Since(t time.Time) time.Duration
• func TimeIsSync() bool
• func WriteBytes(data []byte, w io.Writer) error
• type BytesReader
  • func (r BytesReader) Close() error
  • func (r BytesReader) Read(p []byte) (n int, err error)
  • func (r BytesReader) Seek(offset int64, whence int) (int64, error)
  • func (r BytesReader) WriteTo(w io.Writer) (n int64, err error)

Constants

const DomainFilelock = "D.lock"

const UsersFilename = "U"

const UsersFilesign = "U.sign"

Variables

var ClockOffset time.Duration

var ErrInvalidChangeFilePath = fmt.Errorf("a change file is not in a valid Safepool folder")

var ErrInvalidFilePath = fmt.Errorf("a file is not in a valid Safepool folder")

var ErrInvalidId = fmt.Errorf("the id is invalid")

var ErrInvalidSignature = fmt.Errorf("signature does not match the user id")

var ErrInvalidSize = fmt.Errorf("provided slice has not enough data")

var ErrInvalidVersion = fmt.Errorf("version of protocol is not compatible")

var ErrNoDriver = fmt.Errorf("no driver found for the provided configuration")

var ErrNoExchange = fmt.Errorf("no exchange reachable for the domain")

var ErrNotAuthorized = fmt.Errorf("user is not authorized in the domain")

var ErrNotInitialized = fmt.Errorf("safepool not initialized")

var MaxRecentErrors = 4096

var MaxStacktraceOut = 5

var NtpRetries = 10

var NtpServers = []string{
	"time.google.com",
	"0.beevik-ntp.pool.ntp.org",
}

var RecentLog []string

var SnowFlakeStart = time.Date(2023, 1, 1, 0, 0, 0, 0, time.UTC)

Functions

func Debug

func Debug(format string, args ...any)

func FatalIf

func FatalIf(err error, msg string, args ...interface{})

func If

func If[T any](cond bool, whenTrue T, whenFalse T) T

func Info

func Info(format string, args ...any)

func IsErr

func IsErr(err error, msg string, args ...interface{}) bool

func NewBytesReader

func NewBytesReader(bs []byte) io.ReadSeekCloser

func NewStringReader

func NewStringReader(s string) io.ReadSeekCloser

func Now

func Now() time.Time

func ReadBytes

func ReadBytes(r io.Reader) ([]byte, error)

func Since

func Since(t time.Time) time.Duration

func TimeIsSync

func TimeIsSync() bool

func WriteBytes

func WriteBytes(data []byte, w io.Writer) error

Types

type BytesReader

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

func (BytesReader) Close

func (r BytesReader) Close() error

func (BytesReader) Read

func (r BytesReader) Read(p []byte) (n int, err error)

func (BytesReader) Seek

func (r BytesReader) Seek(offset int64, whence int) (int64, error)

func (BytesReader) WriteTo

func (r BytesReader) WriteTo(w io.Writer) (n int64, err error)