toolbelt

May 20, 2024

Changes in this version

+ type Pool struct

+ func New[T any](fn func() T) Pool[T]

+ func (p *Pool[T]) Get() T

+ func (p *Pool[T]) Put(x T)

Nov 27, 2023

Changes in this version

+ var JulianZeroTime = JulianDayToTime(0)

+ func StmtBytes(stmt *sqlite.Stmt, colName string) []byte

+ func StmtJulianToTime(stmt *sqlite.Stmt, colName string) time.Time

+ func StmtJulianToTimestamp(stmt *sqlite.Stmt, colName string) *timestamppb.Timestamp

+ type MustProtobufHandler struct

+ func NewProtobufHandler(isJSON bool) *MustProtobufHandler

+ func (h *MustProtobufHandler) Marshal(msg proto.Message) []byte

+ func (h *MustProtobufHandler) Unmarshal(b []byte, msg proto.Message)

Nov 27, 2023

Changes in this version

+ func Bytes(stmt *sqlite.Stmt, colName string) []byte

+ func MustProtoJSONMarshal(msg proto.Message) []byte

+ func MustProtoJSONUnmarshal(b []byte, msg proto.Message)

+ func MustProtoMarshal(msg proto.Message) []byte

+ func MustProtoUnmarshal(b []byte, msg proto.Message)

Nov 6, 2023

Changes in this version

type SSEEventOption

+ func WithSSEEvent(event string) SSEEventOption

+ func WithSSEId(id string) SSEEventOption

+ func WithSSERetry(retry time.Duration) SSEEventOption

+ func WithSSESkipMinBytesCheck(skip bool) SSEEventOption

type ServerSentEventsHandler

+ func (sse *ServerSentEventsHandler) SendMultiData(dataArr []string, opts ...SSEEventOption)

Nov 4, 2023

Changes in this version

type SSEEvent

+ SkipMinBytesCheck bool

type SSEEventOption

+ func SSEEventSkipMinBytesCheck(skip bool) SSEEventOption

Nov 1, 2023

Changes in this version

+ type CasedFn func(string) string

type CasedString

+ func ToCasedString(s string) CasedString

Oct 20, 2023

Changes in this version

+ type SSEEvent struct

+ Data string

+ Event string

+ Id string

+ Retry time.Duration

+ type SSEEventOption func(*SSEEvent)

+ func SSEEventEvent(event string) SSEEventOption

+ func SSEEventId(id string) SSEEventOption

+ func SSEEventRetry(retry time.Duration) SSEEventOption

+ type ServerSentEventsHandler struct

+ func NewSSE(w http.ResponseWriter, r *http.Request) *ServerSentEventsHandler

+ func (sse *ServerSentEventsHandler) Send(data string, opts ...SSEEventOption)

Oct 19, 2023

Changes in this version

type TypedKV

+ func (tkv *TypedKV[T]) Watch(ctx context.Context, key string, opts ...nats.WatchOpt) (values <-chan T, stop func() error, err error)

+ func (tkv *TypedKV[T]) WatchAll(ctx context.Context, opts ...nats.WatchOpt) (values <-chan T, stop func() error, err error)

Sep 8, 2023

Changes in this version

+ func CompressMiddleware() func(next http.Handler) http.Handler

type CtxErrFunc

+ func RunHotReload(port int, onStartPath string) CtxErrFunc

Sep 8, 2023

Changes in this version

+ func CtxSlog(ctx context.Context) (logger *slog.Logger, ok bool)

+ func CtxWithSlog(ctx context.Context, slog *slog.Logger) context.Context

+ type CtxKey string

+ const CtxSlogKey

Sep 8, 2023

Changes in this version

+ const UnixEpochJulianDay

+ func AliasHash(alias string) int64

+ func AliasHashEncoded(alias string) string

+ func AliasHashEncodedf(format string, args ...interface{}) string

+ func AliasHashf(format string, args ...interface{}) int64

+ func Camel(s string) string

+ func Clamp(v T, minimum T, maximum T) T

+ func Clamp01(v T) T

+ func ClampFit(x T, oldMin T, oldMax T, newMin T, newMax T) T

