flu

Apr 24, 2022

Changes in this version

type ByteBuffer

+ func (b *ByteBuffer) String() string

type URL

+ func (u URL) String() string

Apr 9, 2022

Changes in this version

+ var ID = internal.ID

+ var Readable = internal.Readable

+ func AppendAll(appendable Appendable[E], iterable Iterable[E])

+ func Contains(iterable Iterable[E], value E) (match bool)

+ type Appendable interface

+ Append func(element E)

type Duration

+ Value time.Duration

+ func (d Duration) MarshalJSON() ([]byte, error)

+ func (d Duration) MarshalYAML() (interface{}, error)

type File

+ func (f File) String() string

+ type ForEach func(element E) bool

+ type Iterable interface

+ ForEach func(forEach ForEach[E])

+ type Set map[E]bool

+ func (s *Set[E]) Append(element E)

+ func (s *Set[E]) UnmarshalJSON(data []byte) error

+ func (s *Set[E]) UnmarshalYAML(node *yaml.Node) error

+ func (s Set[E]) ForEach(forEach ForEach[E])

+ func (s Set[E]) MarshalJSON() ([]byte, error)

+ func (s Set[E]) MarshalYAML() (interface{}, error)

+ func (s Set[E]) Size() int

+ type Sizeable interface

+ Size func() int

+ type Slice []E

+ func ToSlice(iterable Iterable[E]) Slice[E]

+ func (s *Slice[E]) Append(element E)

+ func (s Slice[E]) ForEach(forEach ForEach[E])

+ func (s Slice[E]) Size() int

Oct 24, 2021

Changes in this version

type File

+ func (f File) Append() (*os.File, error)

+ func (f File) CreateParent() error

Oct 19, 2021

Changes in this version

+ var TimeLayout = "2006-01-02 15:04:05"

+ type Int64Set map[int64]bool

+ func (s *Int64Set) UnmarshalJSON(data []byte) error

+ func (s *Int64Set) UnmarshalYAML(node *yaml.Node) error

+ func (s Int64Set) Add(values ...int64) Int64Set

+ func (s Int64Set) Copy() Int64Set

+ func (s Int64Set) MarshalJSON() ([]byte, error)

+ func (s Int64Set) MarshalYAML() (interface{}, error)

+ func (s Int64Set) Slice() []int64

+ type StringSet map[string]bool

+ func (s *StringSet) UnmarshalJSON(data []byte) error

+ func (s *StringSet) UnmarshalYAML(node *yaml.Node) error

+ func (s StringSet) Add(values ...string) StringSet

+ func (s StringSet) AnyMatch(matcher func(key string) bool) bool

+ func (s StringSet) Copy() StringSet

+ func (s StringSet) MarshalJSON() ([]byte, error)

+ func (s StringSet) MarshalYAML() (interface{}, error)

+ func (s StringSet) Slice() []string

+ type Time struct

+ Layout string

+ func (t *Time) FromString(str string) error

+ func (t *Time) MarshalJSON() ([]byte, error)

+ func (t *Time) MarshalYAML() (interface{}, error)

+ func (t *Time) UnmarshalJSON(data []byte) error

+ func (t *Time) UnmarshalYAML(node *yaml.Node) error

+ func (t Time) String() string

Oct 13, 2021

Changes in this version

type Bytes

+ func (b Bytes) String() string

Oct 9, 2021

Changes in this version

+ func AwaitSignal(signals ...os.Signal)

+ func Close(value interface{}) error

+ func CloseQuietly(value interface{})

+ func Copy(in Input, out Output) (written int64, err error)

+ func DecodeFrom(in Input, decoder DecoderFrom) error

+ func EncodeTo(encoder EncoderTo, out Output) error

+ func IsContextRelated(err error) bool

+ func IsNetworkRelated(err error) bool

+ func Sleep(ctx context.Context, timeout time.Duration) error

+ func ToString(in Input) (string, error)

+ type AnyCloser struct

+ V interface{}

+ func (c AnyCloser) Close() error

+ type ByteBuffer bytes.Buffer

+ func (b *ByteBuffer) Bytes() Bytes

+ func (b *ByteBuffer) Reader() (io.Reader, error)

+ func (b *ByteBuffer) Unmask() *bytes.Buffer

+ func (b *ByteBuffer) Writer() (io.Writer, error)

+ type Bytes []byte

+ func (b Bytes) Reader() (io.Reader, error)

+ type Chars struct

+ Enc encoding.Encoding

