util

package

v1.58.0 Latest Latest Go to latest Published: Mar 19, 2024 License: AGPL-3.0 Imports: 18 Imported by: 36

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/c9s/bbgo

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func FNV32(s string) uint32
func FilterSimpleArgs(args []interface{}) (simpleArgs []interface{})
func GetEnvVarBool(n string) (bool, bool)
func GetEnvVarDuration(n string) (time.Duration, bool)
func GetEnvVarInt(n string) (int, bool)
func IsPaperTrade() bool
func MaskKey(key string) string
func MillisecondsJitter(d time.Duration, jitterInMilliseconds int) time.Duration
func NewValidLimiter(r rate.Limit, b int) (*rate.Limiter, error)
func ReadJsonFile(file string, obj interface{}) error
func SafeMkdirAll(p string) error
func SetEnvVarBool(n string, v *bool) bool
func ShouldDelay(l *rate.Limiter, minInterval time.Duration) time.Duration
func StringSliceContains(slice []string, needle string) bool
func StringSplitByLength(s string, length int) (result []string)
func TryLock(lock *sync.RWMutex) bool
func TryRLock(lock *sync.RWMutex) bool
func UnixMilli() int64
func WriteJsonFile(p string, obj interface{}) error
type Reonce
- func (o *Reonce) Do(f func())
- func (o *Reonce) Reset()
type Response
- func NewResponse(r *http.Response) (response *Response, err error)
- func (r *Response) DecodeJSON(o interface{}) error
- func (r *Response) IsError() bool
- func (r *Response) IsHTML() bool
- func (r *Response) IsJSON() bool
- func (r *Response) String() string
type TimeProfile
- func StartTimeProfile(args ...string) TimeProfile
- func (p *TimeProfile) Stop() time.Duration
- func (p *TimeProfile) StopAndLog(f logFunction)
- func (p *TimeProfile) TilNow() time.Duration
type VolatileMemory
- func NewDetectorCache() *VolatileMemory
- func (i *VolatileMemory) IsObjectFresh(obj interface{}, ttl time.Duration) bool
- func (i *VolatileMemory) IsTextFresh(text string, ttl time.Duration) bool

Constants ¶

View Source

const Pointer = reflect.Pointer

Variables ¶

This section is empty.

Functions ¶

func FNV32 ¶ added in v1.33.0

func FNV32(s string) uint32

func FilterSimpleArgs ¶ added in v1.33.4

func FilterSimpleArgs(args []interface{}) (simpleArgs []interface{})

FilterSimpleArgs filters out the simple type arguments int, string, bool, and []byte

func GetEnvVarBool ¶ added in v1.17.0

func GetEnvVarBool(n string) (bool, bool)

func GetEnvVarDuration ¶ added in v1.17.0

func GetEnvVarDuration(n string) (time.Duration, bool)

func GetEnvVarInt ¶ added in v1.17.0

func GetEnvVarInt(n string) (int, bool)

func IsPaperTrade ¶ added in v1.33.0

func IsPaperTrade() bool

func MaskKey ¶ added in v1.21.0

func MaskKey(key string) string

func MillisecondsJitter ¶ added in v1.17.0

func MillisecondsJitter(d time.Duration, jitterInMilliseconds int) time.Duration

func NewValidLimiter ¶

func NewValidLimiter(r rate.Limit, b int) (*rate.Limiter, error)

func ReadJsonFile ¶ added in v1.51.0

func ReadJsonFile(file string, obj interface{}) error

func SafeMkdirAll ¶ added in v1.33.0

func SafeMkdirAll(p string) error

func SetEnvVarBool ¶ added in v1.18.0

func SetEnvVarBool(n string, v *bool) bool

func ShouldDelay ¶

func ShouldDelay(l *rate.Limiter, minInterval time.Duration) time.Duration

func StringSliceContains ¶ added in v1.11.1

func StringSliceContains(slice []string, needle string) bool

func StringSplitByLength ¶ added in v1.42.0

func StringSplitByLength(s string, length int) (result []string)

func TryLock ¶ added in v1.38.0

func TryLock(lock *sync.RWMutex) bool

func TryRLock ¶ added in v1.38.0

func TryRLock(lock *sync.RWMutex) bool

func UnixMilli ¶ added in v1.21.0

func UnixMilli() int64

func WriteJsonFile ¶ added in v1.33.0

func WriteJsonFile(p string, obj interface{}) error

Types ¶

type Reonce ¶ added in v1.21.0

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

func (*Reonce) Do ¶ added in v1.21.0

func (o *Reonce) Do(f func())

func (*Reonce) Reset ¶ added in v1.21.0

func (o *Reonce) Reset()

type Response ¶ added in v1.11.0

type Response struct {
	*http.Response

	// Body overrides the composited Body field.
	Body []byte
}

Response is wrapper for standard http.Response and provides more methods.

func NewResponse ¶ added in v1.11.0

func NewResponse(r *http.Response) (response *Response, err error)

NewResponse is a wrapper of the http.Response instance, it reads the response body and close the file.

func (*Response) DecodeJSON ¶ added in v1.11.0

func (r *Response) DecodeJSON(o interface{}) error

func (*Response) IsError ¶ added in v1.11.0

func (r *Response) IsError() bool

func (*Response) IsHTML ¶ added in v1.11.0

func (r *Response) IsHTML() bool

func (*Response) IsJSON ¶ added in v1.11.0

func (r *Response) IsJSON() bool

func (*Response) String ¶ added in v1.11.0

func (r *Response) String() string

String converts response body to string. An empty string will be returned if error.

type TimeProfile ¶ added in v1.17.0

type TimeProfile struct {
	Name               string
	StartTime, EndTime time.Time
	Duration           time.Duration
}

func StartTimeProfile ¶ added in v1.17.0

func StartTimeProfile(args ...string) TimeProfile

func (*TimeProfile) Stop ¶ added in v1.17.0

func (p *TimeProfile) Stop() time.Duration

func (*TimeProfile) StopAndLog ¶ added in v1.33.0

func (p *TimeProfile) StopAndLog(f logFunction)

func (*TimeProfile) TilNow ¶ added in v1.17.0

func (p *TimeProfile) TilNow() time.Duration

type VolatileMemory ¶

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

func NewDetectorCache ¶

func NewDetectorCache() *VolatileMemory

func (*VolatileMemory) IsObjectFresh ¶

func (i *VolatileMemory) IsObjectFresh(obj interface{}, ttl time.Duration) bool

func (*VolatileMemory) IsTextFresh ¶

func (i *VolatileMemory) IsTextFresh(text string, ttl time.Duration) bool

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
backoff
templateutil
tradingutil

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