infra

package

v0.0.0-...-0b6fd40 Latest Latest Go to latest Published: Apr 8, 2025 License: MIT Imports: 27 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/FuYuanDe2024/kucoin-universal-sdk

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func IntToString(i int64) string
func NewDefaultWsService(option *types.ClientOption, domain string, private bool, sdkVersion string) interfaces.WebSocketService
func NewPingMessage() *types.WsMessage
func Sign(plain []byte, key []byte) []byte
type Callback
type CallbackManager
- func NewCallbackManager(topicPrefix string) *CallbackManager
- func (s *CallbackManager) Add(subInfo *util.SubInfo) (created bool)
- func (s *CallbackManager) Empty() bool
- func (s *CallbackManager) Get(topic string) interfaces.WebSocketMessageCallback
- func (s *CallbackManager) GetSubInfo() []*util.SubInfo
- func (s *CallbackManager) Remove(id string)
type DefaultTransport
- func NewDefaultTransport(clientOption *types.ClientOption, sdkVersion string) *DefaultTransport
- func (t *DefaultTransport) Call(ctx context.Context, domain string, broker bool, method string, path string, ...) error
- func (t *DefaultTransport) Close() error
- func (t *DefaultTransport) DoWithRetry(req *http.Request) (resp *http.Response, err error)
type DefaultWsService
- func (ws *DefaultWsService) Start() error
- func (ws *DefaultWsService) Stop() error
- func (ws *DefaultWsService) Subscribe(prefix string, args []string, callback interfaces.WebSocketMessageCallback) (id string, err error)
- func (ws *DefaultWsService) Unsubscribe(id string) (err error)
type DefaultWsTokenProvider
- func NewDefaultWsTokenProvider(transport interfaces.Transport, domain string, private bool) *DefaultWsTokenProvider
- func (p *DefaultWsTokenProvider) Close() error
- func (p *DefaultWsTokenProvider) GetToken() (error, []*interfaces.WsToken)
type KcSigner
- func NewKcSigner(key, secret, passPhrase, brokerName, brokerPartner, brokerKey string) *KcSigner
- func (ks *KcSigner) BrokerHeaders(plain string) map[string]string
- func (ks *KcSigner) Headers(plain string) map[string]string
type TopicManager
- func NewTopicManager() *TopicManager
- func (m *TopicManager) GetCallbackManager(topic string) *CallbackManager
- func (m *TopicManager) Range(f func(key, value any) bool)
type WebSocketClient
- func NewWebSocketClient(tokenProvider interfaces.WsTokenProvider, options *types.WebSocketClientOption) *WebSocketClient
- func (c *WebSocketClient) Read() <-chan *types.WsMessage
- func (c *WebSocketClient) Reconnected() <-chan struct{}
- func (c *WebSocketClient) Start() error
- func (c *WebSocketClient) Stop() error
- func (c *WebSocketClient) Write(ctx context.Context, ms *types.WsMessage) <-chan error

Constants ¶

View Source

const (
	PathPrivate = "/api/v1/bullet-private"
	PathPublic  = "/api/v1/bullet-public"
)

Variables ¶

This section is empty.

Functions ¶

func IntToString ¶

func IntToString(i int64) string

func NewDefaultWsService ¶

func NewDefaultWsService(option *types.ClientOption, domain string, private bool, sdkVersion string) interfaces.WebSocketService

func NewPingMessage ¶

func NewPingMessage() *types.WsMessage

func Sign ¶

func Sign(plain []byte, key []byte) []byte

Types ¶

type Callback ¶

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

type CallbackManager ¶

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

func NewCallbackManager ¶

func NewCallbackManager(topicPrefix string) *CallbackManager

func (*CallbackManager) Add ¶

func (s *CallbackManager) Add(subInfo *util.SubInfo) (created bool)

func (*CallbackManager) Empty ¶

func (s *CallbackManager) Empty() bool

func (*CallbackManager) Get ¶