+ In Input

+ Out Output

+ func (cs Chars) Reader() (io.Reader, error)

+ func (cs Chars) Writer() (io.Writer, error)

+ type Clock interface

+ Now func() time.Time

+ var DefaultClock Clock = ClockFunc(time.Now)

+ type ClockFunc func() time.Time

+ func (fun ClockFunc) Now() time.Time

+ type Codec func(interface{}) ValueCodec

+ type Conn struct

+ Address string

+ Context context.Context

+ Dialer net.Dialer

+ Network string

+ func (c Conn) Dial() (net.Conn, error)

+ func (c Conn) Reader() (io.Reader, error)

+ func (c Conn) Writer() (io.Writer, error)

+ type ContextFunc func(parent context.Context) (context.Context, context.CancelFunc)

+ func Deadline(deadline time.Time) ContextFunc

+ func Timeout(timeout time.Duration) ContextFunc

+ type Counter int64

+ func (c *Counter) Add(n int64)

+ func (c *Counter) Value() int64

+ type DecoderFrom interface

+ DecodeFrom func(io.Reader) error

+ type Duration time.Duration

+ func (d *Duration) FromString(str string) error

+ func (d *Duration) UnmarshalJSON(data []byte) error

+ func (d *Duration) UnmarshalYAML(node *yaml.Node) error

+ func (d Duration) GetOrDefault(defaultValue time.Duration) time.Duration

+ func (d Duration) Unmask() time.Duration

+ type EncoderTo interface

+ EncodeTo func(io.Writer) error

+ type File string

+ func FilePath(path ...string) File

+ func (f File) Create() (*os.File, error)

+ func (f File) Exists() (bool, error)

+ func (f File) Join(child string) File

+ func (f File) Open() (*os.File, error)

+ func (f File) Path() string

+ func (f File) Reader() (io.Reader, error)

+ func (f File) Remove() error

+ func (f File) Writer() (io.Writer, error)

+ type IO struct

+ E error

+ R io.Reader

+ W io.Writer

+ func (io IO) Reader() (io.Reader, error)

+ func (io IO) Writer() (io.Writer, error)

+ type IOCounter struct

+ func (c *IOCounter) Reader() (r io.Reader, err error)

+ func (c *IOCounter) Writer() (w io.Writer, err error)

+ type Input interface

+ Reader func() (io.Reader, error)

+ func PipeInput(encoder EncoderTo) Input

+ type Mutex struct

+ func (mu *Mutex) Lock() Unlocker

+ func (mu *Mutex) Unlock()

+ type Output interface

+ Writer func() (io.Writer, error)

+ func PipeOutput(decoder DecoderFrom) Output

+ type RWMutex struct

+ func (mu *RWMutex) Lock() Unlocker

+ func (mu *RWMutex) RLock() Unlocker

+ func (mu *RWMutex) RUnlock()

+ func (mu *RWMutex) Unlock()

+ type RateLimiter interface

+ Complete func()

+ Start func(ctx context.Context) error

+ var RateUnlimiter RateLimiter = rateUnlimiter{}

+ func ConcurrencyRateLimiter(concurrency int) RateLimiter

+ func IntervalRateLimiter(interval time.Duration) RateLimiter

+ type ReaderCounter struct

+ func (rc ReaderCounter) Close() error

+ func (rc ReaderCounter) Read(data []byte) (n int, err error)

+ type Text struct

+ Value string

+ func (v *Text) ContentType() string

+ func (v *Text) DecodeFrom(r io.Reader) error

+ func (v *Text) EncodeTo(w io.Writer) error

+ type URL string

+ func (u URL) Reader() (io.Reader, error)

+ func (u URL) Unmask() string

+ type Unlocker interface

+ Unlock func()

+ type UnlockerFunc func()

+ func (fun UnlockerFunc) Unlock()

+ type ValueCodec interface

+ func Gob(value interface{}) ValueCodec

+ func JSON(value interface{}) ValueCodec

+ func XML(value interface{}) ValueCodec

+ func YAML(value interface{}) ValueCodec

+ type WaitGroup struct

+ func (wg *WaitGroup) Go(ctx context.Context, fun func(ctx context.Context)) func()

+ func (wg *WaitGroup) GoWith(ctx context.Context, contextFunc ContextFunc, fun func(ctx context.Context)) func()

+ type WriterCounter struct

+ func (wc WriterCounter) Close() error

+ func (wc WriterCounter) Write(data []byte) (n int, err error)