rice

package module

Go to main page

Versions in this module

v0

v0.0.49

Oct 13, 2024

Changes in this version

+ func DeleteForm[R any](hc *HttpClient, url string, data url.Values) (R, error)

+ func NowTimeString() string

+ func PutForm[R any](hc *HttpClient, url string, data url.Values) (R, error)

v0.0.48

Oct 1, 2024

Changes in this version

+ func Do[R any](hc *HttpClient, request *http.Request) (R, error)

+ type DefaultResponse map[string]any

+ type FormFile struct

+ Data io.Reader

+ Fieldname string

+ Filename string

+ type HttpClient struct

+ func DefaultHttpClient() *HttpClient

+ func NewHttpClient(client *http.Client, logger *slog.Logger) *HttpClient

v0.0.47

Sep 7, 2024

Changes in this version

+ var YitterBaseTime = time.Date(2022, time.January, 1, 0, 0, 0, 0, time.Local)

+ func AppendFile(name string, data []byte) error

+ func JsonIndentEncode(t any, prefix, indent string) ([]byte, error)

+ func NextNanoID() string

+ func NullTimeString(tm sql.NullTime) string

+ func Pagination[T any](page, pageSize int, s []T) []T

+ func PrintAllElementsPull[E comparable](s *Set[E])

+ func PrintAllElementsPush[E comparable](s *Set[E])

+ func PrintAllElements[E comparable](s *Set[E])

+ func WriteFile(name string, data []byte) error

+ func WriteFileSafe(name string, data []byte) error

+ type Set struct

+ func New[E comparable]() *Set[E]

+ func Union[E comparable](s1, s2 *Set[E]) *Set[E]

+ func (s *Set[E]) Add(v E)

+ func (s *Set[E]) All() iter.Seq[E]

+ func (s *Set[E]) Contains(v E) bool

+ func (s *Set[E]) Pull() (func() (E, bool), func())

+ func (s *Set[E]) Push(f func(E) bool)

v0.0.46

Jun 2, 2024

v0.0.45

May 31, 2024

Changes in this version

+ func AESGCMDecryptFile(key []byte, inputFile, outputFile string) error

+ func AESGCMDecryptText(key string, ciphertextHex string) (string, error)

+ func AESGCMEncryptFile(key []byte, inputFile, outputFile string) error

+ func AESGCMEncryptText(key, plaintext string) (string, error)

+ func GenerateRSA() ([]byte, []byte, error)

+ func Get[R any](url string) (R, error)

+ func IP() string

+ func InitYitterID(workID uint16)

+ func IsASCII(s string) bool

+ func NewEtcdClient(endpoints []string) (*clientv3.Client, error)

+ func NewResolver(address string) *net.Resolver

+ func NextYitterID() int64

+ func NextYitterStringID() string

+ func Now() string

+ func PostForm[R any](url string, data url.Values) (R, error)

+ func PostJson[T, R any](url string, data T) (R, error)

+ func PostMultipartForm[R any](url string, data url.Values, wFunc WriteMutipartFunc) (R, error)

+ func PunycodeEncode(s string) (string, error)

+ func RandomBytes(length int) ([]byte, error)

+ func RandomHexString(length int) (string, error)

+ func Request[R any](request *http.Request) (R, error)

+ func SHA256(text string) string

+ func SetJsonSlog()

+ func SetTextSlog()

+ func TimeString(tm time.Time) string

+ type WriteMutipartFunc func(w *multipart.Writer) error

v0.0.42

Dec 2, 2023

Changes in this version

+ func NewFileWriter(fileName string, opts ...LumberjackOption) *lumberjack.Logger

+ func NewRedisClient(addr string, opts ...RedisOption) *redis.Client

type NotifyHook

+ func (t *NotifyHook) AddTelegramNotifierHook(token, proxy string, chatID ...int64) *NotifyHook

v0.0.41

Nov 4, 2023

Changes in this version

+ func ByteStringUnsafe(b []byte) string

v0.0.40

Nov 3, 2023

Changes in this version

+ func AppendFileIfExists(name string, data []byte) error

+ func FileExists(filename string) bool

+ func IsNil(x any) bool

+ func NewTelegramBot(token, proxy string) (*tgbotapi.BotAPI, error)

+ func NewTelegramNotifier(token, proxy string) (*telegram.Telegram, error)

+ func NextXID() string

+ func PathExists(path string) bool

+ func PathIsDir(path string) bool

+ func PathIsFile(path string) bool

+ func TrackTime(pre time.Time) time.Duration

