Documentation
¶
Overview ¶
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.
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.
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.
Index ¶
Constants ¶
const ( NAMESPACE_ORDER_TOPIC_CONFIG = "ORDER_TOPIC_CONFIG" // namesrv维护顺序Topic的命名空间 NAMESPACE_PROJECT_CONFIG = "PROJECT_CONFIG" // broker注册过程，传递正常Topic的命名空间 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ConsumerOffsetSerializeWrapper ¶
type ConsumerOffsetSerializeWrapper struct {
OffsetTable *concurrent.ConcurrentMap `json:"offsetTable"` // key topic@group value:map[int]int64
}
ConsumerOffsetSerializeWrapper Consumer消费进度，序列化包装 Author gaoyanlei Since 2017/8/22
func NewConsumerOffsetSerializeWrapper ¶
func NewConsumerOffsetSerializeWrapper() *ConsumerOffsetSerializeWrapper
NewConsumerOffsetSerializeWrapper 初始化 Author gaoyanlei Since 2017/8/22
type RegisterBrokerResult ¶
type RegisterBrokerResult struct {
HaServerAddr string
MasterAddr string
KvTable *protocol.KVTable
}
func NewRegisterBrokerResult ¶
func NewRegisterBrokerResult(haServerAddr, masterAddr string) *RegisterBrokerResult
NewRegisterBrokerResult 初始化RegisterBrokerResult Author: tianyuliang Since: 2017/9/22
func (*RegisterBrokerResult) String ¶
func (result *RegisterBrokerResult) String() string
Source Files