Documentation
¶
Index ¶
- type BroadcastProxy
- type BroadcastService
- func (service *BroadcastService) Close()
- func (service *BroadcastService) Dispatch(w http.ResponseWriter, r *http.Request)
- func (service *BroadcastService) Ping(w http.ResponseWriter, r *http.Request)
- func (service *BroadcastService) Proxy(w http.ResponseWriter, r *http.Request)
- func (service *BroadcastService) SetAngryValue(w http.ResponseWriter, r *http.Request)
- func (service *BroadcastService) SetAngryValueV2(w http.ResponseWriter, r *http.Request)
- type CometDispatcher
- type ZkClient
- func (c *ZkClient) Close()
- func (c *ZkClient) CreateEphemeralNode(path string, node string, data []byte) (string, error)
- func (c *ZkClient) CreatePersistNode(path string, node string, data []byte) (string, error)
- func (c *ZkClient) DeleteNode(path string, node string) error
- func (c *ZkClient) Exists(path string, node string) (bool, int32, error)
- func (c *ZkClient) GetChildren(node string) ([]string, error)
- func (c *ZkClient) GetChildrenWithData(node string) (map[string]string, error)
- func (c *ZkClient) GetData(path string) (string, error)
- func (c *ZkClient) GetNodeData(path string, node string) ([]byte, int32, error)
- func (c *ZkClient) GetTimeout() time.Duration
- func (c *ZkClient) RecursiveCreate(path string) error
- func (c *ZkClient) Reset() error
- func (c *ZkClient) SetNodeData(path string, node string, data []byte, version int32) error
- func (c *ZkClient) WatchChildren(path string) (map[string]struct{}, <-chan zk.Event, error)
- func (c *ZkClient) WatchChildrenWithData(node string) (map[string]string, <-chan zk.Event, error)
- func (c *ZkClient) WatchData(path string) ([]byte, <-chan zk.Event, error)
- func (c *ZkClient) ZooKeeperPath(args ...string) string
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BroadcastProxy ¶
type BroadcastProxy struct {
// contains filtered or unexported fields
}
func NewBroadcastProxy ¶
func (*BroadcastProxy) Close ¶
func (proxy *BroadcastProxy) Close()
func (*BroadcastProxy) HandleRequest ¶
func (proxy *BroadcastProxy) HandleRequest(w http.ResponseWriter, r *http.Request)
func (*BroadcastProxy) RequestAllBackend ¶
func (proxy *BroadcastProxy) RequestAllBackend(method, uri string, requestBody []byte) ([]string, []error)
type BroadcastService ¶
type BroadcastService struct {
// contains filtered or unexported fields
}
func NewBroadcastService ¶
func NewBroadcastService(addr string, proxy *BroadcastProxy, dispatch *CometDispatcher) (*BroadcastService, error)
func (*BroadcastService) Close ¶
func (service *BroadcastService) Close()
func (*BroadcastService) Dispatch ¶
func (service *BroadcastService) Dispatch(w http.ResponseWriter, r *http.Request)
func (*BroadcastService) Ping ¶
func (service *BroadcastService) Ping(w http.ResponseWriter, r *http.Request)
func (*BroadcastService) Proxy ¶
func (service *BroadcastService) Proxy(w http.ResponseWriter, r *http.Request)
func (*BroadcastService) SetAngryValue ¶
func (service *BroadcastService) SetAngryValue(w http.ResponseWriter, r *http.Request)
func (*BroadcastService) SetAngryValueV2 ¶
func (service *BroadcastService) SetAngryValueV2(w http.ResponseWriter, r *http.Request)
type CometDispatcher ¶
type CometDispatcher struct {
// contains filtered or unexported fields
}
func NewCometDispatcher ¶
func NewCometDispatcher(ipipConfig *conf.IpipConfig, dispatchConfig *conf.DispatchConfig, svenConfig *conf.SvenConfig) (*CometDispatcher, error)
func (*CometDispatcher) Close ¶
func (dispatcher *CometDispatcher) Close()
type ZkClient ¶
type ZkClient struct {
// contains filtered or unexported fields
}
func (*ZkClient) CreateEphemeralNode ¶
func (*ZkClient) CreatePersistNode ¶
func (*ZkClient) GetChildrenWithData ¶
func (*ZkClient) GetNodeData ¶
func (*ZkClient) GetTimeout ¶
func (*ZkClient) RecursiveCreate ¶
func (*ZkClient) SetNodeData ¶
func (*ZkClient) WatchChildren ¶
func (*ZkClient) WatchChildrenWithData ¶
func (*ZkClient) ZooKeeperPath ¶
Source Files
Click to show internal directories.
Click to hide internal directories.