+ func WriteFileIfNotExists(name string, data []byte) error

+ func WriteFileWhatever(name string, data []byte) error

v0.0.39

Aug 30, 2023

Changes in this version

+ func Hash(s string) string

+ func SplitNString(s string, index int) string

v0.0.38

Jul 2, 2023

Changes in this version

+ func InitZerolog(level string)

v0.0.37

Jul 1, 2023

Changes in this version

+ const ISSUER

+ func GenerateOTP(account string) (string, string, error)

+ func NewConsoleWriter() zerolog.ConsoleWriter

v0.0.36

Jun 23, 2023

Changes in this version

+ func JiebaAndPinyin(s string) ([]string, error)

+ func Pinyin(s string) string

v0.0.35

Jun 21, 2023

Changes in this version

+ func CountWeek(TimeFormat string) int

+ func InitTracerProvider(id int64, url, serviceName, environment string) (*tracesdk.TracerProvider, error)

+ func Jieba(s string) ([]string, error)

+ func NextUUID() string

+ type ESWriter struct

+ type MQWriter struct

type RSWriter

+ func NewRSWriter(url string) *RSWriter

v0.0.34

Jun 3, 2023

v0.0.33

Jun 3, 2023

Changes in this version

type NotifyHook

+ func (t *NotifyHook) Write(p []byte) (n int, err error)

+ type RSWriter struct

+ func (w *RSWriter) Write(p []byte) (n int, err error)

v0.0.32

May 30, 2023

Changes in this version

+ type NotifyHook struct

+ Notifier *notify.Notify

+ func NewNotifyHook() *NotifyHook

+ func (t *NotifyHook) AddTelegramBot(token, proxy string, chatID ...int64) *NotifyHook

+ func (t *NotifyHook) Run(e *zerolog.Event, level zerolog.Level, message string)

v0.0.31

May 30, 2023

Changes in this version

type TelegramHook

+ func (t *TelegramHook) AddTelegramBot(token, proxy string, chatID ...int64) *TelegramHook

v0.0.30

May 30, 2023

Changes in this version

+ func NewTelegramBotNotifier(token, proxy string, chatID ...int64) (*notify.Notify, error)

+ func NewTelegramService(token, proxy string) (*telegram.Telegram, error)

v0.0.29

May 28, 2023

Changes in this version

+ var Notifier = notify.New()

+ func AESDecrypt(keyString, cipherString string) (string, error)

+ func AESEncrypt(keyString, plainString string) (string, error)

+ func InitTelegramBotNotifier(token, proxy string, chatID ...int64) error

+ type TelegramHook struct

+ Notifier *notify.Notify

+ TelegramService *telegram.Telegram

+ func NewTelegramHook(token, proxy string, chatID ...int64) (*TelegramHook, error)

+ func (t *TelegramHook) Run(e *zerolog.Event, level zerolog.Level, message string)

v0.0.28

May 7, 2023

Changes in this version

+ func Exists(path string) bool

+ func IsDir(path string) bool

+ func IsFile(path string) bool

v0.0.27

Apr 22, 2023

Changes in this version

+ func JsonEncode(t any) ([]byte, error)

+ func JsonEncodeIndent(t any, prefix, indent string) ([]byte, error)

+ func VersionInfo() (string, string)

v0.0.26

Apr 2, 2023

Changes in this version

+ func LowerTitle(s string) string

+ func RemoveInvisibleChars(s string) string

v0.0.25

Mar 13, 2023

Changes in this version

+ func InitID(workID uint16)

+ func NextID() int64

+ func NextStringID() string

+ func RandNumber(max int64) int64

v0.0.24

Mar 12, 2023

Changes in this version

+ func BytesBufferString(b []byte) string

+ func Collect(iter Iterator[T]) []T

+ func DeDuplicate(items []T) []T

+ func DeDuplicateInPlace(items []T) []T

+ func Difference(items1, items2 []T) []T

+ func DifferenceBoth(items1, items2 []T) []T

+ func InitCert(certPEM, keyPEM []byte) error

+ func InitLogger(level string, w ...io.Writer)

+ func Intersection(s1, s2 []T) (inter []T)

+ func IsTimeExistIntersection(startTime, endTime time.Time, anotherStartTime, anotherEndTime time.Time) bool

+ func IsTimestampExistIntersection(startTime, endTime int64, anotherStartTime, anotherEndTime int64) bool

+ func LocalAddr() (string, error)

+ func LocalHostname() (string, error)

+ func Reduce(iter Iterator[V], f Reducer[T, V]) T