func (s *CallbackManager) Get(topic string) interfaces.WebSocketMessageCallback

func (*CallbackManager) GetSubInfo ¶

func (s *CallbackManager) GetSubInfo() []*util.SubInfo

func (*CallbackManager) Remove ¶

func (s *CallbackManager) Remove(id string)

type DefaultTransport ¶

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

func NewDefaultTransport ¶

func NewDefaultTransport(clientOption *types.ClientOption, sdkVersion string) *DefaultTransport

func (*DefaultTransport) Call ¶

func (t *DefaultTransport) Call(ctx context.Context, domain string, broker bool, method string, path string,
	requestObj interface{}, responseObj interfaces.Response, requestJson bool) error

func (*DefaultTransport) Close ¶

func (t *DefaultTransport) Close() error

func (*DefaultTransport) DoWithRetry ¶

func (t *DefaultTransport) DoWithRetry(req *http.Request) (resp *http.Response, err error)

type DefaultWsService ¶

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

func (*DefaultWsService) Start ¶

func (ws *DefaultWsService) Start() error

func (*DefaultWsService) Stop ¶

func (ws *DefaultWsService) Stop() error

func (ws *DefaultWsService) Subscribe(prefix string, args []string, callback interfaces.WebSocketMessageCallback) (id string, err error)

func (*DefaultWsService) Unsubscribe ¶

func (ws *DefaultWsService) Unsubscribe(id string) (err error)

type DefaultWsTokenProvider ¶

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

func NewDefaultWsTokenProvider ¶

func NewDefaultWsTokenProvider(transport interfaces.Transport, domain string, private bool) *DefaultWsTokenProvider

func (*DefaultWsTokenProvider) Close ¶

func (p *DefaultWsTokenProvider) Close() error

func (*DefaultWsTokenProvider) GetToken ¶

func (p *DefaultWsTokenProvider) GetToken() (error, []*interfaces.WsToken)

type KcSigner ¶

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

KcSigner contains information about `apiKey`, `apiSecret`, `apiPassPhrase`, and `apiKeyVersion` and provides methods to sign and generate headers for API requests.

func NewKcSigner ¶

func NewKcSigner(key, secret, passPhrase, brokerName, brokerPartner, brokerKey string) *KcSigner

func (*KcSigner) BrokerHeaders ¶

func (ks *KcSigner) BrokerHeaders(plain string) map[string]string

func (*KcSigner) Headers ¶

func (ks *KcSigner) Headers(plain string) map[string]string

Headers method generates and returns a map of signature headers needed for API authorization It takes a plain string as an argument to help form the signature. The outputs are set of API headers,

type TopicManager ¶

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

func NewTopicManager ¶

func NewTopicManager() *TopicManager

func (*TopicManager) GetCallbackManager ¶

func (m *TopicManager) GetCallbackManager(topic string) *CallbackManager

func (*TopicManager) Range ¶

func (m *TopicManager) Range(f func(key, value any) bool)

type WebSocketClient ¶

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

WebSocketClient represents the WebSocket client

func NewWebSocketClient ¶

func NewWebSocketClient(tokenProvider interfaces.WsTokenProvider, options *types.WebSocketClientOption) *WebSocketClient

NewWebSocketClient creates a new WebSocketClient instance

func (*WebSocketClient) Read ¶

func (c *WebSocketClient) Read() <-chan *types.WsMessage

func (*WebSocketClient) Reconnected ¶

func (c *WebSocketClient) Reconnected() <-chan struct{}

func (*WebSocketClient) Start ¶

func (c *WebSocketClient) Start() error

Start establishes the WebSocket connection

func (*WebSocketClient) Stop ¶

func (c *WebSocketClient) Stop() error

Stop closes the WebSocket connection

func (*WebSocketClient) Write ¶

func (c *WebSocketClient) Write(ctx context.Context, ms *types.WsMessage) <-chan error

Source Files ¶

View all Source files

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