+ func ClampFit01(x T, newMin T, newMax T) T

+ func Fit(x T, oldMin T, oldMax T, newMin T, newMax T) T

+ func Fit01(x T, newMin T, newMax T) T

+ func FitMax(x T, newMax T) T

+ func JulianDayToTime(d float64) time.Time

+ func JulianDayToTimeStmt(stmt *sqlite.Stmt, param string) time.Time

+ func JulianDayToTimestamp(f float64) *timestamppb.Timestamp

+ func JulianDayToTimestampStmt(stmt *sqlite.Stmt, param string) *timestamppb.Timestamp

+ func JulianNow() float64

+ func Kebab(s string) string

+ func Lower(s string) string

+ func NextEncodedID() string

+ func NextID() int64

+ func Pascal(s string) string

+ func RandIntRange(r *rand.Rand, min, max T) T

+ func RandNegOneToOneClamped(r *rand.Rand) T

+ func RoundFit01(x T, newMin T, newMax T) T

+ func Snake(s string) string

+ func TimeToJulianDay(t time.Time) float64

+ func TimestampJulian(ts *timestamppb.Timestamp) float64

+ func Upper(s string) string

+ func UpsertStream(js nats.JetStreamContext, cfg *nats.StreamConfig) (si *nats.StreamInfo, err error)

+ type CasedString struct

+ Camel string

+ Kebab string

+ Lower string

+ Original string

+ Pascal string

+ Snake string

+ Upper string

+ func Cased(s string) CasedString

+ type CtxErrFunc func(ctx context.Context) error

+ type Database struct

+ func NewDatabase(ctx context.Context, dbFilename string, migrations []string) (*Database, error)

+ func (db *Database) Close() error

+ func (db *Database) ReadTX(ctx context.Context, fn TxFn) (err error)

+ func (db *Database) WriteTX(ctx context.Context, fn TxFn) (err error)

+ type EmbeddedNATsServer struct

+ NatsServer *server.Server

+ func NewEmbeddedNATsServer(ctx context.Context, clearData bool) (*EmbeddedNATsServer, error)

+ func (n *EmbeddedNATsServer) Client() (*nats.Conn, error)

+ func (n *EmbeddedNATsServer) Close() error

+ func (n *EmbeddedNATsServer) WaitForServer()

+ type ErrGroupSeparateCtx struct

+ func NewErrGroupSeparateCtx() *ErrGroupSeparateCtx

+ func (egc *ErrGroupSeparateCtx) Go(ctx context.Context, funcs ...CtxErrFunc)

+ func (egc *ErrGroupSeparateCtx) Wait() error

+ type ErrGroupSharedCtx struct

+ func NewErrGroupSharedCtx(ctx context.Context, funcs ...CtxErrFunc) *ErrGroupSharedCtx

+ func (egc *ErrGroupSharedCtx) Go(funcs ...CtxErrFunc)

+ func (egc *ErrGroupSharedCtx) Wait() error

+ type Float interface

+ type Integer interface

+ type TxFn func(tx *sqlite.Conn) error

+ type TypedIdFunc func(T) string

+ type TypedKV struct

+ func UpsertTypedKV(js nats.JetStreamContext, cfg *nats.KeyValueConfig, newFn TypedNewFunc[T], ...) (*TypedKV[T], error)

+ func (t *TypedKV[T]) Get(key string) (T, uint64, error)

+ func (tkv *TypedKV[T]) All() (out []T, err error)

+ func (tkv *TypedKV[T]) Batch(values ...T) (err error)

+ func (tkv *TypedKV[T]) Delete(value T) (err error)

+ func (tkv *TypedKV[T]) DeleteKey(key string) (err error)

+ func (tkv *TypedKV[T]) Keys() ([]string, error)

+ func (tkv *TypedKV[T]) Load(keys ...string) (loaded []T, err error)

+ func (tkv *TypedKV[T]) Set(value T) (revision uint64, err error)

+ func (tkv *TypedKV[T]) Update(value T, last uint64) (revision uint64, err error)

+ type TypedNewFunc func() T