+ func RemoveItem(items []T, index int) []T

+ func RemoveItemNoOrder(items []T, index int) []T

+ func Reverse(items []T)

+ type Iterator interface

+ Next func() bool

+ Value func() T

+ func NewSliceIterator(xs []T) Iterator[T]

+ type Reducer func(accum T, value V) T

+ type SliceIterator struct

+ Elements []T

+ func (iter *SliceIterator[T]) Next() bool

+ func (iter *SliceIterator[T]) Value() T

v0.0.22

Oct 6, 2022

Changes in this version

+ var ErrInvalidTransition = errors.New("invalid transition")

v0.0.21

Oct 6, 2022

Changes in this version

+ const Digits

+ const GmailSSLPort

+ const GmailSmtp

+ const GmailTLSPort

+ const LowerLetters

+ const Symbols

+ const UpperLetters

+ var Cert tls.Certificate

+ var CertPool *x509.CertPool

+ var InvalidTransition = errors.New("invalid transition")

+ var Logger *zerolog.Logger = &zerolog.Logger

+ func BCryptCompareHashAndPassword(pwd, hash string) bool

+ func BCryptGenerateFromPassword(pwd string) (string, error)

+ func BetweenDays(startTime, endTime time.Time) int64

+ func ByteString(b []byte) string

+ func BytesNewBufferString(b []byte) string

+ func CertInit(certPEM, keyPEM []byte) error

+ func CheckPassword(pwd string) error

+ func CronRun(ctx context.Context, corn string, task ...func()) error

+ func CronRunM(ctx context.Context, corn string, task ...func()) error

+ func DeleteStruct(key string) error

+ func DeleteStructByPrefix(prefix string) error

+ func ErrorWrap(w http.ResponseWriter, code int, err error, msg ...string) error

+ func Filter(objs []T, filter func(obj T) bool) []T

+ func First(objs []T) (T, bool)

+ func FullPassword(level, length int) (string, error)

+ func GetHostname() string

+ func GetString(key string) string

+ func GetStruct(key string) (T, error)

+ func HGetStruct(key, field string) (T, error)

+ func HMCompare(h1, m1, h2, m2 int) bool

+ func HSetStruct(key, field string, data any) error

+ func HttpGet(url string) (T, error)

+ func In(e T, s []T) bool

+ func LoggerInit(level, path string)

+ func Map(objs []T, mapper func(obj T) ([]K, bool)) []K

+ func MaxNumber(n ...T) T

+ func MinNumber(n ...T) T

+ func NewGmailAuth(username, password string) smtp.Auth

+ func NewGrpcServer(ctx context.Context, port string, server *grpc.Server)

+ func NewLumberjackLogger(fileName string, opts ...LumberjackOption) io.Writer

+ func NextStringId() string

+ func NotIn(e T, s []T) bool

+ func Pageination(page, pageSize int, s []T) []T

+ func RandInt(max int64) (int64, error)

+ func RemoveDuplicates(s1 []T) []T

+ func RemoveDuplicatesInPlace(userIDs []int64) []int64

+ func SetString(key, value string, expiration ...time.Duration) error

+ func SetStruct(key string, data any, expiration ...time.Duration) error

+ func SliceDifference(a, b []T) []T

+ func SliceDifferenceBoth(slice1, slice2 []T) []T

+ func SliceIn(e T, s []T) bool

+ func SliceIntersection(s1, s2 []T) (inter []T)

+ func SlicePtrToSlice(s []*T) []T

+ func SliceRemoveIndex(s []T, index int) []T

+ func SliceRemoveIndexUnOrder(s []T, i int) []T

+ func SliceReverse(slice []T)

+ func SliceToSlicePtr(s []T) []*T

+ func StrconvFormatInt(i int64) string

+ func StrconvParseFloat(i int) (float64, error)

+ func StrconvParseInt(s string) (int64, error)

+ func StringByte(s string) []byte

+ func StringByteUnsafe(s string) []byte

+ func TickerRun(ctx context.Context, d time.Duration, task ...Task) error

+ func TickerRunContext(ctx context.Context, d time.Duration, task ...TaskContext) error

+ func TickerRunWithStartTimeContext(ctx context.Context, wg *sync.WaitGroup, tm time.Time, d time.Duration, ...) error

+ func TimeCompare(t1, t2 time.Time) bool

+ func TimeExistIntersection(startTime, endTime time.Time, anotherStartTime, anotherEndTime time.Time) bool

+ func TimeFormat(tm time.Time) string

