68 lines
1.3 KiB
Go
68 lines
1.3 KiB
Go
package client
|
|
|
|
import (
|
|
"gitea.cdlsxd.cn/self-tools/l-dingtalk-stream-sdk-go/handler"
|
|
"time"
|
|
)
|
|
|
|
/**
|
|
* @Author linya.jj
|
|
* @Date 2023/3/22 14:48
|
|
*/
|
|
|
|
type ClientOption func(*StreamClient)
|
|
|
|
func WithAutoReconnect(autoReconnect bool) ClientOption {
|
|
return func(c *StreamClient) {
|
|
c.AutoReconnect = autoReconnect
|
|
}
|
|
}
|
|
|
|
func WithAppCredential(cred *AppCredentialConfig) ClientOption {
|
|
return func(c *StreamClient) {
|
|
c.AppCredential = cred
|
|
}
|
|
}
|
|
|
|
func WithSubscription(stype, stopic string, frameHandler handler.IFrameHandler) ClientOption {
|
|
return func(c *StreamClient) {
|
|
c.RegisterRouter(stype, stopic, frameHandler)
|
|
}
|
|
}
|
|
|
|
func WithKeepAlive(keepAliveIdle time.Duration) ClientOption {
|
|
return func(client *StreamClient) {
|
|
if keepAliveIdle >= 3*time.Second {
|
|
client.keepAliveIdle = keepAliveIdle
|
|
}
|
|
}
|
|
}
|
|
|
|
func WithUserAgent(ua *UserAgentConfig) ClientOption {
|
|
return func(c *StreamClient) {
|
|
if ua.Valid() != nil {
|
|
ua = NewDingtalkGoSDKUserAgent()
|
|
}
|
|
|
|
c.UserAgent = ua
|
|
}
|
|
}
|
|
|
|
func WithExtras(extras map[string]string) ClientOption {
|
|
return func(c *StreamClient) {
|
|
c.extras = extras
|
|
}
|
|
}
|
|
|
|
func WithOpenApiHost(host string) ClientOption {
|
|
return func(c *StreamClient) {
|
|
c.openApiHost = host
|
|
}
|
|
}
|
|
|
|
func WithProxy(proxy string) ClientOption {
|
|
return func(c *StreamClient) {
|
|
c.proxy = proxy
|
|
}
|
|
}
|