util

Documentation

Index

• func DELETE(u string, opts ...Option) (raw json.RawMessage, err error)
• func Dir() string
• func File(u, method string, opts ...Option) (io io.Reader, err error)
• func GET(u string, opts ...Option) (raw json.RawMessage, err error)
• func GetCookie(url *url.URL, name string) *http.Cookie
• func Hash(key, msg string) string
• func MD5(msg string) []byte
• func POST(u string, opts ...Option) (raw json.RawMessage, err error)
• func PUT(u string, opts ...Option) (raw json.RawMessage, err error)
• func ReadFile(filepath string, data interface{}) error
• func RegisterConnTimeout(timeout, longTimeout time.Duration)
• func RegisterCookieFun(name string)
• func RegisterCookieJar(name string)
• func RegisterDNS(dns []string)
• func RegisterDNSTimeout(timeout time.Duration)
• func RegisterDialerTimeout(timeout time.Duration)
• func RegisterProxy(proxy func(*http.Request) (*url.URL, error))
• func Request(method, u string, opts ...Option) (json.RawMessage, http.Header, error)
• func Sha256(msg string) string
• func UserAgent(args ...int) string
• func WriteFile(filepath string, data interface{}) error
• type ClientOption
  • func WithClientCookieFun(name string) ClientOption
  • func WithClientCookieJar(name string) ClientOption
  • func WithClientDNS(dns []string) ClientOption
  • func WithClientProxy(proxy func(*http.Request) (*url.URL, error)) ClientOption
  • func WithConnTimeout(timeout, longTimeout time.Duration) ClientOption
  • func WithDNSTimeout(timeout time.Duration) ClientOption
  • func WithDialerTimeout(timeout time.Duration) ClientOption
• type CodeError
  • func (err CodeError) Error() string
• type EmbedClient
  • func NewClient(opts ...ClientOption) *EmbedClient
  • func (c *EmbedClient) DELETE(u string, opts ...Option) (raw json.RawMessage, err error)
  • func (c *EmbedClient) File(u, method string, opts ...Option) (io io.Reader, err error)
  • func (c *EmbedClient) GET(u string, opts ...Option) (raw json.RawMessage, err error)
  • func (c *EmbedClient) GetCookie(url *url.URL, name string) *http.Cookie
  • func (c *EmbedClient) GetCookies(url *url.URL) []*http.Cookie
  • func (c *EmbedClient) POST(u string, opts ...Option) (raw json.RawMessage, err error)
  • func (c *EmbedClient) PUT(u string, opts ...Option) (raw json.RawMessage, err error)
  • func (c *EmbedClient) Request(method, u string, opts ...Option) (json.RawMessage, http.Header, error)
• type Group
  • func (g *Group) Do(key string, fn func() (interface{}, error)) (v interface{}, err error, shared bool)
  • func (g *Group) DoChan(key string, fn func() (interface{}, error)) <-chan Result
  • func (g *Group) Forget(key string)
• type Jar
• type Option
  • func WithAfterResponse(f func(w *http.Response)) Option
  • func WithBeforeRequest(f func(r *http.Request)) Option
  • func WithBody(body interface{}) Option
  • func WithContext(ctx context.Context) Option
  • func WithDebug() Option
  • func WithHeader(header map[string]string) Option
  • func WithProxy(f func(*http.Request) (*url.URL, error)) Option
  • func WithRandomHost(f func(string) string) Option
  • func WithRetry(retry uint) Option
  • func WithTest() Option
• type Result

Functions

func DELETE

func DELETE(u string, opts ...Option) (raw json.RawMessage, err error)

func Dir

func Dir() string

func File

func File(u, method string, opts ...Option) (io io.Reader, err error)

func GET

func GET(u string, opts ...Option) (raw json.RawMessage, err error)

func GetCookie

func GetCookie(url *url.URL, name string) *http.Cookie

func Hash

func Hash(key, msg string) string

func MD5

func MD5(msg string) []byte

func POST

func POST(u string, opts ...Option) (raw json.RawMessage, err error)

func PUT

func PUT(u string, opts ...Option) (raw json.RawMessage, err error)

func ReadFile

func ReadFile(filepath string, data interface{}) error

func RegisterConnTimeout

func RegisterConnTimeout(timeout, longTimeout time.Duration)

func RegisterCookieFun

func RegisterCookieFun(name string)

func RegisterCookieJar

func RegisterCookieJar(name string)

func RegisterDNS

func RegisterDNS(dns []string)

func RegisterDNSTimeout

func RegisterDNSTimeout(timeout time.Duration)

func RegisterDialerTimeout

func RegisterDialerTimeout(timeout time.Duration)

func RegisterProxy

