v1

Documentation

Index

• Constants
• func SetAuthHeaders(method string, payload []byte, config *Config, u *url.URL, req Requester) (*http.Header, error)
• func WsParamForPrivate(sercret string) (now int, nonce, sign string)
• type Client
  • func New(config *Config) *Client
  • func (c *Client) Addresses(req *address.Request) (*address.Response, error)
  • func (c *Client) Balance(req *balance.Request) (*balance.Response, error)
  • func (c *Client) Balances(req *list.RequestForBalances) (*list.ResponseForBalances, error)
  • func (c *Client) Bankin(req *banks.RequestForIn) (*banks.ResponseForIn, error)
  • func (c *Client) Bankout(req *banks.RequestForOut) (*banks.ResponseForOut, error)
  • func (c *Client) Banks(req *banks.RequestForBanks) (*banks.ResponseForBanks, error)
  • func (c *Client) Board(req *board.Request) (*board.Response, error)
  • func (c *Client) BoardHealth(req *health.RequestForBoard) (*health.Board, error)
  • func (c *Client) CancelAll(req *cancels.RequestForAllCancel) error
  • func (c *Client) CancelByID(req *cancels.RequestByID) error
  • func (c *Client) CancelByIDForParent(req *cancels.RequestByIDForParentCancel) error
  • func (c *Client) Chats(req *chat.Request) (*chat.Response, error)
  • func (c *Client) ChildOrder(req *orders.RequestForChildOrder) (*orders.ResponseForChildOrder, error)
  • func (c *Client) ChildOrders(req *list.RequestForChildOrders) (*list.ResponseForChildOrders, error)
  • func (c *Client) Coinin(req *coins.RequestForIn) (*coins.ResponseForIn, error)
  • func (c *Client) Coinout(req *coins.RequestForOut) (*coins.ResponseForOut, error)
  • func (c *Client) Collateral(req *collateral.Request) (*collateral.Response, error)
  • func (c *Client) Collaterals(req *list.RequestForCollaterals) (*list.ResponseForCollaterals, error)
  • func (c *Client) Commission(req *commission.Request) (*commission.Response, error)
  • func (p *Client) Config() *Config
  • func (p *Client) Do(req Requester, result interface{}) error
  • func (c *Client) ExchangeHealth(req *health.RequestForExchange) (*health.Exchange, error)
  • func (c *Client) Executions(req *execution.Request) (*execution.Response, error)
  • func (p *Client) Host() string
  • func (c *Client) MyExecutions(req *list.RequestForExecutions) (*list.ResponseForExecutions, error)
  • func (c *Client) ParentOrder(req *orders.RequestForParentOrder) (*orders.ResponseForParentOrder, error)
  • func (c *Client) ParentOrders(req *list.RequestForParentOrders) (*list.ResponseForParentOrders, error)
  • func (c *Client) Positions(req *list.RequestForPositions) (*list.ResponseForPositions, error)
  • func (c *Client) Ticker(req *ticker.Request) (*ticker.Response, error)
  • func (c *Client) Withdraw(req *banks.RequestForWithdraw) (*banks.ResponseForWithdraw, error)
• type Config
  • func (p *Config) Check() *Config
• type Headers
• type Limit
  • func NewLimit(comparisonValue int) *Limit
  • func (p *Limit) Check() error
  • func (p *Limit) CheckForOrder() error
  • func (p *Limit) Period(isOrder bool) int
  • func (p *Limit) Remain(isOrder bool) int
  • func (p *Limit) Reset(isOrder bool) time.Time
  • func (p *Limit) Set(h http.Header)
  • func (p *Limit) SetThreshold(i int)
• type Requester

Constants

const (
	// APIREMAIN API Limit for same IP
	APIREMAIN = 500
	// APIREMAINFORORDER API Limit for orders/cancelAll
	APIREMAINFORORDER = 300
)

const (
	// APIHOST is Endpoint
	APIHOST = "https://api.bitflyer.com"

	// APITIMEOUT http wait
	APITIMEOUT = 10 * time.Second
)

Functions

func SetAuthHeaders

func SetAuthHeaders(method string, payload []byte, config *Config, u *url.URL, req Requester) (*http.Header, error)

SetAuthHeaders Signture to header

func WsParamForPrivate

func WsParamForPrivate(sercret string) (now int, nonce, sign string)

WsParamForPrivate return util for private websocket

Types

type Client

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

func New

func New(config *Config) *Client

func (*Client) Addresses

func (c *Client) Addresses(req *address.Request) (*address.Response, error)

func (*Client) Balance

func (c *Client) Balance(req *balance.Request) (*balance.Response, error)

func (*Client) Balances

