1 Star 0 Fork 0

NATS/graft

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
克隆/下载
chan_handler.go 2.11 KB
一键复制 编辑 原始数据 按行查看 历史
Derek Collison 提交于 2018-03-17 12:12 . Update license to Apache 2
// Copyright 2013-2018 The NATS Authors
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
package graft
// ChanHandler is a convenience handler when a user wants to simply use
// channels for the async handling of errors and state changes.
type ChanHandler struct {
StateMachineHandler
// Chan to receive state changes.
stateChangeChan chan<- StateChange
// Chan to receive errors.
errorChan chan<- error
}
// StateChange captures "from" and "to" States for the ChanHandler.
type StateChange struct {
// From is the previous state.
From State
// To is the new state.
To State
}
// NewChanHandler returns a Handler implementation which uses channels for
// handling errors and state changes.
func NewChanHandler(scCh chan<- StateChange, errCh chan<- error) *ChanHandler {
return NewChanHandlerWithStateMachine(new(defaultStateMachineHandler), scCh, errCh)
}
// NewChanHandlerWithStateMachine returns a Handler implementation which uses
// channels for handling errors and state changes and a StateMachineHandler for
// hooking into external state. The external state machine influences leader
// election votes.
func NewChanHandlerWithStateMachine(
stateHandler StateMachineHandler,
scCh chan<- StateChange,
errCh chan<- error) *ChanHandler {
return &ChanHandler{
StateMachineHandler: stateHandler,
stateChangeChan: scCh,
errorChan: errCh,
}
}
// Queue the state change onto the channel
func (chand *ChanHandler) StateChange(from, to State) {
chand.stateChangeChan <- StateChange{From: from, To: to}
}
// Queue the error onto the channel
func (chand *ChanHandler) AsyncError(err error) {
chand.errorChan <- err
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/nats-io/graft.git
[email protected]:nats-io/graft.git
nats-io
graft
graft
main

搜索帮助