Versions in this module Expand all Collapse all v0 v0.9.0 Nov 22, 2023 Changes in this version + type AppCredentialConfig struct + ClientId string + ClientSecret string + func NewAppCredentialConfig(clientId, clientSecret string) *AppCredentialConfig + func (c *AppCredentialConfig) Valid() error + type ClientOption func(*StreamClient) + func WithAppCredential(cred *AppCredentialConfig) ClientOption + func WithAutoReconnect(autoReconnect bool) ClientOption + func WithExtras(extras map[string]string) ClientOption + func WithOpenApiHost(host string) ClientOption + func WithProxy(proxy string) ClientOption + func WithSubscription(stype, stopic string, frameHandler handler.IFrameHandler) ClientOption + func WithUserAgent(ua *UserAgentConfig) ClientOption + type StreamClient struct + AppCredential *AppCredentialConfig + AutoReconnect bool + UserAgent *UserAgentConfig + func NewStreamClient(options ...ClientOption) *StreamClient + func (cli *StreamClient) CheckConfigValid() error + func (cli *StreamClient) Close() + func (cli *StreamClient) GetConnectionEndpoint(ctx context.Context) (*payload.ConnectionEndpointResponse, error) + func (cli *StreamClient) GetHandler(stype, stopic string) (handler.IFrameHandler, error) + func (cli *StreamClient) OnDisconnect(ctx context.Context, df *payload.DataFrame) (*payload.DataFrameResponse, error) + func (cli *StreamClient) OnPing(ctx context.Context, df *payload.DataFrame) (*payload.DataFrameResponse, error) + func (cli *StreamClient) RegisterAllEventRouter(frameHandler handler.IFrameHandler) + func (cli *StreamClient) RegisterCallbackRouter(topic string, frameHandler handler.IFrameHandler) + func (cli *StreamClient) RegisterCardCallbackRouter(messageHandler card.ICardCallbackHandler) + func (cli *StreamClient) RegisterChatBotCallbackRouter(messageHandler chatbot.IChatBotMessageHandler) + func (cli *StreamClient) RegisterEventRouter(topic string, frameHandler handler.IFrameHandler) + func (cli *StreamClient) RegisterPluginCallbackRouter(messageHandler plugin.IPluginMessageHandler) + func (cli *StreamClient) RegisterRouter(stype, stopic string, frameHandler handler.IFrameHandler) + func (cli *StreamClient) SendDataFrameResponse(ctx context.Context, resp *payload.DataFrameResponse) error + func (cli *StreamClient) Start(ctx context.Context) error + type UserAgentConfig struct + UserAgent string + func NewDingtalkGoSDKUserAgent() *UserAgentConfig + func (c *UserAgentConfig) Valid() error