namesrv

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
• type ConsumerOffsetSerializeWrapper
  • func NewConsumerOffsetSerializeWrapper() *ConsumerOffsetSerializeWrapper
• type RegisterBrokerResult
  • func NewRegisterBrokerResult(haServerAddr, masterAddr string) *RegisterBrokerResult
  • func (result *RegisterBrokerResult) String() string

Constants

const (
	NAMESPACE_ORDER_TOPIC_CONFIG = "ORDER_TOPIC_CONFIG" // namesrv维护顺序Topic的命名空间
	NAMESPACE_PROJECT_CONFIG     = "PROJECT_CONFIG"     // broker注册过程，传递正常Topic的命名空间
)

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