Method starting

kv/memberlist/memberlist_client.go:609–650

(ctx context.Context)

}

func (m *KV) starting(ctx context.Context) error {
	mlCfg, err := m.buildMemberlistConfig()
	if err != nil {
		return err
	}

	// Wait for memberlist and broadcasts fields creation because
	// memberlist may start calling delegate methods if it
	// receives traffic.
	// See https://godoc.org/github.com/hashicorp/memberlist#Delegate
	//
	// Note: We cannot check for Starting state, as we want to use delegate during cluster joining process
	// that happens in Starting state.
	list, err := memberlist.Create(mlCfg)
	if err != nil {
		return fmt.Errorf("failed to create memberlist: %v", err)
	}
	// Finish delegate initialization.
	m.memberlist = list
	m.localBroadcasts = &memberlist.TransmitLimitedQueue{
		NumNodes:       list.NumMembers,
		RetransmitMult: mlCfg.RetransmitMult,
	}
	m.gossipBroadcasts = &memberlist.TransmitLimitedQueue{
		NumNodes:       list.NumMembers,
		RetransmitMult: mlCfg.RetransmitMult,
	}
	m.delegateReady.Store(true)

	// Try to fast-join memberlist cluster in Starting state, so that we don't start with empty KV store.
	if len(m.cfg.JoinMembers) > 0 {
		if err := m.fastJoinMembersOnStartup(ctx); err != nil {
			level.Error(m.logger).Log("msg", "failed to fast-join the memberlist cluster at startup", "err", err)

			if m.cfg.AbortIfFastJoinFails {
				return fmt.Errorf("failed to fast-join the memberlist cluster at startup: %w", err)
			}
		}
	}

	return nil
}

var errFailedToJoinCluster = errors.New("failed to join memberlist cluster on startup")