func (c *Client) Balances(req *list.RequestForBalances) (*list.ResponseForBalances, error)

func (*Client) Bankin

func (c *Client) Bankin(req *banks.RequestForIn) (*banks.ResponseForIn, error)

func (*Client) Bankout

func (c *Client) Bankout(req *banks.RequestForOut) (*banks.ResponseForOut, error)

func (*Client) Banks

func (c *Client) Banks(req *banks.RequestForBanks) (*banks.ResponseForBanks, error)

func (*Client) Board

func (c *Client) Board(req *board.Request) (*board.Response, error)

func (*Client) BoardHealth

func (c *Client) BoardHealth(req *health.RequestForBoard) (*health.Board, error)

func (*Client) CancelAll

func (c *Client) CancelAll(req *cancels.RequestForAllCancel) error

func (*Client) CancelByID

func (c *Client) CancelByID(req *cancels.RequestByID) error

func (*Client) CancelByIDForParent

func (c *Client) CancelByIDForParent(req *cancels.RequestByIDForParentCancel) error

func (*Client) Chats

func (c *Client) Chats(req *chat.Request) (*chat.Response, error)

func (*Client) ChildOrder

func (c *Client) ChildOrder(req *orders.RequestForChildOrder) (*orders.ResponseForChildOrder, error)

func (*Client) ChildOrders

func (c *Client) ChildOrders(req *list.RequestForChildOrders) (*list.ResponseForChildOrders, error)

一覧系

func (*Client) Coinin

func (c *Client) Coinin(req *coins.RequestForIn) (*coins.ResponseForIn, error)

func (*Client) Coinout

func (c *Client) Coinout(req *coins.RequestForOut) (*coins.ResponseForOut, error)

func (*Client) Collateral

func (c *Client) Collateral(req *collateral.Request) (*collateral.Response, error)

func (*Client) Collaterals

func (c *Client) Collaterals(req *list.RequestForCollaterals) (*list.ResponseForCollaterals, error)

func (*Client) Commission

func (c *Client) Commission(req *commission.Request) (*commission.Response, error)

func (*Client) Config

func (p *Client) Config() *Config

func (*Client) Do

func (p *Client) Do(req Requester, result interface{}) error

Do request APILimit.Private(req.Header) APILimit.Public(req.Header)

func (*Client) ExchangeHealth

func (c *Client) ExchangeHealth(req *health.RequestForExchange) (*health.Exchange, error)

func (*Client) Executions

func (c *Client) Executions(req *execution.Request) (*execution.Response, error)

func (*Client) Host

func (p *Client) Host() string

func (*Client) MyExecutions

func (c *Client) MyExecutions(req *list.RequestForExecutions) (*list.ResponseForExecutions, error)

func (*Client) ParentOrder

func (c *Client) ParentOrder(req *orders.RequestForParentOrder) (*orders.ResponseForParentOrder, error)

func (*Client) ParentOrders

func (c *Client) ParentOrders(req *list.RequestForParentOrders) (*list.ResponseForParentOrders, error)

func (*Client) Positions

func (c *Client) Positions(req *list.RequestForPositions) (*list.ResponseForPositions, error)

func (*Client) Ticker

func (c *Client) Ticker(req *ticker.Request) (*ticker.Response, error)

func (*Client) Withdraw

func (c *Client) Withdraw(req *banks.RequestForWithdraw) (*banks.ResponseForWithdraw, error)

type Config

type Config struct {
	Key    string
	Secret string
	// contains filtered or unexported fields
}

func (*Config) Check

func (p *Config) Check() *Config

type Headers

type Headers struct {
	Public  Limit
	Private Limit
}

APIHeaders 基本的には5分毎リセット

type Limit

type Limit struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Limit is API Limit, ForOrder is Order(child/parent), CancelAll

func NewLimit

func NewLimit(comparisonValue int) *Limit

func (*Limit) Check

func (p *Limit) Check() error

func (*Limit) CheckForOrder

func (p *Limit) CheckForOrder() error

CheckForOrder is check API limit for Order method

func (*Limit) Period

func (p *Limit) Period(isOrder bool) int

func (*Limit) Remain

func (p *Limit) Remain(isOrder bool) int

func (*Limit) Reset

func (p *Limit) Reset(isOrder bool) time.Time

func (*Limit) Set

func (p *Limit) Set(h http.Header)

Set X-xxxからLimitを取得 wg.Workgroup: 174748 6572 ns/op permutation: 414080 2934 ns/op

func (*Limit) SetThreshold

func (p *Limit) SetThreshold(i int)

type Requester

type Requester interface {
	Path() string
	Method() string
	Query() string
	Payload() []byte
}