Golang types.Sentinel类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Go›Go教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Golang中github.com/jrmConduce/redishappy/types.Sentinel类的典型用法代码示例。如果您正苦于以下问题：Golang Sentinel类的具体用法？Golang Sentinel怎么用？Golang Sentinel使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了Sentinel类的7个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Golang代码示例。

示例1: TestCanMarkSentinelsAlive

func TestCanMarkSentinelsAlive(t *testing.T) {

	state := NewSentinelState(func(_ types.Sentinel) {})
	sentinel := types.Sentinel{Host: "10.1.1.2", Port: 12345}
	sentinelMessage := SentinelAdded{Sentinel: sentinel}
	sentinelPingMessage := SentinelPing{Sentinel: sentinel}
	state.Notify(&sentinelMessage)
	state.Notify(&sentinelPingMessage)

	responseChannel := make(chan SentinelTopology)
	state.GetState(TopologyRequest{ReplyChannel: responseChannel})

	topologyState := <-responseChannel

	if len(topologyState.Sentinels) != 1 {
		t.Error("Topology count should be 1")
	}

	sen, _ := topologyState.FindSentinelInfo(sentinel)

	if sen.SentinelLocation != sentinel.GetLocation() {
		t.Error("Wrong host found")
	}

	if sen.State != SentinelMarkedAlive {
		t.Error("Sentinel in wrong state")
	}
}

开发者ID:jrmConduce，项目名称:redishappy，代码行数:28，代码来源:sentinels_test.go

示例2: TestCanAddCLustersToSentinel

func TestCanAddCLustersToSentinel(t *testing.T) {

	state := NewSentinelState(func(_ types.Sentinel) {})
	sentinel := types.Sentinel{Host: "10.1.1.2", Port: 12345}

	sentinelMessage := SentinelAdded{Sentinel: sentinel}
	sentinelInfoMessage := SentinelClustersMonitoredUpdate{Sentinel: sentinel, Clusters: []string{"A"}}

	state.Notify(&sentinelMessage)
	state.Notify(&sentinelInfoMessage)

	responseChannel := make(chan SentinelTopology)
	state.GetState(TopologyRequest{ReplyChannel: responseChannel})

	topologyState := <-responseChannel

	if len(topologyState.Sentinels) != 1 {
		t.Error("Topology count should be 1")
	}

	sen, _ := topologyState.FindSentinelInfo(sentinel)

	if sen.SentinelLocation != sentinel.GetLocation() {
		t.Error("Wrong host found")
	}

	if len(sen.Clusters) != 1 {
		t.Error("Wrong number of clusters")
	}

	if sen.Clusters[0] != "A" {
		t.Error("Wrong cluster found")
	}
}

开发者ID:jrmConduce，项目名称:redishappy，代码行数:34，代码来源:sentinels_test.go

示例3: TestCanMarkSentinelsDown

func TestCanMarkSentinelsDown(t *testing.T) {

	state := NewSentinelState(func(_ types.Sentinel) {})
	sentinel := types.Sentinel{Host: "10.1.1.2", Port: 12345}

	sentinelAddedMessage := &SentinelAdded{Sentinel: sentinel}
	sentinelLostMessage := &SentinelLost{Sentinel: sentinel}

	responseChannel := make(chan SentinelTopology)

	state.Notify(sentinelAddedMessage)
	state.Notify(sentinelLostMessage)

	state.GetState(TopologyRequest{ReplyChannel: responseChannel})
	topologyState := <-responseChannel
	fmt.Print(util.String(topologyState))

	if len(topologyState.Sentinels) != 1 {
		t.Error("Topology count should be 1")
	}

	sen, _ := topologyState.FindSentinelInfo(sentinel)

	if sen.SentinelLocation != sentinel.GetLocation() {
		t.Error("Wrong host found")
	}

	if sen.State != SentinelMarkedDown {
		t.Errorf("Sentinel in wrong state : %d", sen.State)
	}
}

开发者ID:jrmConduce，项目名称:redishappy，代码行数:31，代码来源:sentinels_test.go

示例4: NewMonitor

func NewMonitor(sentinel types.Sentinel, manager Manager, redisConnection redis.RedisConnection) (*Monitor, error) {

	uri := sentinel.GetLocation()

	channel := make(chan redis.RedisPubSubReply)
	pubSubClient, err := redis.NewPubSubClient(uri, channel, redisConnection)

	if err != nil {
		return nil, err
	}

	client, err := redis.NewSentinelClient(sentinel, redisConnection)

	if err != nil {
		return nil, err
	}

	monitor := &Monitor{pubSubClient: pubSubClient,
		client:          client,
		channel:         channel,
		manager:         manager,
		sentinel:        sentinel,
		redisConnection: redisConnection}
	return monitor, nil
}

开发者ID:jrmConduce，项目名称:redishappy，代码行数:25，代码来源:monitor.go

示例5: startNewMonitor

func (m *SentinelManager) startNewMonitor(sentinel types.Sentinel) {

	monitor, err := NewMonitor(sentinel, m, m.redisConnection)

	if err != nil {
		logger.Error.Printf("Error starting monitor %s : %s", sentinel.GetLocation(), err.Error())
		m.Notify(&SentinelLost{Sentinel: sentinel})
		return
	}

	err = monitor.StartMonitoringMasterEvents(m.switchmasterchannel)

	if err != nil {
		logger.Error.Printf("Error starting monitoring events %s : %s", sentinel.GetLocation(), err.Error())
		m.Notify(&SentinelLost{Sentinel: sentinel})
	}
}

开发者ID:jrmConduce，项目名称:redishappy，代码行数:17，代码来源:manager.go

示例6: NewSentinelClient

func NewSentinelClient(sentinel types.Sentinel, redisConnection RedisConnection) (*SentinelClient, error) {

	uri := sentinel.GetLocation()

	redisclient, err := redisConnection.GetConnection("tcp", uri)

	if err != nil {
		logger.Info.Printf("SentinelClient : not connected to %s, %s", uri, err.Error())
		return nil, err
	}

	client := &SentinelClient{
		redisClient: redisclient,
		sentinel:    sentinel,
	}

	return client, nil
}

开发者ID:jrmConduce，项目名称:redishappy，代码行数:18，代码来源:sentinelclient.go

示例7: createKey

func (topology SentinelTopology) createKey(sentinel types.Sentinel) string {
	return sentinel.GetLocation()
}

开发者ID:jrmConduce，项目名称:redishappy，代码行数:3，代码来源:manager_types.go

注：本文中的github.com/jrmConduce/redishappy/types.Sentinel类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。