func RegisterProxy(proxy func(*http.Request) (*url.URL, error))

func Request

func Request(method, u string, opts ...Option) (json.RawMessage, http.Header, error)

func Sha256

func Sha256(msg string) string

func UserAgent

func UserAgent(args ...int) string

func WriteFile

func WriteFile(filepath string, data interface{}) error

Types

type ClientOption

type ClientOption interface {
	// contains filtered or unexported methods
}

func WithClientCookieFun

func WithClientCookieFun(name string) ClientOption

func WithClientCookieJar

func WithClientCookieJar(name string) ClientOption

func WithClientDNS

func WithClientDNS(dns []string) ClientOption

func WithClientProxy

func WithClientProxy(proxy func(*http.Request) (*url.URL, error)) ClientOption

func WithConnTimeout

func WithConnTimeout(timeout, longTimeout time.Duration) ClientOption

func WithDNSTimeout

func WithDNSTimeout(timeout time.Duration) ClientOption

func WithDialerTimeout

func WithDialerTimeout(timeout time.Duration) ClientOption

type CodeError

type CodeError struct {
	Method  string
	URL     string
	Code    int
	Message string
}

func (CodeError) Error

func (err CodeError) Error() string

type EmbedClient

type EmbedClient struct {
	*http.Client
	// contains filtered or unexported fields
}

func NewClient

func NewClient(opts ...ClientOption) *EmbedClient

func (*EmbedClient) DELETE

func (c *EmbedClient) DELETE(u string, opts ...Option) (raw json.RawMessage, err error)

func (*EmbedClient) File

func (c *EmbedClient) File(u, method string, opts ...Option) (io io.Reader, err error)

func (*EmbedClient) GET

func (c *EmbedClient) GET(u string, opts ...Option) (raw json.RawMessage, err error)

func (*EmbedClient) GetCookie

func (c *EmbedClient) GetCookie(url *url.URL, name string) *http.Cookie

func (*EmbedClient) GetCookies

func (c *EmbedClient) GetCookies(url *url.URL) []*http.Cookie

func (*EmbedClient) POST

func (c *EmbedClient) POST(u string, opts ...Option) (raw json.RawMessage, err error)

func (*EmbedClient) PUT

func (c *EmbedClient) PUT(u string, opts ...Option) (raw json.RawMessage, err error)

func (*EmbedClient) Request

func (c *EmbedClient) Request(method, u string, opts ...Option) (json.RawMessage, http.Header, error)

type Group

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

Group represents a class of work and forms a namespace in which units of work can be executed with duplicate suppression.

func (*Group) Do

func (g *Group) Do(key string, fn func() (interface{}, error)) (v interface{}, err error, shared bool)

Do executes and returns the results of the given function, making sure that only one execution is in-flight for a given key at a time. If a duplicate comes in, the duplicate caller waits for the original to complete and receives the same results. The return value shared indicates whether v was given to multiple callers.

func (*Group) DoChan

func (g *Group) DoChan(key string, fn func() (interface{}, error)) <-chan Result

DoChan is like Do but returns a channel that will receive the results when they are ready.

The returned channel will not be closed.

func (*Group) Forget

func (g *Group) Forget(key string)

Forget tells the singleflight to forget about a key. Future calls to Do for this key will call the function rather than waiting for an earlier call to complete.

type Jar

type Jar struct {
	PsList cookiejar.PublicSuffixList `json:"pslist"`

	// mu locks the remaining fields.
	Mu sync.Mutex `json:"mu"`

	// entries is a set of entries, keyed by their eTLD+1 and subkeyed by
	// their name/domain/path.
	Entries map[string]map[string]entry `json:"entries"`

	// nextSeqNum is the next sequence number assigned to a new cookie
	// created SetCookies.
	NextSeqNum uint64 `json:"nextseqnum"`
}

type Option

type Option interface {
	// contains filtered or unexported methods
}

func WithAfterResponse

func WithAfterResponse(f func(w *http.Response)) Option

func WithBeforeRequest

func WithBeforeRequest(f func(r *http.Request)) Option

func WithBody

func WithBody(body interface{}) Option

func WithContext

func WithContext(ctx context.Context) Option

func WithDebug

func WithDebug() Option

func WithHeader

func WithHeader(header map[string]string) Option

func WithProxy

func WithProxy(f func(*http.Request) (*url.URL, error)) Option

func WithRandomHost

func WithRandomHost(f func(string) string) Option

func WithRetry

func WithRetry(retry uint) Option

func WithTest

func WithTest() Option

type Result

type Result struct {
	Val    interface{}
	Err    error
	Shared bool
}

Result holds the results of Do, so they can be passed on a channel.