+ func TimeFormatDate(tm time.Time) string

+ func TimeNowFormat() string

+ func TimeParseDate(date string) (time.Time, error)

+ func TimeParseDatetime(datetime string) (time.Time, error)

+ func TimeUnixFormatDate(timestamp int64) string

+ func TimeUnixFormatDatetime(timestamp int64) string

+ func TimerRun(ctx context.Context, tm time.Time, task ...Task) error

+ func TimestampExistIntersection(startTime, endTime int64, anotherStartTime, anotherEndTime int64) bool

+ func TodayZeroTime() time.Time

+ func TodayZeroTimestamp() int64

+ func UnWrapBody(r *http.Request) (*T, error)

+ func UnWrapURL(r *http.Request) (map[string]any, error)

+ func Wrap(w http.ResponseWriter, data any, msg ...string) error

+ func ZeroTime(tm time.Time) time.Time

+ func ZeroTimestamp(ts int64) int64

+ type AESCrypter interface

+ Decrypt func(keyString, cipherString string) (string, error)

+ Encrypt func(keyString, plainString string) (string, error)

+ func NewCTRCrypt() AESCrypter

+ type ApiWrapper struct

+ Code int

+ Data any

+ Msg string

+ type AsyncError struct

+ Err error

+ func (e AsyncError) Error() string

+ type CTRCrypt struct

+ func (*CTRCrypt) Decrypt(keyString, cipherString string) (string, error)

+ func (*CTRCrypt) Encrypt(keyString, plainString string) (string, error)

+ type Callback func(*Event)

+ type CallbackKey struct

+ type CallbackType int

+ const AfterEvent

+ const BeforeEvent

+ const EnterState

+ const LeaveState

+ const None

+ type Callbacks map[string]Callback

+ type CanceledError struct

+ Err error

+ func (e CanceledError) Error() string

+ type Event struct

+ Args []interface{}

+ Dst StateType

+ Err error

+ Event EventType

+ FSM *FSM

+ Src StateType

+ type EventDesc struct

+ Dst StateType

+ Name EventType

+ Src []StateType

+ type EventKey struct

+ type EventType int

+ type FSM struct

+ func NewFSM(initState StateType, events []EventDesc, callbacks map[CallbackKey]Callback) *FSM

+ func (f *FSM) Metadata(key string) (any, bool)

+ func (fsm *FSM) Current() StateType

+ func (fsm *FSM) Event(eventType EventType, args ...any) error

+ func (fsm *FSM) Is(state StateType) bool

+ func (fsm *FSM) Previous() StateType

+ func (fsm *FSM) Transition(event EventType)

+ type FSMManage struct

+ type FileStorage struct

+ BasePath string

+ Date string

+ func NewFileStorage(basePath, date string) *FileStorage

+ func (fs *FileStorage) Append(name string, data any) error

+ func (fs *FileStorage) Save(name string, data []byte) error

+ type FullPasswordConf struct

+ Length int

+ NumDigits int

+ NumLowerLetters int

+ NumSymbols int

+ NumUpperLetters int

+ func SetLevel(level, length int) FullPasswordConf

+ type IFSM interface

+ type Ider interface

+ NextInt64Id func() int64

+ NextStringId func() string

+ func NewUUID() Ider

+ func NewXId() Ider

+ func NewYitId() Ider

+ type InTransitionError struct

+ Event string

+ func (e InTransitionError) Error() string

+ type InternalError struct

+ func (e InternalError) Error() string

+ type InvalidEventError struct

+ Event string

+ State string

+ func (e InvalidEventError) Error() string

+ type JsonUnmarshal struct

+ func (j *JsonUnmarshal) ReadConfig(p []byte, v any) error

+ func (j *JsonUnmarshal) ReadConfigFromFile(path string, v any) error

+ type LumberjackOption func(*lumberjack.Logger)

+ func Compress(b bool) LumberjackOption

+ func LocalTime(b bool) LumberjackOption

+ func MaxAge(i int) LumberjackOption

+ func MaxBackups(i int) LumberjackOption

+ func MaxSize(i int) LumberjackOption

+ type Mail struct

+ Addr string

+ Auth smtp.Auth

+ From string

+ Host string

+ func (m *Mail) SendMail(subject, body string, to []string) error

+ type Mailer interface

+ SendMail func(subject, body string, to []string) error

+ func NewMail(auth smtp.Auth, from, host string, port int) Mailer

+ type MariaDB struct

+ func NewMaria(dsn string, opts ...Option) (*MariaDB, error)

+ func (db *MariaDB) Close()

+ type NoTransitionError struct

+ Err error

+ func (e NoTransitionError) Error() string

+ type NotInTransitionError struct

+ func (e NotInTransitionError) Error() string

+ type Numbers interface

+ type Option func(*sql.DB)

+ func ConnMaxIdleTime(d time.Duration) Option

+ func ConnMaxLifetime(d time.Duration) Option

+ func MaxIdleConns(size int) Option

+ func MaxOpenConns(size int) Option

+ type Postgres struct

+ func NewPostgres(dsn string, opts ...Option) (*Postgres, error)

+ func (db *Postgres) Close()

+ type Pretty interface

+ Exec func(query string, args ...any) (sql.Result, error)

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)

+ Prepare func(query string) (*sql.Stmt, error)

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

+ Query func(query string, args ...any) (*sql.Rows, error)

+ QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ QueryRow func(query string, args ...any) *sql.Row

+ QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row

+ type PrettyDB interface

+ Begin func() (*sql.Tx, error)

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ func NewMariaDB() PrettyDB

+ func NewPostgresDB() PrettyDB

+ type PrettyTx interface

+ Commit func() error

+ Rollback func() error

+ Stmt func(stmt *sql.Stmt) *sql.Stmt

+ StmtContext func(ctx context.Context, stmt *sql.Stmt) *sql.Stmt

+ func NewMariaTx() (PrettyTx, error)

+ func NewMariaTxContext(ctx context.Context) (PrettyTx, error)

+ func NewPostgresTx() (PrettyTx, error)

+ func NewPostgresTxContext(ctx context.Context) (PrettyTx, error)

+ type RSASign struct

+ PrivateKey *rsa.PrivateKey

+ PublicKey *rsa.PublicKey

+ func (r *RSASign) Sign(data []byte) ([]byte, error)

+ func (r *RSASign) Verify(data []byte, signature []byte) error

+ type Redis struct

+ func NewRedis(addr string, opts ...RedisOption) (*Redis, error)

+ func NewRedisDB() *Redis

+ type RedisOption func(*redis.Options)

+ func RedisAddr(addr string) RedisOption

+ func RedisDB(db int) RedisOption

+ func RedisPassword(pwd string) RedisOption

+ func RedisPoolSize(poolSize int) RedisOption

+ type Server struct

+ func NewHttpServer(handler http.Handler, opts ...ServerOption) *Server

+ func (s *Server) Notify() <-chan error

+ func (s *Server) Shutdown() error

+ type ServerOption func(*Server)

+ func Port(port string) ServerOption

+ func ReadTimeout(timeout time.Duration) ServerOption

+ func ShutdownTimeout(timeout time.Duration) ServerOption

+ func WriteTimeout(timeout time.Duration) ServerOption

+ type Signer interface

+ Sign func(data []byte) ([]byte, error)

+ Verify func(data []byte, signature []byte) error

+ func NewRSASignFromBytes(privateKeyData, publicKeyData []byte) (Signer, error)

+ func NewRSASignFromFile(privateKeyFile, publicKeyFile string) (Signer, error)

+ type StateType int

+ type Storage interface

+ Append func(name string, data any) error

+ Save func(name string, data []byte) error

+ type Task func() error

+ type TaskContext func(ctx context.Context) error

+ type TomlUnmarshal struct

+ func (t *TomlUnmarshal) ReadConfig(p []byte, v any) error

+ func (t *TomlUnmarshal) ReadConfigFromFile(path string, v any) error

+ type Transition int

+ type UUID struct

+ func (u *UUID) NextInt64Id() int64

+ func (u *UUID) NextStringId() string

+ type UnknownEventError struct

+ Event string

+ func (e UnknownEventError) Error() string

+ type UnmarshalConfiger interface

+ ReadConfig func(p []byte, v any) error

+ ReadConfigFromFile func(path string, v any) error

+ func NewJsonUnmarshal() UnmarshalConfiger

+ func NewTomlUnmarshal() UnmarshalConfiger

+ func NewYamlUnmarshal() UnmarshalConfiger

+ type XId struct

+ func (x *XId) NextInt64Id() int64

+ func (x *XId) NextStringId() string

+ type YamlUnmarshal struct

+ func (y *YamlUnmarshal) ReadConfig(p []byte, v any) error

+ func (y *YamlUnmarshal) ReadConfigFromFile(path string, v any) error

+ type YitId struct

+ func (n *YitId) NextInt64Id() int64

+ func (n *YitId) NextStringId() string

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